Package flumotion :: Package job :: Module job :: Class JobClientBroker

Class JobClientBroker

twisted.internet.protocol.BaseProtocol --+            
                                         |            
        twisted.internet.protocol.Protocol --+        
                                             |        
        twisted.persisted.styles.Ephemeral --+        
                                             |        
                  twisted.spread.banana.Banana --+    
                                                 |    
                          twisted.spread.pb.Broker --+
                                                     |
                           extern.log.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.pb.Broker (private): _recvMessage, _sendAnswer, _sendError, _sendFailure, _sendFailureOrError, _sendMessage

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 extern.log.log.Loggable: debug, doLog, error, info, log, logFunction, logObjectName, warning, warningFailure, writeMarker

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 extern.log.log.Loggable: logCategory

Method Details

[hide private]

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

source code

Parameters:

connectionClass - subclass of twisted.internet.tcp.Connection

Overrides: twisted.spread.banana.Banana.__init__

Class JobClientBroker

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

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