spacepaste

Paste details

reply | raw

  1.  
  2. class LogicServer(threading.Thread):
  3. def __init__(self):
  4. threading.Thread.__init__(self)
  5. self._game_running = True
  6. self._paused = False
  7. self._no_interaction = False
  8. self._is_started = False
  9. self._time = None
  10. self._panda = None
  12. self._objects = []
  13. self._scheduled_events = []
  16. # Internal methods
  17. def _tick(self):
  18. if self._paused:
  19. return
  21. self._no_interaction = True
  22. self._time = time.time()
  23. for event in self._scheduled_events:
  24. self._resolve_event(event)
  25. self._no_interaction = False
  28. def _resolve_event(self, _event_data):
  29. game, originator, event, call_time, fire_time, on_event, args, kwargs = _event_data
  30. mod_time = time.time() - self._time
  31. call_time += mod_time
  32. if fire_time is None:
  33. is_once = event(call_time, *args, **kwargs)
  34. if on_event is not None:
  35. self._fire_event(on_event, originator)
  36. if is_once:
  37. self._remove_event(_event_data)
  38. else:
  39. if call_time >= fire_time:
  40. mod_time = time.time() - self._time
  41. is_once = event(mod_time, *args, **kwargs)
  42. _event_data[3] = 0
  43. if on_event is not None:
  44. self._fire_event(on_event, originator)
  45. if is_once:
  46. self._remove_event(_event_data)
  47. else:
  48. _event_data[3] = call_time
  51. def _resolve_event_return_stack(self, _event_data):
  52. game, originator, event, call_time, fire_time, on_event, args, kwargs = _event_data
  53. mod_time = time.time() - self._time
  54. call_time += mod_time
  55. if fire_time is None:
  56. return True, event, call_time, args, kwargs
  57. else:
  58. if call_time >= fire_time:
  59. _event_data[3] = 0
  60. return True, event, call_time, args, kwargs
  61. else:
  62. _event_data[3] += call_time
  63. return False, None, None, None, None
  66. def _remove_event(self, event):
  67. try:
  68. self._scheduled_events.remove(event)
  69. except ValueError:
  70. pass # the event was already remove by some other means, usually by removing it in the logic
  73. def _fire_event(self, event, *args, **kwargs):
  74. for child in self._objects:
  75. stop = child._resolve_event(event, *args, **kwargs)
  76. if stop:
  77. return
  79. # API Methods
  80. def kill(self):
  81. """stops the execution of this Logic server"""
  83. assert self._is_started, "Cannot kill Logic server. It was either killed already or never started in the first place."
  84. self._game_running = False
  87. def parent_object(self, object):
  88. """parents Logic object to this server"""
  90. assert self._is_started, "Cannot reparent to Logic server. It was either killed already or never started in the first place."
  91. assert object not in self._objects, "Object already exists in the Logic, reparent failed."
  92. self._objects.append(object)
  95. def deparent_object(self, object):
  96. """parents Logic object to this server"""
  98. assert self._is_started, "Cannot reparent to Logic server. It was either killed already or never started in the first place."
  99. assert object in self._objects, "Object is not in the Logic, deparent failed."
  100. self._objects.remove(object)
  103. def schedule(self, originator, event, delay=None, on_event=None, *args, **kwargs):
  104. """schedules event on this Logic server"""
  105. assert self._is_started, "Cannot schedule event. It was either killed already or never started in the first place."
  107. event_data = [None, originator, event, 0, delay, on_event, args, kwargs]
  108. self._scheduled_events.append(event_data)
  111. def unschedule(self, originator, event):
  112. """unschedules event/events.
  114. If all is passed instead of event, it will unschedule ALL events owned by that originator.
  115. Otherwise, it will only unschedule first event (should be the only one anyways).
  116. """
  117. assert self._is_started, "Cannot unschedule event. It was either killed already or never started in the first place."
  119. if event != "all":
  120. for ev in self._scheduled_events:
  121. if (ev[1] is originator) and (ev[2] is event):
  122. self._remove_event(ev)
  123. return
  124. else:
  125. for ev in self._scheduled_events:
  126. if (ev[1] is originator):
  127. self._remove_event(ev)
  131. def trigger(self, event, *args, **kwargs):
  132. """triggers event on all children of this Logic server"""
  134. assert self._is_started, "Cannot trigger an event. It was either killed already or never started in the first place."
  135. self._fire_event(event, *args, **kwargs)
  138. def pause(self):
  139. """pauses this Logic server"""
  141. assert self._is_started, "Cannot pause Logic server. It was either killed already or never started in the first place."
  142. self._paused = True
  145. def resume(self):
  146. """resumes this Logic server"""
  148. assert self._is_started, "Cannot run Logic server. It was either killed already or never started in the first place."
  149. self._paused = False
  152. def restart(self):
  153. """restarts this Logic server"""
  155. assert self._is_started, "Cannot run Logic server. It was either killed already or never started in the first place."
  156. self._paused = True
  159. def return_status(self):
  160. return self._is_started
  163. # Run method
  164. def run(self):
  165. self._is_started = True
  166. while self._game_running:
  167. self._tick()
  168. time.sleep(0.000001)
  169. self._is_started = False
  172. logic_server = LogicServer()
  175. def run_logic():
  176. logic_server.start()
  179. def stop_logic():
  180. logic_server.kill()
  183. def pause_logic():
  184. logic_server.pause()
  187. def resume_logic():
  188. logic_server.resume()
  191. def restart_logic():
  192. logic_server.restart()
  194.  
Powered by spacepaste. Paste removal.