####################
def start(self,options,conf):
logger.log("reservation: plugin performing dummy start...")
####################
def start(self,options,conf):
logger.log("reservation: plugin performing dummy start...")
# at the <granularity> intervals where there is a lease that starts or ends
def GetSlivers (self, data, conf=None, plc=None):
# at the <granularity> intervals where there is a lease that starts or ends
def GetSlivers (self, data, conf=None, plc=None):
logger.log_missing_data("reservation.GetSlivers",'reservation_policy')
return
reservation_policy=data['reservation_policy']
logger.log_missing_data("reservation.GetSlivers",'reservation_policy')
return
reservation_policy=data['reservation_policy']
# at this point we have reservation_policy in ['lease_or_idle','lease_or_shared']
# we make no difference for now
logger.verbose('reservation.GetSlivers : reservable node -- listing timers ')
# at this point we have reservation_policy in ['lease_or_idle','lease_or_shared']
# we make no difference for now
logger.verbose('reservation.GetSlivers : reservable node -- listing timers ')
@staticmethod
def time_printable (timestamp):
return time.strftime ("%Y-%m-%d %H:%M UTC",time.gmtime(timestamp))
@staticmethod
def time_printable (timestamp):
return time.strftime ("%Y-%m-%d %H:%M UTC",time.gmtime(timestamp))
self.suspend_slice (ending_lease['name'])
if not starting_lease:
logger.log("'lease_or_shared' is xxx todo - would restart to shared mode")
self.suspend_slice (ending_lease['name'])
if not starting_lease:
logger.log("'lease_or_shared' is xxx todo - would restart to shared mode")
logger.log_call( ['/usr/sbin/vserver-stat', ] )
if slicename:
logger.log_call ( ['/usr/sbin/vserver',slicename,'status', ])
logger.log_call( ['/usr/sbin/vserver-stat', ] )
if slicename:
logger.log_call ( ['/usr/sbin/vserver',slicename,'status', ])
def is_running (self, slicename):
try:
return accounts.get(slicename).is_running()
except:
return False
def is_running (self, slicename):
try:
return accounts.get(slicename).is_running()
except:
return False
def suspend_slice(self, slicename):
logger.log('reservation: Suspending slice %s'%(slicename))
self.debug_box('before suspending',slicename)
def suspend_slice(self, slicename):
logger.log('reservation: Suspending slice %s'%(slicename))
self.debug_box('before suspending',slicename)
logger.log_exc("reservation.suspend_slice: Could not stop slice %s through its worker"%slicename)
# we hope the status line won't return anything
self.debug_box('after suspending',slicename)
logger.log_exc("reservation.suspend_slice: Could not stop slice %s through its worker"%slicename)
# we hope the status line won't return anything
self.debug_box('after suspending',slicename)
def suspend_all_slices (self):
for sliver in self.data['slivers']:
# is this a system sliver ?
def suspend_all_slices (self):
for sliver in self.data['slivers']:
# is this a system sliver ?
logger.verbose("reservation: Located worker object %r"%worker)
logger.verbose("reservation: Located record at the db %r"%record)
worker.start(record)
logger.verbose("reservation: Located worker object %r"%worker)
logger.verbose("reservation: Located record at the db %r"%record)
worker.start(record)
logger.log_exc("reservation.restart_slice: Could not start slice %s through its worker"%slicename)
# we hope the status line won't return anything
self.debug_box('after restarting',slicename)
logger.log_exc("reservation.restart_slice: Could not start slice %s through its worker"%slicename)
# we hope the status line won't return anything
self.debug_box('after restarting',slicename)