add logs
This commit is contained in:
parent
802b4a244e
commit
d68df6080d
2 changed files with 4 additions and 0 deletions
2
local.py
2
local.py
|
@ -58,6 +58,7 @@ class RemoteHandler(object):
|
||||||
self.conn.pause()
|
self.conn.pause()
|
||||||
|
|
||||||
def on_drain(self, s):
|
def on_drain(self, s):
|
||||||
|
logging.debug('remote drain')
|
||||||
if self.local_handler:
|
if self.local_handler:
|
||||||
self.local_handler.conn.resume()
|
self.local_handler.conn.resume()
|
||||||
|
|
||||||
|
@ -125,6 +126,7 @@ class LocalHandler(object):
|
||||||
self.cached_pieces.append(data)
|
self.cached_pieces.append(data)
|
||||||
|
|
||||||
def on_drain(self, s):
|
def on_drain(self, s):
|
||||||
|
logging.debug('local drain')
|
||||||
if self.remote_handler:
|
if self.remote_handler:
|
||||||
self.remote_handler.conn.resume()
|
self.remote_handler.conn.resume()
|
||||||
|
|
||||||
|
|
|
@ -58,6 +58,7 @@ class RemoteHandler(object):
|
||||||
self.conn.pause()
|
self.conn.pause()
|
||||||
|
|
||||||
def on_drain(self, s):
|
def on_drain(self, s):
|
||||||
|
logging.debug('remote drain')
|
||||||
if self.local_handler:
|
if self.local_handler:
|
||||||
self.local_handler.conn.resume()
|
self.local_handler.conn.resume()
|
||||||
|
|
||||||
|
@ -116,6 +117,7 @@ class LocalHandler(object):
|
||||||
self.cached_pieces.append(data)
|
self.cached_pieces.append(data)
|
||||||
|
|
||||||
def on_drain(self, s):
|
def on_drain(self, s):
|
||||||
|
logging.debug('local drain')
|
||||||
if self.remote_handler:
|
if self.remote_handler:
|
||||||
self.remote_handler.conn.resume()
|
self.remote_handler.conn.resume()
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue