Rezzect/syncplay
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 2 Wiki Activity

Schedule next ping immediately after sending one

Browse Source
This commit is contained in:
Tomasz Fluxid Kowalczyk 2012-02-15 19:49:01 +01:00
parent 1e23e98d78
commit bccbda23b7
1 changed files with 6 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
syncplay/server.py
View File

@ -175,7 +175,7 @@ class SyncFactory(Factory):
watcher_proto.send_present(receiver.name, receiver.filename) watcher_proto.send_present(receiver.name, receiver.filename)
watcher_proto.send_hello() watcher_proto.send_hello()
self.send_state_to(watcher) self.send_state_to(watcher)
self.schedule_send_ping(watcher_proto) self.send_ping_to(watcher)
def remove_watcher(self, watcher_proto): def remove_watcher(self, watcher_proto):
watcher = self.watchers.pop(watcher_proto, None) watcher = self.watchers.pop(watcher_proto, None)
@ -302,19 +302,16 @@ class SyncFactory(Factory):
#print watcher.name, 'last ping', watcher.ping, 'time offset %.6f' % watcher.time_offset #print watcher.name, 'last ping', watcher.ping, 'time offset %.6f' % watcher.time_offset
self.schedule_send_ping(watcher_proto) def send_ping_to(self, watcher):
def send_ping_to(self, watcher_proto):
watcher = self.watchers.get(watcher_proto)
if not watcher:
return
chars = random_chars() chars = random_chars()
watcher.last_ping_time = time.time() watcher.last_ping_time = time.time()
watcher.last_ping_value = chars watcher.last_ping_value = chars
watcher.watcher_proto.send_ping(chars) watcher.watcher_proto.send_ping(chars)
def schedule_send_ping(self, watcher_proto, when=1): self.schedule_send_ping(watcher)
reactor.callLater(when, self.send_ping_to, watcher_proto)
def schedule_send_ping(self, watcher, when=1):
reactor.callLater(when, self.send_ping_to, watcher)
def playing_received(self, watcher_proto, filename): def playing_received(self, watcher_proto, filename):
watcher = self.watchers.get(watcher_proto) watcher = self.watchers.get(watcher_proto)