X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;f=database.py;h=96664af7d08ac690096a84dade3f6e103c97afc2;hb=refs%2Fheads%2F2.0;hp=c990364ef6b306e1fa8c4f37d9d62ac1bc8e8fcb;hpb=d3a3b2d3ea98e72183d1cb5497c38badaa0c5863;p=nodemanager.git diff --git a/database.py b/database.py index c990364..96664af 100644 --- a/database.py +++ b/database.py @@ -1,6 +1,4 @@ -# $Id$ -# $URL$ - +# """The database houses information on slivers. This information reaches the sliver manager in two different ways: one, through the GetSlivers() call made periodically; two, by users delivering tickets. @@ -19,7 +17,8 @@ import cPickle import threading import time -import accounts +import account +import coresched import logger import tools import bwmon @@ -120,18 +119,24 @@ It may be necessary in the future to do something smarter.""" self._compute_effective_rspecs() + try: + x = coresched.CoreSched() + x.adjustCores(self) + except: + logger.log_exc("database: exception while doing core sched") + # create and destroy accounts as needed logger.verbose("database: sync : fetching accounts") - existing_acct_names = accounts.all() + existing_acct_names = account.all() for name in existing_acct_names: if name not in self: logger.verbose("database: sync : ensure_destroy'ing %s"%name) - accounts.get(name).ensure_destroyed() + account.get(name).ensure_destroyed() for name, rec in self.iteritems(): # protect this; if anything fails for a given sliver # we still need the other ones to be handled try: - sliver = accounts.get(name) + sliver = account.get(name) logger.verbose("database: sync : looping on %s (shell account class from pwd %s)" %(name,sliver._get_class())) # Make sure we refresh accounts that are running if rec['instantiation'] == 'plc-instantiated':