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

added prelim staggered pos-broadcast task scheduling

Browse Source
This commit is contained in:
Darren Ranalli 2004-06-24 22:44:36 +00:00
parent c535888966
commit ad09b6fbbd
1 changed files with 12 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
direct/src/distributed/DistributedSmoothNodeBase.py
View File

@ -2,6 +2,7 @@
from ClockDelta import * from ClockDelta import *
from direct.task import Task from direct.task import Task
from direct.showbase.PythonUtil import randFloat
class DistributedSmoothNodeBase: class DistributedSmoothNodeBase:
"""common base class for DistributedSmoothNode and DistributedSmoothNodeAI """common base class for DistributedSmoothNode and DistributedSmoothNodeAI
@ -61,7 +62,10 @@ class DistributedSmoothNodeBase:
def stopPosHprBroadcast(self): def stopPosHprBroadcast(self):
taskMgr.remove(self.getPosHprBroadcastTaskName()) taskMgr.remove(self.getPosHprBroadcastTaskName())
def startPosHprBroadcast(self, period=.2): def startPosHprBroadcast(self, period=.2, stagger=0):
# Set stagger to non-zero to randomly delay the initial task execution
# over 'period' seconds, to spread out task processing over time
# when a large number of SmoothNodes are created simultaneously.
taskName = self.getPosHprBroadcastTaskName() taskName = self.getPosHprBroadcastTaskName()
# Set up telemetry optimization variables # Set up telemetry optimization variables
xyz = self.getPos() xyz = self.getPos()
@ -83,10 +87,16 @@ class DistributedSmoothNodeBase:
# remove any old tasks # remove any old tasks
taskMgr.remove(taskName) taskMgr.remove(taskName)
# spawn the new task # spawn the new task
taskMgr.doMethodLater(self.__broadcastPeriod, delay = 0.
if stagger:
delay = randFloat(period)
taskMgr.doMethodLater(self.__broadcastPeriod + delay,
self.posHprBroadcast, taskName) self.posHprBroadcast, taskName)
def posHprBroadcast(self, task): def posHprBroadcast(self, task):
# TODO: we explicitly stagger the initial task timing in
# startPosHprBroadcast; we should at least make an effort to keep
# this task accurately aligned with its period and starting time.
self.d_broadcastPosHpr() self.d_broadcastPosHpr()
taskName = self.taskName("sendPosHpr") taskName = self.taskName("sendPosHpr")
taskMgr.doMethodLater(self.__broadcastPeriod, taskMgr.doMethodLater(self.__broadcastPeriod,