Trees | Indices | Help |
|
---|
|
1 # This file is part of Buildbot. Buildbot is free software: you can 2 # redistribute it and/or modify it under the terms of the GNU General Public 3 # License as published by the Free Software Foundation, version 2. 4 # 5 # This program is distributed in the hope that it will be useful, but WITHOUT 6 # ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS 7 # FOR A PARTICULAR PURPOSE. See the GNU General Public License for more 8 # details. 9 # 10 # You should have received a copy of the GNU General Public License along with 11 # this program; if not, write to the Free Software Foundation, Inc., 51 12 # Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. 13 # 14 # Copyright Buildbot Team Members 15 16 from twisted.internet import defer 17 from twisted.python import log 18 from buildbot.util import loop 19 from buildbot.util import collections 20 from buildbot.util.eventual import eventually 218024 loop.MultiServiceLoop.__init__(self) 25 self.master = master 26 self.db = db 27 self.change_svc = change_svc 28 self.upstream_subscribers = collections.defaultdict(list)2931 """Add and start any Scheduler that isn't already a child of ours. 32 Stop and remove any that are no longer in the list. Make sure each 33 one has a schedulerid in the database.""" 34 # TODO: this won't tolerate reentrance very well 35 new_names = set() 36 added = set() 37 removed = set() 38 for s in newschedulers: 39 new_names.add(s.name) 40 try: 41 old = self.getServiceNamed(s.name) 42 except KeyError: 43 old = None 44 if old: 45 if old.compareToOther(s): 46 removed.add(old) 47 added.add(s) 48 else: 49 pass # unchanged 50 else: 51 added.add(s) 52 for old in list(self): 53 if old.name not in new_names: 54 removed.add(old) 55 #if removed or added: 56 # # notify Downstream schedulers to potentially pick up 57 # # new schedulers now that we have removed and added some 58 # def updateDownstreams(res): 59 # log.msg("notifying downstream schedulers of changes") 60 # for s in newschedulers: 61 # if interfaces.IDownstreamScheduler.providedBy(s): 62 # s.checkUpstreamScheduler() 63 # d.addCallback(updateDownstreams) 64 log.msg("removing %d old schedulers, adding %d new ones" 65 % (len(removed), len(added))) 66 dl = [defer.maybeDeferred(s.disownServiceParent) for s in removed] 67 d = defer.gatherResults(dl) 68 d.addCallback(lambda ign: self.db.addSchedulers(added)) 69 def _attach(ign): 70 for s in added: 71 s.setServiceParent(self) 72 self.upstream_subscribers = collections.defaultdict(list) 73 for s in list(self): 74 if s.upstream_name: 75 self.upstream_subscribers[s.upstream_name].append(s) 76 eventually(self.trigger)77 d.addCallback(_attach) 78 d.addErrback(log.err) 79 return d82 if upstream_name in self.upstream_subscribers: 83 for s in self.upstream_subscribers[upstream_name]: 84 s.buildSetSubmitted(bsid, t)8587 self.trigger()89 # TODO: this could just run the schedulers that have subscribed to 90 # scheduler_upstream_buildsets, or even just the ones that subscribed 91 # to hear about the specific buildsetid 92 self.trigger()93
Trees | Indices | Help |
|
---|
Generated by Epydoc 3.0.1 on Sun Dec 19 18:26:51 2010 | http://epydoc.sourceforge.net |