Package flumotion :: Package job :: Module job :: Class JobClientBroker
[hide private]

Class JobClientBroker

source code

twisted.internet.protocol.BaseProtocol --+            
                                         |            
        twisted.internet.protocol.Protocol --+        
                                             |        
        twisted.persisted.styles.Ephemeral --+        
                                             |        
                  twisted.spread.banana.Banana --+    
                                                 |    
                          twisted.spread.pb.Broker --+
                                                     |
                               common.log.Loggable --+
                                                     |
                                                    JobClientBroker

A pb.Broker subclass that handles FDs being passed (with associated data) over the same connection as the normal PB data stream. When an FD is seen, the FD should be added to a given eater or feeder element.

Instance Methods [hide private]
 
__init__(self, connectionClass, **kwargs) source code
 
fileDescriptorsReceived(self, fds, message) source code

Inherited from twisted.spread.pb.Broker: cacheLocally, cacheRemotely, cachedLocallyAs, cachedRemotelyAs, connectionFailed, connectionLost, connectionReady, decCacheRef, dontNotifyOnDisconnect, expressionReceived, localObjectForID, newLocalID, newRequestID, notifyOnConnect, notifyOnDisconnect, notifyOnFail, pauseProducing, proto_answer, proto_cachemessage, proto_decache, proto_decref, proto_didNotUnderstand, proto_error, proto_message, proto_uncache, proto_version, registerPageProducer, registerReference, remoteForName, remotelyCachedForLUID, resumeProducing, sendCall, sendDecRef, serialize, setNameForLocal, stopProducing, unserialize

Inherited from twisted.spread.banana.Banana: callExpressionReceived, connectionMade, dataReceived, gotItem, sendEncoded, setPrefixLimit

Inherited from twisted.spread.banana.Banana (private): _encode, _selectDialect

Inherited from twisted.internet.protocol.BaseProtocol: __providedBy__, makeConnection

Inherited from twisted.persisted.styles.Ephemeral: __getstate__, __setstate__

Inherited from common.log.Loggable: debug, doLog, error, info, log, logFunction, logObjectName, warning, warningFailure

Class Variables [hide private]

Inherited from twisted.spread.pb.Broker: factory, maxBrokerRefsViolations, username, version, waitingForAnswers

Inherited from twisted.spread.banana.Banana: buffer, incomingVocabulary, k, knownDialects, outgoingVocabulary, prefixLimit, sizeLimit, v

Inherited from twisted.internet.protocol.Protocol: __implemented__, __provides__

Inherited from twisted.internet.protocol.BaseProtocol: connected, transport

Inherited from common.log.Loggable: logCategory

Method Details [hide private]

__init__(self, connectionClass, **kwargs)
(Constructor)

source code 
Parameters:
  • connectionClass - a subclass of twisted.internet.tcp.Connection
Overrides: twisted.spread.banana.Banana.__init__