From 7c2d7f4c7df692bec4227922e0949d3fc1aa7f48 Mon Sep 17 00:00:00 2001 From: Tomasz Fluxid Kowalczyk Date: Sat, 28 Jan 2012 22:05:04 +0100 Subject: [PATCH] Ping clients and send position time modified by total lag between them --- syncplay/client.py | 19 ++++++++++++++++++- syncplay/server.py | 46 +++++++++++++++++++++++++++++++++++++++++++++- 2 files changed, 63 insertions(+), 2 deletions(-) diff --git a/syncplay/client.py b/syncplay/client.py index 9f3f65c..5c4479d 100644 --- a/syncplay/client.py +++ b/syncplay/client.py @@ -32,6 +32,9 @@ class SyncClientProtocol(CommandProtocol): self.manager.update_global_state(paused, position, name) + def handle_connected_ping(self, arg): + self.send_message('pong', arg) + def send_state(self, paused, position): self.send_message('state', ('paused' if paused else 'playing'), int(position*100)) @@ -40,7 +43,7 @@ class SyncClientProtocol(CommandProtocol): connected = dict( state = 'handle_connected_state', seek = 'handle_connected_seek', - #ping = 'handle_connected_ping', + ping = 'handle_connected_ping', ), ) initial_state = 'connected' @@ -67,10 +70,14 @@ class Manager(object): self.global_paused = True self.global_position = 0.0 + self.last_global_update = 0.0 self.player_paused = True self.player_position = 0.0 + def get_current_global_position(self): + return self.global_position + (time.time() - self.last_global_update) + def start(self): factory = SyncClientFactory(self) reactor.connectTCP(self.host, self.port, factory) @@ -115,6 +122,16 @@ class Manager(object): def update_player_position(self, value): self.player_position = value + #diff = self.get_current_global_position() - value + #if 0.2 <= abs(diff) <= 4: + # if diff > 0: + # diff -= 0.2 + # else: + # diff += 0.2 + # speed = (diff/4.0) + 1 + # self.player.send_set_speed(speed) + #else: + # self.player.send_set_speed(1) def update_player_paused(self, value): old = self.player_paused diff --git a/syncplay/server.py b/syncplay/server.py index b45bacc..66a5b9e 100644 --- a/syncplay/server.py +++ b/syncplay/server.py @@ -1,12 +1,19 @@ #coding:utf8 import time +import random from twisted.internet.protocol import Factory from .network_utils import CommandProtocol from .utils import parse_state +random.seed() + +CHARS = 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789' + +def random_chars(): + return ''.join(random.choice(CHARS) for _ in xrange(10)) class SyncServerProtocol(CommandProtocol): def __init__(self, factory): @@ -41,6 +48,9 @@ class SyncServerProtocol(CommandProtocol): self.factory.seek(self, position) + def handle_connected_pong(self, arg): + self.factory.pong_received(self, arg) + def __hash__(self): return hash('|'.join(( self.transport.getPeer().host, @@ -62,7 +72,7 @@ class SyncServerProtocol(CommandProtocol): connected = dict( state = 'handle_connected_state', seek = 'handle_connected_seek', - #ping = 'handle_connected_ping', + pong = 'handle_connected_pong', ), ) initial_state = 'init' @@ -78,7 +88,13 @@ class WatcherInfo(object): self.last_update = None self.last_update_sent = None + self.ping = None + self.last_ping_time = None + self.last_ping_value = None + def update_position(self, position): + if self.ping is not None: + position += self.ping self.position = position self.max_position = max(position, self.max_position) self.last_update = time.time() @@ -150,10 +166,15 @@ class SyncFactory(Factory): position = self.find_position() if curtime is None: curtime = time.time() + + if watcher.ping is not None: + position += watcher.ping + if self.pause_change_by: watcher.watcher_proto.send_state(self.paused, position, self.pause_change_by.name) else: watcher.watcher_proto.send_state(self.paused, position, None) + watcher.last_update_sent = curtime def find_position(self): @@ -168,3 +189,26 @@ class SyncFactory(Factory): #min() arg is an empty sequence return 0.0 + def pong_received(self, watcher_proto, value): + watcher = self.watchers.get(watcher_proto) + if not watcher: + return + + if watcher.last_ping_value == value: + time = (time.time() - watcher.last_ping_time)/2 + if watcher.ping is None: + watcher.ping = time + else: + watcher.ping = watcher.ping*0.6 + time*0.4 + + self.schedule_send_ping(watcher) + + def send_ping(self, watcher): + chars = random_chars() + watcher.last_ping_time = time.time() + watcher.last_ping_value = chars + watcher.watcher_proto.send_ping(chars) + + def schedule_send_ping(self, watcher, when=1): + reactor.callLater(when, self.send_ping, watcher) +