StarMirror/py-libp2p
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

ttl as int

Browse Source
This commit is contained in:
Chih Cheng Liang 2019-08-05 17:02:18 +08:00
parent 63c733c3f5
commit cb3a59e0ac
No known key found for this signature in database
GPG Key ID: C86B5E6612B1487A
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
libp2p/stream_muxer/abc.py
View File

@ -112,7 +112,7 @@ class IMuxedStream(ABC):
""" """
@abstractmethod @abstractmethod
def set_deadline(self, ttl: float) -> bool: def set_deadline(self, ttl: int) -> bool:
""" """
set deadline for muxed stream set deadline for muxed stream
:return: a new stream :return: a new stream

10
libp2p/stream_muxer/mplex/mplex_stream.py
View File

@ -13,8 +13,8 @@ class MplexStream(IMuxedStream):
stream_id: int stream_id: int
initiator: bool initiator: bool
mplex_conn: IMuxedConn mplex_conn: IMuxedConn
read_deadline: float read_deadline: int
write_deadline: float write_deadline: int
local_closed: bool local_closed: bool
remote_closed: bool remote_closed: bool
stream_lock: asyncio.Lock stream_lock: asyncio.Lock
@ -103,7 +103,7 @@ class MplexStream(IMuxedStream):
return True return True
# TODO deadline not in use # TODO deadline not in use
def set_deadline(self, ttl: float) -> bool: def set_deadline(self, ttl: int) -> bool:
""" """
set deadline for muxed stream set deadline for muxed stream
:return: True if successful :return: True if successful
@ -112,7 +112,7 @@ class MplexStream(IMuxedStream):
self.write_deadline = ttl self.write_deadline = ttl
return True return True
def set_read_deadline(self, ttl: float) -> bool: def set_read_deadline(self, ttl: int) -> bool:
""" """
set read deadline for muxed stream set read deadline for muxed stream
:return: True if successful :return: True if successful
@ -120,7 +120,7 @@ class MplexStream(IMuxedStream):
self.read_deadline = ttl self.read_deadline = ttl
return True return True
def set_write_deadline(self, ttl: float) -> bool: def set_write_deadline(self, ttl: int) -> bool:
""" """
set write deadline for muxed stream set write deadline for muxed stream
:return: True if successful :return: True if successful