diff --git a/direct/src/distributed/DoInterestManager.py b/direct/src/distributed/DoInterestManager.py index d92d721029..00ccbc011e 100755 --- a/direct/src/distributed/DoInterestManager.py +++ b/direct/src/distributed/DoInterestManager.py @@ -158,9 +158,9 @@ class DoInterestManager(DirectObject.DirectObject): """ Look into a (set of) zone(s). """ - assert DoInterestManager.notify.debugCall() handle = self._getNextHandle() + # print 'base.cr.addInterest(',description,',',handle,'):',globalClock.getFrameCount() if self._noNewInterests: DoInterestManager.notify.warning( "addInterest: addingInterests on delete: %s" % (handle)) @@ -232,6 +232,8 @@ class DoInterestManager(DirectObject.DirectObject): """ Stop looking in a (set of) zone(s) """ + # print 'base.cr.removeInterest(',handle,'):',globalClock.getFrameCount() + assert DoInterestManager.notify.debugCall() assert isinstance(handle, InterestHandle) existed = False @@ -537,12 +539,13 @@ class DoInterestManager(DirectObject.DirectObject): self._completeDelayedCallback.destroy() self._completeDelayedCallback = None - def queueAllInterestsCompleteEvent(self, frames=3): + def queueAllInterestsCompleteEvent(self, frames=5): # wait for N frames, if no new interests, send out all-done event # calling this is OK even if there are no pending interest completes def checkMoreInterests(): # if there are new interests, cancel this delayed callback, another # will automatically be scheduled when all interests complete + # print 'checkMoreInterests(',self._completeEventCount.num,'):',globalClock.getFrameCount() return self._completeEventCount.num > 0 def sendEvent(): messenger.send(self.getAllInterestsCompleteEvent())