add __slots__ to BlobInfo, StreamDescriptor, and KademliaPeer
This commit is contained in:
parent
1f266ebdad
commit
f8c0e80cfc
3 changed files with 27 additions and 0 deletions
|
@ -2,6 +2,13 @@ import typing
|
||||||
|
|
||||||
|
|
||||||
class BlobInfo:
|
class BlobInfo:
|
||||||
|
__slots__ = [
|
||||||
|
'blob_hash',
|
||||||
|
'blob_num',
|
||||||
|
'length',
|
||||||
|
'iv',
|
||||||
|
]
|
||||||
|
|
||||||
def __init__(self, blob_num: int, length: int, iv: str, blob_hash: typing.Optional[str] = None):
|
def __init__(self, blob_num: int, length: int, iv: str, blob_hash: typing.Optional[str] = None):
|
||||||
self.blob_hash = blob_hash
|
self.blob_hash = blob_hash
|
||||||
self.blob_num = blob_num
|
self.blob_num = blob_num
|
||||||
|
|
|
@ -135,6 +135,15 @@ class PeerManager:
|
||||||
|
|
||||||
|
|
||||||
class KademliaPeer:
|
class KademliaPeer:
|
||||||
|
__slots__ = [
|
||||||
|
'loop',
|
||||||
|
'_node_id',
|
||||||
|
'address',
|
||||||
|
'udp_port',
|
||||||
|
'tcp_port',
|
||||||
|
'protocol_version',
|
||||||
|
]
|
||||||
|
|
||||||
def __init__(self, loop: asyncio.BaseEventLoop, address: str, node_id: typing.Optional[bytes] = None,
|
def __init__(self, loop: asyncio.BaseEventLoop, address: str, node_id: typing.Optional[bytes] = None,
|
||||||
udp_port: typing.Optional[int] = None, tcp_port: typing.Optional[int] = None):
|
udp_port: typing.Optional[int] = None, tcp_port: typing.Optional[int] = None):
|
||||||
if node_id is not None:
|
if node_id is not None:
|
||||||
|
|
|
@ -47,6 +47,17 @@ def file_reader(file_path: str):
|
||||||
|
|
||||||
|
|
||||||
class StreamDescriptor:
|
class StreamDescriptor:
|
||||||
|
__slots__ = [
|
||||||
|
'loop',
|
||||||
|
'blob_dir',
|
||||||
|
'stream_name',
|
||||||
|
'key',
|
||||||
|
'suggested_file_name',
|
||||||
|
'blobs',
|
||||||
|
'stream_hash',
|
||||||
|
'sd_hash'
|
||||||
|
]
|
||||||
|
|
||||||
def __init__(self, loop: asyncio.BaseEventLoop, blob_dir: str, stream_name: str, key: str,
|
def __init__(self, loop: asyncio.BaseEventLoop, blob_dir: str, stream_name: str, key: str,
|
||||||
suggested_file_name: str, blobs: typing.List[BlobInfo], stream_hash: typing.Optional[str] = None,
|
suggested_file_name: str, blobs: typing.List[BlobInfo], stream_hash: typing.Optional[str] = None,
|
||||||
sd_hash: typing.Optional[str] = None):
|
sd_hash: typing.Optional[str] = None):
|
||||||
|
|
Loading…
Reference in a new issue