import logger
import accounts
+import database
# there is an implicit assumption that this triggers after slicemanager
priority = 45
# this instructs nodemanager that we want to use the latest known data in case the plc link is down
persistent_data = True
-# of course things would be simpler if node manager was to create one instance of the plugins
+# of course things would be simpler if node manager was to create one instance of the plugins
# instead of blindly caling functions in the module...
##############################
klass._instance=klass(*args,**kwds)
return klass._instance
-def start(options, conf):
- return Singleton(reservation).start(options,conf)
+def start():
+ return Singleton(reservation).start()
def GetSlivers(data, conf = None, plc = None):
return Singleton(reservation).GetSlivers(data, conf, plc)
self.data = None
# this is a dict mapping a raounded timestamp to the corr. Timer object
self.timers = {}
-
+
####################
- def start(self,options,conf):
+ def start(self):
logger.log("reservation: plugin performing dummy start...")
- # this method is entirely about making sure that we have events scheduled
+ # this method is entirely about making sure that we have events scheduled
# at the <granularity> intervals where there is a lease that starts or ends
def GetSlivers (self, data, conf=None, plc=None):
-
+
# check we're using a compliant GetSlivers
- if 'reservation_policy' not in data:
+ if 'reservation_policy' not in data:
logger.log_missing_data("reservation.GetSlivers",'reservation_policy')
return
reservation_policy=data['reservation_policy']
- if 'leases' not in data:
+ if 'leases' not in data:
logger.log_missing_data("reservation.GetSlivers",'leases')
return
# 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 ')
-
+
self.sync_timers_from_leases()
if reservation.debug:
self.list_timers()
self.timers[round]=timer
timer.start()
-
+
@staticmethod
def time_printable (timestamp):
return time.strftime ("%Y-%m-%d %H:%M UTC",time.gmtime(timestamp))
else:
logger.log("reservation.granularity_callback: mmh, the sliver is unexpectedly not running, starting it...")
self.restart_slice(slicename)
+ return
# otherwise things are simple
- if ending_lease: self.suspend_slice (ending_lease['name'])
- if starting_lease: self.restart_slice (starting_lease['name'])
+ if ending_lease:
+ self.suspend_slice (ending_lease['name'])
+ if not starting_lease:
+ logger.log("'lease_or_shared' is xxx todo - would restart to shared mode")
+ # only lease_or_idle available : we freeze the box
+ self.suspend_all_slices()
+ else:
+ self.restart_slice(starting_lease['name'])
+ return
+
+ # no ending, just one starting
+ logger.log("'lease_or_shared' is xxx todo - would stop shared mode")
+ # in lease_or_idle, all it takes is restart the sliver
+ self.restart_slice (starting_lease['name'])
+ return
def debug_box(self,message,slicename=None):
if reservation.debug:
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
- # quick an d dirty - this does not obey the accounts/sliver_vs/controller hierarchy
+ # quick an d dirty - this does not obey the accounts/sliver_vs/controller hierarchy
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)
-
+
+ def suspend_all_slices (self):
+ for sliver in self.data['slivers']:
+ # is this a system sliver ?
+ system_slice=False
+ for d in sliver['attributes']:
+ if d['tagname']=='system' and d['value'] : system_slice=True
+ if not system_slice:
+ self.suspend_slice(sliver['name'])
+
def restart_slice(self, slicename):
logger.log('reservation: Restarting slice %s'%(slicename))
self.debug_box('before restarting',slicename)
worker=accounts.get(slicename)
try:
# dig in self.data to retrieve corresponding rec
- slivers = [ sliver for sliver in self.data.slivers if sliver['name']==slicename ]
+ slivers = [ sliver for sliver in self.data['slivers'] if sliver['name']==slicename ]
sliver=slivers[0]
-
- #
+ record=database.db.get(slicename)
+ record['enabled']=True
+ #
logger.verbose("reservation: Located worker object %r"%worker)
- worker.start(rec)
+ logger.verbose("reservation: Located record at the db %r"%record)
+ worker.start(record)
except:
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)
-
git://git.onelab.eu / nodemanager.git / blobdiff