Trees | Indices | Help |
|
---|
|
1 ########################################################################### 2 # 3 # This program is part of Zenoss Core, an open source monitoring platform. 4 # Copyright (C) 2007, Zenoss Inc. 5 # 6 # This program is free software; you can redistribute it and/or modify it 7 # under the terms of the GNU General Public License version 2 or (at your 8 # option) any later version as published by the Free Software Foundation. 9 # 10 # For complete information please visit: http://www.zenoss.com/oss/ 11 # 12 ########################################################################### 13 from twisted.spread import pb 14 15 import logging 16 import time 17 import socket 18208222 self.log = logging.getLogger('zen.hub') 23 self.fqdn = socket.getfqdn() 24 self.dmd = dmd 25 self.zem = dmd.ZenEventManager 26 self.instance = instance 27 self.listeners = [] 28 self.callTime = 0. 29 self.methodPriorityMap = {}30 3335 self.log.debug("Servicing %s in %s", message, self.name()) 36 now = time.time() 37 try: 38 return pb.Referenceable.remoteMessageReceived(self, broker, message, args, kw) 39 finally: 40 secs = time.time() - now 41 self.log.debug("Time in %s: %.2f", message, secs) 42 self.callTime += secs43 47 5153 return self.__class__.__name__5456 remote.notifyOnDisconnect(self.removeListener) 57 self.log.debug("adding listener for %s:%s", self.instance, self.name()) 58 self.listeners.append(remote)5961 self.log.debug("removing listener for %s:%s", self.instance, self.name()) 62 try: 63 self.listeners.remove(listener) 64 except ValueError: 65 self.warning("Unable to remove listener... ignoring")6668 if methodName in self.methodPriorityMap: 69 return self.methodPriorityMap[methodName] 70 return 0.27173 map(self.sendEvent, events)74
Trees | Indices | Help |
|
---|
Generated by Epydoc 3.0.1.1812 on Tue Oct 11 12:51:41 2011 | http://epydoc.sourceforge.net |