TheCloud/panda3d
1
0
Fork 0
mirror of https://github.com/panda3d/panda3d.git synced 2025-10-02 09:52:27 -04:00
Code Issues Packages Projects Releases Wiki Activity

askForObjectField

Browse Source
This commit is contained in:
Dave Schuyler 2005-08-03 22:48:42 +00:00
parent d11cb8b183
commit 9b83e3112f
1 changed files with 60 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

61
direct/src/distributed/AsyncRequest.py
View File

@ -100,6 +100,28 @@ class AsyncRequest(DirectObject):
return
self.finish()
def askForObjectField(
self, dclassName, fieldName, doId, key=None, context=None):
"""
Request an already created object, i.e. read from database.
"""
assert self.notify.debugCall()
if key is None:
# default the dictionary key to the fieldName
key = fieldName
assert doId
## object = self.air.doId2do.get(doId)
## self.neededObjects[key]=object
if 0 and object is not None:
self._checkCompletion(key, None, object)
else:
if context is None:
context=self.air.allocateContext()
self.acceptOnce(
"doFieldResponse-%s"%(context,),
self._checkCompletion, [key])
self.air.queryObjectField(dclassName, fieldName, doId, context)
def askForObject(self, doId, context=None):
"""
Request an already created object, i.e. read from database.
@ -113,11 +135,48 @@ class AsyncRequest(DirectObject):
else:
if context is None:
context=self.air.allocateContext()
self.accept(
self.acceptOnce(
"doRequestResponse-%s"%(context,),
self._checkCompletion, [None])
self.air.queryObjectAll(doId, context)
## def askForObjectAIReceive(self, doId, context=None):
## """
## Request an already created object, i.e. read from database.
## """
## assert self.notify.debugCall()
## assert doId
## object = self.air.doId2do.get(doId)
## self.neededObjects[doId]=object
## if object is not None:
## self._checkCompletion(None, context, object)
## else:
## if context is None:
## context=self.air.allocateContext()
## self.accept(
## "doRequestResponse-%s"%(context,),
## self._checkCompletion, [None])
## self.air.queryObjectAIReceive(doId, context)
#def addInterestInObject(self, doId, context=None):
# """
# Request an already created object, i.e. read from database
# and claim a long term interest in the object (get updates, etc.).
# """
# assert self.notify.debugCall()
# assert doId
# object = self.air.doId2do.get(doId)
# self.neededObjects[doId]=object
# if object is not None:
# self._checkCompletion(None, context, object)
# else:
# if context is None:
# context=self.air.allocateContext()
# self.accept(
# "doRequestResponse-%s"%(context,),
# self._checkCompletion, [None])
# self.air.queryObject(doId, context)
def createObject(self, name, className, context=None, values=None):
"""
Create a new database object. You can get the doId from within