diff options
Diffstat (limited to 'lib/python2.7/site-packages/buildbot-0.8.8-py2.7.egg/buildbot/schedulers/basic.py')
| -rw-r--r-- | lib/python2.7/site-packages/buildbot-0.8.8-py2.7.egg/buildbot/schedulers/basic.py | 256 |
1 files changed, 0 insertions, 256 deletions
diff --git a/lib/python2.7/site-packages/buildbot-0.8.8-py2.7.egg/buildbot/schedulers/basic.py b/lib/python2.7/site-packages/buildbot-0.8.8-py2.7.egg/buildbot/schedulers/basic.py deleted file mode 100644 index a2b9f19c..00000000 --- a/lib/python2.7/site-packages/buildbot-0.8.8-py2.7.egg/buildbot/schedulers/basic.py +++ /dev/null @@ -1,256 +0,0 @@ -# This file is part of Buildbot. Buildbot is free software: you can -# redistribute it and/or modify it under the terms of the GNU General Public -# License as published by the Free Software Foundation, version 2. -# -# This program is distributed in the hope that it will be useful, but WITHOUT -# ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS -# FOR A PARTICULAR PURPOSE. See the GNU General Public License for more -# details. -# -# You should have received a copy of the GNU General Public License along with -# this program; if not, write to the Free Software Foundation, Inc., 51 -# Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. -# -# Copyright Buildbot Team Members - -from twisted.internet import defer, reactor -from twisted.python import log -from buildbot import util, config -from buildbot.util import NotABranch -from collections import defaultdict -from buildbot.changes import filter, changes -from buildbot.schedulers import base, dependent - -class BaseBasicScheduler(base.BaseScheduler): - """ - @param onlyImportant: If True, only important changes will be added to the - buildset. - @type onlyImportant: boolean - - """ - - compare_attrs = (base.BaseScheduler.compare_attrs + - ('treeStableTimer', 'change_filter', 'fileIsImportant', - 'onlyImportant') ) - - _reactor = reactor # for tests - - fileIsImportant = None - - class NotSet: pass - def __init__(self, name, shouldntBeSet=NotSet, treeStableTimer=None, - builderNames=None, branch=NotABranch, branches=NotABranch, - fileIsImportant=None, properties={}, categories=None, - change_filter=None, onlyImportant=False, **kwargs): - if shouldntBeSet is not self.NotSet: - config.error( - "pass arguments to schedulers using keyword arguments") - if fileIsImportant and not callable(fileIsImportant): - config.error( - "fileIsImportant must be a callable") - - # initialize parent classes - base.BaseScheduler.__init__(self, name, builderNames, properties, **kwargs) - - self.treeStableTimer = treeStableTimer - if fileIsImportant is not None: - self.fileIsImportant = fileIsImportant - self.onlyImportant = onlyImportant - self.change_filter = self.getChangeFilter(branch=branch, - branches=branches, change_filter=change_filter, - categories=categories) - - # the IDelayedCall used to wake up when this scheduler's - # treeStableTimer expires. - self._stable_timers = defaultdict(lambda : None) - self._stable_timers_lock = defer.DeferredLock() - - def getChangeFilter(self, branch, branches, change_filter, categories): - raise NotImplementedError - - def startService(self, _returnDeferred=False): - base.BaseScheduler.startService(self) - - d = self.startConsumingChanges(fileIsImportant=self.fileIsImportant, - change_filter=self.change_filter, - onlyImportant=self.onlyImportant) - - # if treeStableTimer is False, then we don't care about classified - # changes, so get rid of any hanging around from previous - # configurations - if not self.treeStableTimer: - d.addCallback(lambda _ : - self.master.db.schedulers.flushChangeClassifications( - self.objectid)) - - # otherwise, if there are classified changes out there, start their - # treeStableTimers again - else: - d.addCallback(lambda _ : - self.scanExistingClassifiedChanges()) - - # handle Deferred errors, since startService does not return a Deferred - d.addErrback(log.err, "while starting SingleBranchScheduler '%s'" - % self.name) - - if _returnDeferred: - return d # only used in tests - - def stopService(self): - # the base stopService will unsubscribe from new changes - d = base.BaseScheduler.stopService(self) - @util.deferredLocked(self._stable_timers_lock) - def cancel_timers(_): - for timer in self._stable_timers.values(): - if timer: - timer.cancel() - self._stable_timers.clear() - d.addCallback(cancel_timers) - return d - - @util.deferredLocked('_stable_timers_lock') - def gotChange(self, change, important): - if not self.treeStableTimer: - # if there's no treeStableTimer, we can completely ignore - # unimportant changes - if not important: - return defer.succeed(None) - # otherwise, we'll build it right away - return self.addBuildsetForChanges(reason='scheduler', - changeids=[ change.number ]) - - timer_name = self.getTimerNameForChange(change) - - # if we have a treeStableTimer, then record the change's importance - # and: - # - for an important change, start the timer - # - for an unimportant change, reset the timer if it is running - d = self.master.db.schedulers.classifyChanges( - self.objectid, { change.number : important }) - def fix_timer(_): - if not important and not self._stable_timers[timer_name]: - return - if self._stable_timers[timer_name]: - self._stable_timers[timer_name].cancel() - def fire_timer(): - d = self.stableTimerFired(timer_name) - d.addErrback(log.err, "while firing stable timer") - self._stable_timers[timer_name] = self._reactor.callLater( - self.treeStableTimer, fire_timer) - d.addCallback(fix_timer) - return d - - @defer.inlineCallbacks - def scanExistingClassifiedChanges(self): - # call gotChange for each classified change. This is called at startup - # and is intended to re-start the treeStableTimer for any changes that - # had not yet been built when the scheduler was stopped. - - # NOTE: this may double-call gotChange for changes that arrive just as - # the scheduler starts up. In practice, this doesn't hurt anything. - classifications = \ - yield self.master.db.schedulers.getChangeClassifications( - self.objectid) - - # call gotChange for each change, after first fetching it from the db - for changeid, important in classifications.iteritems(): - chdict = yield self.master.db.changes.getChange(changeid) - - if not chdict: - continue - - change = yield changes.Change.fromChdict(self.master, chdict) - yield self.gotChange(change, important) - - def getTimerNameForChange(self, change): - raise NotImplementedError # see subclasses - - def getChangeClassificationsForTimer(self, objectid, timer_name): - """similar to db.schedulers.getChangeClassifications, but given timer - name""" - raise NotImplementedError # see subclasses - - @util.deferredLocked('_stable_timers_lock') - @defer.inlineCallbacks - def stableTimerFired(self, timer_name): - # if the service has already been stoppd then just bail out - if not self._stable_timers[timer_name]: - return - - # delete this now-fired timer - del self._stable_timers[timer_name] - - classifications = \ - yield self.getChangeClassificationsForTimer(self.objectid, - timer_name) - - # just in case: databases do weird things sometimes! - if not classifications: # pragma: no cover - return - - changeids = sorted(classifications.keys()) - yield self.addBuildsetForChanges(reason='scheduler', - changeids=changeids) - - max_changeid = changeids[-1] # (changeids are sorted) - yield self.master.db.schedulers.flushChangeClassifications( - self.objectid, less_than=max_changeid+1) - - def getPendingBuildTimes(self): - # This isn't locked, since the caller expects and immediate value, - # and in any case, this is only an estimate. - return [timer.getTime() for timer in self._stable_timers.values() if timer and timer.active()] - -class SingleBranchScheduler(BaseBasicScheduler): - def getChangeFilter(self, branch, branches, change_filter, categories): - if branch is NotABranch and not change_filter: - config.error( - "the 'branch' argument to SingleBranchScheduler is " + - "mandatory unless change_filter is provided") - elif branches is not NotABranch: - config.error( - "the 'branches' argument is not allowed for " + - "SingleBranchScheduler") - - - return filter.ChangeFilter.fromSchedulerConstructorArgs( - change_filter=change_filter, branch=branch, - categories=categories) - - def getTimerNameForChange(self, change): - return "only" # this class only uses one timer - - def getChangeClassificationsForTimer(self, objectid, timer_name): - return self.master.db.schedulers.getChangeClassifications( - self.objectid) - - -class Scheduler(SingleBranchScheduler): - "alias for SingleBranchScheduler" - def __init__(self, *args, **kwargs): - log.msg("WARNING: the name 'Scheduler' is deprecated; use " + - "buildbot.schedulers.basic.SingleBranchScheduler instead " + - "(note that this may require you to change your import " + - "statement)") - SingleBranchScheduler.__init__(self, *args, **kwargs) - - -class AnyBranchScheduler(BaseBasicScheduler): - def getChangeFilter(self, branch, branches, change_filter, categories): - assert branch is NotABranch - return filter.ChangeFilter.fromSchedulerConstructorArgs( - change_filter=change_filter, branch=branches, - categories=categories) - - def getTimerNameForChange(self, change): - # Py2.6+: could be a namedtuple - return (change.codebase, change.project, change.repository, change.branch) - - def getChangeClassificationsForTimer(self, objectid, timer_name): - codebase, project, repository, branch = timer_name # set in getTimerNameForChange - return self.master.db.schedulers.getChangeClassifications( - self.objectid, branch=branch, repository=repository, - codebase=codebase, project=project) - -# now at buildbot.schedulers.dependent, but keep the old name alive -Dependent = dependent.Dependent |