diff --git a/local.py b/local.py index 29f08e7..31b28ba 100755 --- a/local.py +++ b/local.py @@ -58,6 +58,7 @@ class RemoteHandler(object): self.conn.pause() def on_drain(self, s): + logging.debug('remote drain') if self.local_handler: self.local_handler.conn.resume() @@ -125,6 +126,7 @@ class LocalHandler(object): self.cached_pieces.append(data) def on_drain(self, s): + logging.debug('local drain') if self.remote_handler: self.remote_handler.conn.resume() diff --git a/server.py b/server.py index fbaf7e3..bac0b7e 100755 --- a/server.py +++ b/server.py @@ -58,6 +58,7 @@ class RemoteHandler(object): self.conn.pause() def on_drain(self, s): + logging.debug('remote drain') if self.local_handler: self.local_handler.conn.resume() @@ -116,6 +117,7 @@ class LocalHandler(object): self.cached_pieces.append(data) def on_drain(self, s): + logging.debug('local drain') if self.remote_handler: self.remote_handler.conn.resume()