Package flumotion :: Package twisted :: Module fdserver :: Class FDPassingBroker
[hide private]

Class FDPassingBroker

source code

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

A pb.Broker subclass that handles FDs being passed to it (with associated data) over the same connection as the normal PB data stream. When an FD is seen, it creates new protocol objects for them from the childFactory attribute.

Instance Methods [hide private]
 
__init__(self, childFactory, 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 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, childFactory, connectionClass, **kwargs)
(Constructor)

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