Trees | Index | Help |
---|
Package flumotion :: Package job :: Module job :: Class JobClientBroker |
|
Ephemeral
--+ |BaseProtocol
--+ | | |Protocol
--+ |Banana
--+ |Broker
--+ |Loggable
--+ | JobClientBroker
Method Summary | |
---|---|
| |
fileDescriptorsReceived(self,
fds,
message)
| |
Inherited from Broker | |
| |
Returns an ID that says what this instance is cached as remotely, or None if it's not. | |
(internal) | |
XXX | |
| |
The connection was lost. | |
Initialize. | |
(internal) Send a DECACHE directive. | |
Remove a callback from list of disconnect callbacks. | |
Evaluate an expression as it's received. | |
Get a local object for a locally unique ID. | |
Generate a new LUID. | |
Generate a new request ID. | |
Call the given callback when the Broker connects. | |
Call the given callback when the Broker disconnects. | |
Call the given callback if the Broker fails to connect. | |
| |
(internal) Got an answer to a previously sent message. | |
| |
(internal) Decrement the reference count of a cached object. | |
(internal) Decrement the reference count of an object. | |
Respond to stock ' didNotUnderstand ' message. | |
(internal) Deal with an error. | |
| |
(internal) Tell the client it is now OK to uncache an object. | |
Protocol message: (version version-number) | |
| |
Get an ID for a local object. | |
Returns an object from the remote name mapping. | |
Returns an instance which is cached remotely, with this LUID. | |
Called when the consumer attached to me runs out of buffer. | |
Utility method to send an expression to the other side of the connection. | |
(internal) Send a DECREF directive. | |
Jelly an object according to the remote security rules for this broker. | |
Store a special (string) ID for this object. | |
| |
Unjelly an sexp according to the local security rules for this broker. | |
Received a message-send. | |
(internal) Send an answer to a previously sent message. | |
(internal) Send an error for a previously sent message. | |
Log error and then send it. | |
Call _sendError or _sendFailure , depending on whether
fail represents an Error subclass or not. | |
| |
Inherited from Banana | |
| |
Called when a connection is made. | |
| |
| |
| |
Set the prefix limit for decoding done by this protocol instance. | |
| |
| |
Inherited from BaseProtocol | |
Make a connection to a transport and a server. | |
Inherited from Ephemeral | |
| |
| |
Inherited from Loggable | |
Log a debug message. | |
dict |
Log a message at the given level, with the possibility of going higher up in the stack. |
Log an error. | |
Log an informational message. | |
Log a log message. | |
Overridable log function. | |
Overridable object name function. | |
Log a warning. | |
Log a warning about a Failure. |
Class Variable Summary | |
---|---|
Inherited from Broker | |
NoneType |
factory = None |
int |
maxBrokerRefsViolations = 0 |
NoneType |
username = None |
int |
version = 6 |
NoneType |
waitingForAnswers = None |
Inherited from Banana | |
str |
buffer = ''
|
dict |
incomingVocabulary = {1: 'None', 2: 'class', 3: 'derefer...
|
str |
k = 'lcache'
|
list |
knownDialects = ['pb', 'none']
|
dict |
outgoingVocabulary = {'reference': 4, 'uncache': 31, 'mo...
|
NoneType |
prefixLimit = None |
int |
sizeLimit = 655360 |
int |
v = 18 |
Inherited from Protocol | |
Implements |
__implemented__ = <implementedBy twisted.internet.protoc...
|
ClassProvides |
__provides__ = <zope.interface.declarations.ClassProvide...
|
Inherited from BaseProtocol | |
ClassProvides |
__providedBy__ = <zope.interface.declarations.ClassProvi...
|
int |
connected = 0 |
NoneType |
transport = None |
Inherited from Loggable | |
str |
logCategory : Implementors can provide a category to log their messages under. |
Method Details |
---|
__init__(self,
connectionClass,
**kwargs)
|
Trees | Index | Help |
---|
Generated by Epydoc 2.1 on Fri Apr 6 10:10:24 2007 | http://epydoc.sf.net |