Public Member Functions | Public Attributes | Static Public Attributes | List of all members
ConnectionRepository Class Reference
Inheritance diagram for ConnectionRepository:
DoInterestManager DoCollectionManager CConnectionRepository ClientRepositoryBase ClientRepository

Public Member Functions

def __init__ (self, connectMethod, config, hasOwnerView=False, threadedNet=None)
def checkHttp (self)
def connect (self, serverList, successCallback=None, successArgs=[], failureCallback=None, failureArgs=[])
def disconnect (self)
def generateGlobalObject (self, doId, dcname, values=None)
def getServerAddress (self)
def handleDatagram (self, di)
def handleReaderOverflow (self)
def httpConnectCallback (self, ch, serverList, serverIndex, successCallback, successArgs, failureCallback, failureArgs)
def importModule (self, dcImports, moduleName, importSymbols)
def lostConnection (self)
def readDCFile (self, dcFileNames=None)
def readerPollOnce (self)
def readerPollUntilEmpty (self, task)
def send (self, datagram)
def shutdown (self)
def startReaderPollTask (self)
def stopReaderPollTask (self)
- Public Member Functions inherited from DoInterestManager
def __init__ (self)
def addAutoInterest (self, parentId, zoneIdList, description)
def addInterest (self, parentId, zoneIdList, description, event=None)
def alterInterest (self, handle, parentId, zoneIdList, description=None, event=None)
def cleanupWaitAllInterestsComplete (self)
def closeAutoInterests (self, obj)
def getAllInterestsCompleteEvent (self)
def handleInterestDoneMessage (self, di)
def isValidInterestHandle (self, handle)
def noNewInterests (self)
def openAutoInterests (self, obj)
def printInterestHistory (self)
def printInterests (self)
def printInterestSets (self)
def printInterestsIfDebug (self)
def queueAllInterestsCompleteEvent (self, frames=5)
def removeAIInterest (self, handle)
def removeAutoInterest (self, handle)
def removeInterest (self, handle, event=None)
def resetInterestStateForConnectionLoss (self)
def setAllInterestsCompleteCallback (self, callback)
def setNoNewInterests (self, flag)
def updateInterestDescription (self, handle, desc)
- Public Member Functions inherited from DoCollectionManager
def __init__ (self)
def addDOToTables (self, do, location=None, ownerView=False)
def callbackWithDo (self, doId, callback)
def callbackWithOwnerView (self, doId, callback)
def countObjects (self, classType)
def deleteDistributedObjects (self)
def deleteObjectLocation (self, object, parentId, zoneId)
def doByDistance (self)
def doFind (self, str)
def doFindAll (self, str)
def doFindAllInstances (self, cls)
def doFindAllMatching (self, str)
def doFindAllOfType (self, query)
def dosByDistance (self)
def findAnyOfType (self, type)
def getAllOfType (self, type)
def getDo (self, doId)
def getDoIdList (self, parentId, zoneId=None, classType=None)
def getDoList (self, parentId, zoneId=None, classType=None)
def getDoTable (self, ownerView)
def getGameDoId (self)
def 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) More...
def getObjectsOfClassInZone (self, parentId, zoneId, objClass)
def getOwnerView (self, doId)
def getOwnerViewDoIdList (self, classType)
def getOwnerViewDoList (self, classType)
def handleObjectLocation (self, di)
def handleSetLocation (self, di)
def hasOwnerViewDoId (self, doId)
def isInDoTables (self, doId)
def isValidLocationTuple (self, location)
def printObjectCount (self)
def printObjects (self)
def removeDOFromTables (self, do)
def storeObjectLocation (self, object, parentId, zoneId)
def 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 More...
 bundleMsg (const Datagram dg)
bool checkDatagram ()
 Returns true if a new datagram is available, false otherwise. More...
bool connectNative (const URLSpec url)
 Connects to the server using Panda's low-level and fast "native net" library. More...
bool considerFlush ()
 Sends the most recently queued data if enough time has elapsed. More...
 disconnect ()
 Closes the connection to the server. More...
bool flush ()
 Sends the most recently queued data now. More...
BufferedDatagramConnection getBdc ()
 Returns the Buffered_DatagramConnection object associated with the repository. More...
bool getClientDatagram ()
 Returns the client_datagram flag. More...
ConnectionWriter getCw ()
 Returns the ConnectionWriter object associated with the repository. More...
 getDatagram (Datagram dg)
 Fills the datagram object with the datagram most recently retrieved by check_datagram(). More...
 getDatagramIterator (DatagramIterator di)
 Fills the DatagramIterator object with the iterator for the datagram most recently retrieved by check_datagram(). More...
DCFile getDcFile ()
 Returns the DCFile object associated with this repository. More...
bool getHandleCUpdates ()
 Returns true if this repository will process distributed updates internally in C++ code, or false if it will return them to Python. More...
bool getHandleDatagramsInternally ()
 Returns the handle_datagrams_internally flag. More...
bool getInQuietZone ()
 Returns true if repository is in quiet zone mode. More...
CHANNELTYPE getMsgChannel (int offset)
 Returns the channel(s) to which the current message was sent, according to the datagram headers. More...
int getMsgChannelCount ()
CHANNELTYPE getMsgSender ()
 Returns the sender ID of the current message, according to the datagram headers. More...
unsigned int getMsgType ()
 Returns the type ID of the current message, according to the datagram headers. More...
QueuedConnectionManager getQcm ()
 Returns the QueuedConnectionManager object associated with the repository. More...
QueuedConnectionReader getQcr ()
 Returns the QueuedConnectionReader object associated with the repository. More...
bool getSimulatedDisconnect ()
 Returns the simulated disconnect flag. More...
SocketStream getStream ()
 Returns the SocketStream that internally represents the already-established HTTP connection. More...
int getTcpHeaderSize ()
 Returns the current setting of TCP header size. More...
float getTimeWarning ()
 Returns the current setting of the time_warning field. More...
bool getVerbose ()
 Returns the current setting of the verbose flag. More...
bool getWantMessageBundling ()
 Returns true if message bundling enabled. More...
bool hasOwnerView ()
 Returns true if this repository can have 'owner' views of distributed objects. More...
bool isBundlingMessages ()
 Returns true if repository is queueing outgoing messages into a message bundle. More...
bool isConnected ()
 Returns true if the connection to the gameserver is established and still good, false if we are not connected. More...
bool sendDatagram (const Datagram dg)
 Queues the indicated datagram for sending to the server. More...
 sendMessageBundle (unsigned int channel, unsigned int sender_channel)
 Send network messages queued up since startMessageBundle was called. More...
 setClientDatagram (bool client_datagram)
 Sets the client_datagram flag. More...
 setConnectionHttp (HTTPChannel channel)
 Once a connection has been established via the HTTP interface, gets the connection and uses it. More...
 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. More...
 setHandleDatagramsInternally (bool handle_datagrams_internally)
 Sets the handle_datagrams_internally flag. More...
 setInQuietZone (bool flag)
 Enables/disables quiet zone mode. More...
 setPythonRepository (object python_repository)
 Records the pointer to the Python class that derives from CConnectionRepository. More...
 setSimulatedDisconnect (bool simulated_disconnect)
 Sets the simulated disconnect flag. More...
 setTcpHeaderSize (int tcp_header_size)
 Sets the header size of TCP packets. More...
 setTimeWarning (float time_warning)
 Directly sets the time_warning field. More...
 setVerbose (bool verbose)
 Directly sets the verbose flag. More...
 setWantMessageBundling (bool flag)
 Enable/disable outbound message bundling. More...
 shutdown ()
 May be called at application shutdown to ensure all threads are cleaned up. More...
 startMessageBundle ()
 Send a set of messages to the state server that will be processed atomically. More...
 toggleVerbose ()
 Toggles the current setting of the verbose flag. More...
bool tryConnectNet (const URLSpec url)
 Uses Panda's "net" library to try to connect to the server and port named in the indicated URL. More...

Public Attributes

 if self.recorder and self.recorder.isPlaying(): More...
- Public Attributes inherited from DoCollectionManager
 self.zoneId2doIds={} More...

Static Public Attributes

int CM_HTTP = 0
int CM_NATIVE = 2
int CM_NET = 1
string GarbageCollectTaskName = "allowGarbageCollect"
string GarbageThresholdTaskName = "adjustGarbageCollectThreshold"
 gcNotify = directNotify.newCategory("GarbageCollect")
 notify = directNotify.newCategory("ConnectionRepository")
 taskChain = None
int taskPriority = -30
- Static Public Attributes inherited from DoInterestManager
 InterestDebug = ConfigVariableBool('interest-debug', False)
 notify = directNotify.newCategory("DoInterestManager")

Additional Inherited Members

- Static Public Member Functions inherited from CConnectionRepository
static str getOverflowEventName ()
 Returns event string that will be thrown if the datagram reader queue overflows. More...

Detailed Description

This is a base class for things that know how to establish a
connection (and exchange datagrams) with a gameserver.  This
includes ClientRepository and AIRepository.

Constructor & Destructor Documentation

◆ __init__()

def __init__ (   self,
  hasOwnerView = False,
  threadedNet = None 

Reimplemented in ClientRepository, and ClientRepositoryBase.

Member Function Documentation

◆ checkHttp()

def checkHttp (   self)

◆ connect()

def connect (   self,
  successCallback = None,
  successArgs = [],
  failureCallback = None,
  failureArgs = [] 
Attempts to establish a connection to the server.  May return
before the connection is established.  The two callbacks
represent the two functions to call (and their arguments) on
success or failure, respectively.  The failure callback also
gets one additional parameter, which will be passed in first:
the return status code giving reason for failure, if it is

◆ disconnect()

def disconnect (   self)
Closes the previously-established connection.

◆ generateGlobalObject()

def generateGlobalObject (   self,
  values = None 

◆ getServerAddress()

def getServerAddress (   self)

◆ handleDatagram()

def handleDatagram (   self,

Reimplemented in ClientRepository.

◆ handleReaderOverflow()

def handleReaderOverflow (   self)

◆ httpConnectCallback()

def httpConnectCallback (   self,

◆ importModule()

def importModule (   self,
Imports the indicated moduleName and all of its symbols
into the current namespace.  This more-or-less reimplements
the Python import command.

◆ lostConnection()

def lostConnection (   self)

◆ readDCFile()

def readDCFile (   self,
  dcFileNames = None 
Reads in the dc files listed in dcFileNames, or if
dcFileNames is None, reads in all of the dc files listed in
the Config.prc file.

◆ readerPollOnce()

def readerPollOnce (   self)

◆ readerPollUntilEmpty()

def readerPollUntilEmpty (   self,

◆ send()

def send (   self,

◆ shutdown()

def shutdown (   self)

◆ startReaderPollTask()

def startReaderPollTask (   self)

◆ stopReaderPollTask()

def stopReaderPollTask (   self)

Member Data Documentation

◆ bootedIndex


if self.recorder and self.recorder.isPlaying():

If we have a recorder and it's already in playback mode,

don't actually attempt to connect to a gameserver since

we don't need to. Just let it play back the data."Not connecting to gameserver; using playback data instead.") self.connectHttp = 1 self.tcpConn = SocketStreamRecorder() self.recorder.addRecorder('gameserver', self.tcpConn) self.startReaderPollTask() if successCallback: successCallback(*successArgs) return

◆ bootedText



int CM_HTTP = 0


int CM_NATIVE = 2


int CM_NET = 1

◆ config


◆ connectHttp


◆ connectMethod


◆ dclassesByName


◆ dclassesByNumber


◆ dcSuffix


◆ GarbageCollectTaskName

string GarbageCollectTaskName = "allowGarbageCollect"

◆ GarbageThresholdTaskName

string GarbageThresholdTaskName = "adjustGarbageCollectThreshold"

◆ gcNotify

gcNotify = directNotify.newCategory("GarbageCollect")

◆ hashVal


◆ http


◆ notify

notify = directNotify.newCategory("ConnectionRepository")

◆ private__di


◆ readerPollTaskObj


◆ recorder


◆ taskChain

taskChain = None

◆ taskPriority

int taskPriority = -30

◆ uniqueId