diff options
author | Benjamin 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) |
commit | ca4aad25f329f1fd1402d00d55236f5b84e707c6 (patch) | |
tree | 60104fd67c00cd8b99b8ae7ea0c3e1b32794105a /dobject.py | |
parent | 0845a67272127be0971930cde496f3eeaeb36345 (diff) |
Use async calls to speed up joins
Diffstat (limited to 'dobject.py')
-rw-r--r-- | dobject.py | 7 |
1 files changed, 5 insertions, 2 deletions
@@ -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 |