Web   ·   Wiki   ·   Activities   ·   Blog   ·   Lists   ·   Chat   ·   Meeting   ·   Bugs   ·   Git   ·   Translate   ·   Archive   ·   People   ·   Donate
summaryrefslogtreecommitdiffstats
path: root/dobject.py
diff options
context:
space:
mode:
authorBenjamin Schwartz <bens@alum.mit.edu>2008-02-08 02:29:00 (GMT)
committer Benjamin Schwartz <bens@alum.mit.edu>2008-02-08 02:29:00 (GMT)
commitca4aad25f329f1fd1402d00d55236f5b84e707c6 (patch)
tree60104fd67c00cd8b99b8ae7ea0c3e1b32794105a /dobject.py
parent0845a67272127be0971930cde496f3eeaeb36345 (diff)
Use async calls to speed up joins
Diffstat (limited to 'dobject.py')
-rw-r--r--dobject.py7
1 files changed, 5 insertions, 2 deletions
diff --git a/dobject.py b/dobject.py
index cfcc755..e8ebfa1 100644
--- a/dobject.py
+++ b/dobject.py
@@ -6,6 +6,9 @@ import logging
import threading
import thread
+def NoneFunction(*args):
+ return
+
class TubeBox:
""" A TubeBox is a box that either contains a Tube or does not."""
def __init__(self):
@@ -87,7 +90,7 @@ class TimeHandler(dbus.gobject_service.ExportedGObject):
self._logger.debug("telling offset")
remote = self.tube.get_object(sender, self.PATH)
start_time += self.offset
- remote.receive_time(asktime, start_time, time.time() + self.offset)
+ remote.receive_time(asktime, start_time, time.time() + self.offset, reply_handler=NoneFunction, error_handler=NoneFunction)
finally:
return
@@ -160,7 +163,7 @@ class UnorderedHandler(dbus.gobject_service.ExportedGObject):
return
remote = self.tube.get_object(sender, self.PATH)
h = self.object.get_history()
- remote.receive_history(h)
+ remote.receive_history(h, reply_handler=NoneFunction, error_handler=NoneFunction)
finally:
return