TheCloud/panda3d
1
0
Fork 0
mirror of https://github.com/panda3d/panda3d.git synced 2025-10-03 10:22:45 -04:00
Code Issues Packages Projects Releases Wiki Activity

create with other option

Browse Source
This commit is contained in:
Dave Schuyler 2005-05-04 04:21:56 +00:00
parent f3c1a1e61a
commit 08db80c106
1 changed files with 10 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -3,6 +3,8 @@ from otp.ai.AIBaseGlobal import *
from direct.directnotify import DirectNotifyGlobal
from direct.showbase.DirectObject import DirectObject
BreakOnTimeout = config.GetBool("break-on-timeout", 0)
class AsyncRequest(DirectObject):
"""
@ -75,6 +77,9 @@ class AsyncRequest(DirectObject):
call this base method to cleanup.
"""
assert self.notify.debugCall("neededObjects: %s"%(self.neededObjects,))
global BreakOnTimeout
if BreakOnTimeout:
import pdb; pdb.set_trace()
self.delete()
def _checkCompletion(self, name, context, distObj):
@ -110,7 +115,7 @@ class AsyncRequest(DirectObject):
self._checkCompletion, [None])
self.air.queryObjectSnapshot(doId, context)
def createObject(self, name, className, context=None):
def createObject(self, name, className, context=None, values=None):
"""
Create a new database object. You can get the doId from within
your self.finish() function.
@ -123,7 +128,10 @@ class AsyncRequest(DirectObject):
context=self.air.allocateContext()
self.accept(
"doRequestResponse-%s"%(context,), self._checkCompletion, [name])
self.air.requestDatabaseGenerate(className, context)
if values is None:
self.air.requestDatabaseGenerate(className, context)
else:
self.air.requestDatabaseGenerate2(className, context, values=values)
def finish(self):
"""