|
__init__(self,
isClient=1,
security=globalSecurity) |
|
|
|
resumeProducing(self)
Called when the consumer attached to me runs out of buffer. |
|
|
|
|
|
|
|
registerPageProducer(self,
pager) |
|
|
|
|
|
proto_version(self,
vnum)
Protocol message: (version version-number) |
|
|
|
sendCall(self,
*exp)
Utility method to send an expression to the other side of the
connection. |
|
|
|
|
|
|
|
|
|
|
|
notifyOnDisconnect(self,
notifier)
Call the given callback when the Broker disconnects. |
|
|
|
notifyOnFail(self,
notifier)
Call the given callback if the Broker fails to connect. |
|
|
|
notifyOnConnect(self,
notifier)
Call the given callback when the Broker connects. |
|
|
|
dontNotifyOnDisconnect(self,
notifier)
Remove a callback from list of disconnect callbacks. |
|
|
|
|
|
|
|
setNameForLocal(self,
name,
object)
Store a special (string) ID for this object. |
|
|
|
remoteForName(self,
name)
Returns an object from the remote name mapping. |
|
|
|
cachedRemotelyAs(self,
instance,
incref=0)
Returns an ID that says what this instance is cached as remotely,
or None if it's not. |
|
|
|
remotelyCachedForLUID(self,
luid)
Returns an instance which is cached remotely, with this LUID. |
|
|
|
cacheRemotely(self,
instance)
XXX |
|
|
|
|
|
cachedLocallyAs(self,
cid) |
|
|
|
serialize(self,
object,
perspective=None,
method=None,
args=None,
kw=None)
Jelly an object according to the remote security rules for this
broker. |
|
|
|
unserialize(self,
sexp,
perspective=None)
Unjelly an sexp according to the local security rules for this
broker. |
|
|
|
newLocalID(self)
Generate a new LUID. |
|
|
|
newRequestID(self)
Generate a new request ID. |
|
|
|
_sendMessage(self,
prefix,
perspective,
objectID,
message,
args,
kw) |
|
|
|
proto_message(self,
requestID,
objectID,
message,
answerRequired,
netArgs,
netKw) |
|
|
|
proto_cachemessage(self,
requestID,
objectID,
message,
answerRequired,
netArgs,
netKw) |
|
|
|
_recvMessage(self,
findObjMethod,
requestID,
objectID,
message,
answerRequired,
netArgs,
netKw)
Received a message-send. |
|
|
|
_sendAnswer(self,
netResult,
requestID)
(internal) Send an answer to a previously sent message. |
|
|
|
proto_answer(self,
requestID,
netResult)
(internal) Got an answer to a previously sent message. |
|
|
|
_sendFailureOrError(self,
fail,
requestID)
Call _sendError or _sendFailure , depending on whether
fail represents an Error
subclass or not. |
|
|
|
_sendFailure(self,
fail,
requestID)
Log error and then send it. |
|
|
|
_sendError(self,
fail,
requestID)
(internal) Send an error for a previously sent message. |
|
|
|
proto_error(self,
requestID,
fail)
(internal) Deal with an error. |
|
|
|
sendDecRef(self,
objectID)
(internal) Send a DECREF directive. |
|
|
|
proto_decref(self,
objectID)
(internal) Decrement the reference count of an object. |
|
|
|
decCacheRef(self,
objectID)
(internal) Send a DECACHE directive. |
|
|
|
proto_decache(self,
objectID)
(internal) Decrement the reference count of a cached object. |
|
|
|
proto_uncache(self,
objectID)
(internal) Tell the client it is now OK to uncache an object. |
|
|
Inherited from banana.Banana :
callExpressionReceived ,
connectionMade ,
dataReceived ,
gotItem ,
sendEncoded ,
setPrefixLimit
Inherited from banana.Banana (private):
_encode ,
_selectDialect
Inherited from internet.protocol.BaseProtocol :
__providedBy__ ,
makeConnection
Inherited from persisted.styles.Ephemeral :
__getstate__ ,
__setstate__
|