|
| __init__ (self, dcFileNames=None, dcSuffix='', connectMethod=None, threadedNet=None) |
|
| allocateDoId (self) |
|
| createDistributedObject (self, className=None, distObj=None, zoneId=0, optionalFields=None, doId=None, reserveDoId=False) |
|
| createReady (self) |
|
| deleteObject (self, doId) |
|
| formatGenerate (self, distObj, extraFields) |
|
| freeDoId (self, doId) |
|
| getAvatarIdFromSender (self) |
|
| handleDatagram (self, di) |
|
| handleDelete (self, di) |
|
| handleDisable (self, di) |
|
| handleGenerate (self, di) |
|
| handleMessageType (self, msgType, di) |
|
| handleRequestGenerates (self, di) |
|
| handleSetDoIdrange (self, di) |
|
| handleUpdateField (self, di) |
|
| haveCreateAuthority (self) |
|
| isLocalId (self, doId) |
|
| resendGenerate (self, obj) |
|
| reserveDoId (self, doId) |
|
| sendDeleteMsg (self, doId) |
|
| sendDisconnect (self) |
|
| sendHeartbeat (self) |
|
| sendSetLocation (self, doId, parentId, zoneId) |
|
| sendUpdate (self, distObj, fieldName, args) |
|
| sendUpdateToChannel (self, distObj, channelId, fieldName, args) |
|
| setInterestZones (self, interestZoneIds) |
|
| setObjectZone (self, distObj, zoneId) |
|
| stopTrackRequestDeletedDO (self, *args) |
|
| storeObjectLocation (self, object, parentId, zoneId) |
|
| allocateContext (self) |
|
| considerHeartbeat (self) |
|
| disableDoId (self, doId, ownerView=False) |
|
| doDeferredGenerate (self, task) |
|
| doGenerate (self, parentId, zoneId, classId, doId, di) |
|
| flushGenerates (self) |
|
| generateWithRequiredFields (self, dclass, doId, di, parentId, zoneId) |
|
| generateWithRequiredOtherFields (self, dclass, doId, di, parentId=None, zoneId=None) |
|
| generateWithRequiredOtherFieldsOwner (self, dclass, doId, di) |
|
| getObjectsOfClass (self, objClass) |
|
| getObjectsOfExactClass (self, objClass) |
|
| getServerDelta (self) |
|
| getServerTimeOfDay (self) |
|
| getTables (self, ownerView) |
|
| getWorld (self, doId) |
|
| handleGoGetLost (self, di) |
|
| handleServerHeartbeat (self, di) |
|
| handleSystemMessage (self, di) |
|
| handleSystemMessageAknowledge (self, di) |
|
| isLive (self) |
|
| printDelayDeletes (self) |
|
| replaceMethod (self, oldMethod, newFunction) |
|
| replayDeferredGenerate (self, msgType, extra) |
|
| sendHeartbeatTask (self, task) |
|
| setDeferInterval (self, deferInterval) |
|
| setServerDelta (self, delta) |
|
| specialName (self, label) |
| def queryObjectAll(self, doID, context=0): """ Get a one-time snapshot look at the object.
|
|
| startHeartbeat (self) |
|
| stopHeartbeat (self) |
|
| waitForNextHeartBeat (self) |
|
| checkHttp (self) |
|
| connect (self, serverList, successCallback=None, successArgs=[], failureCallback=None, failureArgs=[]) |
|
| disconnect (self) |
|
| generateGlobalObject (self, doId, dcname, values=None) |
|
| getServerAddress (self) |
|
| handleReaderOverflow (self) |
|
| httpConnectCallback (self, ch, serverList, serverIndex, successCallback, successArgs, failureCallback, failureArgs) |
|
| importModule (self, dcImports, moduleName, importSymbols) |
|
| lostConnection (self) |
|
| readDCFile (self, dcFileNames=None) |
|
| readerPollOnce (self) |
|
| readerPollUntilEmpty (self, task) |
|
| send (self, datagram) |
|
| shutdown (self) |
|
| startReaderPollTask (self) |
|
| stopReaderPollTask (self) |
|
| addAutoInterest (self, parentId, zoneIdList, description) |
|
| addInterest (self, parentId, zoneIdList, description, event=None) |
|
| alterInterest (self, handle, parentId, zoneIdList, description=None, event=None) |
|
| cleanupWaitAllInterestsComplete (self) |
|
| closeAutoInterests (self, obj) |
|
| getAllInterestsCompleteEvent (self) |
|
| handleInterestDoneMessage (self, di) |
|
| isValidInterestHandle (self, handle) |
|
| noNewInterests (self) |
|
| openAutoInterests (self, obj) |
|
| printInterestHistory (self) |
|
| printInterests (self) |
|
| printInterestSets (self) |
|
| printInterestsIfDebug (self) |
|
| queueAllInterestsCompleteEvent (self, frames=5) |
|
| removeAIInterest (self, handle) |
|
| removeAutoInterest (self, handle) |
|
| removeInterest (self, handle, event=None) |
|
| resetInterestStateForConnectionLoss (self) |
|
| setAllInterestsCompleteCallback (self, callback) |
|
| setNoNewInterests (self, flag) |
|
| updateInterestDescription (self, handle, desc) |
|
| addDOToTables (self, do, location=None, ownerView=False) |
|
| callbackWithDo (self, doId, callback) |
|
| callbackWithOwnerView (self, doId, callback) |
|
| countObjects (self, classType) |
|
| deleteDistributedObjects (self) |
|
| deleteObjectLocation (self, object, parentId, zoneId) |
|
| doByDistance (self) |
|
| doFind (self, str) |
|
| doFindAll (self, str) |
|
| doFindAllInstances (self, cls) |
|
| doFindAllMatching (self, str) |
|
| doFindAllOfType (self, query) |
|
| dosByDistance (self) |
|
| findAnyOfType (self, type) |
|
| getAllOfType (self, type) |
|
| getDo (self, doId) |
|
| getDoIdList (self, parentId, zoneId=None, classType=None) |
|
| getDoList (self, parentId, zoneId=None, classType=None) |
|
| getDoTable (self, ownerView) |
|
| getGameDoId (self) |
|
| getObjectsInZone (self, parentId, zoneId) |
| def changeDOZoneInTables(self, do, newParentId, newZoneId, oldParentId, oldZoneId): if 1: self.storeObjectLocation(do.doId, newParentId, newZoneId) else: #assert not hasattr(do, "isQueryAllResponse") or not do.isQueryAllResponse oldLocation = (oldParentId, oldZoneId) newLocation = (newParentId, newZoneId)
|
|
| getObjectsOfClassInZone (self, parentId, zoneId, objClass) |
|
| getOwnerView (self, doId) |
|
| getOwnerViewDoIdList (self, classType) |
|
| getOwnerViewDoList (self, classType) |
|
| handleObjectLocation (self, di) |
|
| handleSetLocation (self, di) |
|
| hasOwnerViewDoId (self, doId) |
|
| isInDoTables (self, doId) |
|
| isValidLocationTuple (self, location) |
|
| printObjectCount (self) |
|
| printObjects (self) |
|
| removeDOFromTables (self, do) |
|
| webPrintObjectCount (self) |
|
Public Member Functions inherited from CConnectionRepository |
| __init__ (bool has_owner_view, bool threaded_net) |
|
| abandonMessageBundles () |
| throw out any msgs that have been queued up for message bundles
|
|
| bundleMsg (const Datagram dg) |
|
bool | checkDatagram () |
| Returns true if a new datagram is available, false otherwise.
|
|
bool | connectNative (const URLSpec url) |
| Connects to the server using Panda's low-level and fast "native net" library.
|
|
bool | considerFlush () |
| Sends the most recently queued data if enough time has elapsed.
|
|
| disconnect () |
| Closes the connection to the server.
|
|
bool | flush () |
| Sends the most recently queued data now.
|
|
BufferedDatagramConnection | getBdc () |
| Returns the Buffered_DatagramConnection object associated with the repository.
|
|
bool | getClientDatagram () |
| Returns the client_datagram flag.
|
|
ConnectionWriter | getCw () |
| Returns the ConnectionWriter object associated with the repository.
|
|
| getDatagram (Datagram dg) |
| Fills the datagram object with the datagram most recently retrieved by check_datagram().
|
|
| getDatagramIterator (DatagramIterator di) |
| Fills the DatagramIterator object with the iterator for the datagram most recently retrieved by check_datagram().
|
|
DCFile | getDcFile () |
| Returns the DCFile object associated with this repository.
|
|
bool | getHandleCUpdates () |
| Returns true if this repository will process distributed updates internally in C++ code, or false if it will return them to Python.
|
|
bool | getHandleDatagramsInternally () |
| Returns the handle_datagrams_internally flag.
|
|
bool | getInQuietZone () |
| Returns true if repository is in quiet zone mode.
|
|
CHANNELTYPE | getMsgChannel (int offset) |
| Returns the channel(s) to which the current message was sent, according to the datagram headers.
|
|
int | getMsgChannelCount () |
|
CHANNELTYPE | getMsgSender () |
| Returns the sender ID of the current message, according to the datagram headers.
|
|
unsigned int | getMsgType () |
| Returns the type ID of the current message, according to the datagram headers.
|
|
QueuedConnectionManager | getQcm () |
| Returns the QueuedConnectionManager object associated with the repository.
|
|
QueuedConnectionReader | getQcr () |
| Returns the QueuedConnectionReader object associated with the repository.
|
|
bool | getSimulatedDisconnect () |
| Returns the simulated disconnect flag.
|
|
SocketStream | getStream () |
| Returns the SocketStream that internally represents the already-established HTTP connection.
|
|
int | getTcpHeaderSize () |
| Returns the current setting of TCP header size.
|
|
float | getTimeWarning () |
| Returns the current setting of the time_warning field.
|
|
bool | getVerbose () |
| Returns the current setting of the verbose flag.
|
|
bool | getWantMessageBundling () |
| Returns true if message bundling enabled.
|
|
bool | hasOwnerView () |
| Returns true if this repository can have 'owner' views of distributed objects.
|
|
bool | isBundlingMessages () |
| Returns true if repository is queueing outgoing messages into a message bundle.
|
|
bool | isConnected () |
| Returns true if the connection to the gameserver is established and still good, false if we are not connected.
|
|
bool | sendDatagram (const Datagram dg) |
| Queues the indicated datagram for sending to the server.
|
|
| sendMessageBundle (unsigned int channel, unsigned int sender_channel) |
| Send network messages queued up since startMessageBundle was called.
|
|
| setClientDatagram (bool client_datagram) |
| Sets the client_datagram flag.
|
|
| setConnectionHttp (HTTPChannel channel) |
| Once a connection has been established via the HTTP interface, gets the connection and uses it.
|
|
| setHandleCUpdates (bool handle_c_updates) |
| Set true to specify this repository should process distributed updates internally in C++ code, or false if it should return them to Python.
|
|
| setHandleDatagramsInternally (bool handle_datagrams_internally) |
| Sets the handle_datagrams_internally flag.
|
|
| setInQuietZone (bool flag) |
| Enables/disables quiet zone mode.
|
|
| setPythonRepository (object python_repository) |
| Records the pointer to the Python class that derives from CConnectionRepository.
|
|
| setSimulatedDisconnect (bool simulated_disconnect) |
| Sets the simulated disconnect flag.
|
|
| setTcpHeaderSize (int tcp_header_size) |
| Sets the header size of TCP packets.
|
|
| setTimeWarning (float time_warning) |
| Directly sets the time_warning field.
|
|
| setVerbose (bool verbose) |
| Directly sets the verbose flag.
|
|
| setWantMessageBundling (bool flag) |
| Enable/disable outbound message bundling.
|
|
| shutdown () |
| May be called at application shutdown to ensure all threads are cleaned up.
|
|
| startMessageBundle () |
| Send a set of messages to the state server that will be processed atomically.
|
|
| toggleVerbose () |
| Toggles the current setting of the verbose flag.
|
|
bool | tryConnectNet (const URLSpec url) |
| Uses Panda's "net" library to try to connect to the server and port named in the indicated URL.
|
|