rnhmjoj/magnetico
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 1 Wiki Activity

corrected naming

Browse Source
This commit is contained in:
Bora M. Alper 2017-06-17 15:20:06 +03:00
parent 0c6d01184b
commit 07fe0d3eb4
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
magneticod/magneticod/dht.py
View File

@ -32,7 +32,7 @@ Metadata = bytes
class SybilNode(asyncio.DatagramProtocol): class SybilNode(asyncio.DatagramProtocol):
def __init__(self, is_infohash_new, max_metadata_size): def __init__(self, is_info_hash_new, max_metadata_size):
self.__true_id = os.urandom(20) self.__true_id = os.urandom(20)
self._routing_table = {} # type: typing.Dict[NodeID, NodeAddress] self._routing_table = {} # type: typing.Dict[NodeID, NodeAddress]
@ -42,7 +42,7 @@ class SybilNode(asyncio.DatagramProtocol):
# stop; but until then, the total number of neighbours might exceed the threshold). # stop; but until then, the total number of neighbours might exceed the threshold).
self.__n_max_neighbours = 2000 self.__n_max_neighbours = 2000
self.__parent_futures = {} # type: typing.Dict[InfoHash, asyncio.Future] self.__parent_futures = {} # type: typing.Dict[InfoHash, asyncio.Future]
self._is_inforhash_new = is_infohash_new self._is_info_hash_new = is_info_hash_new
self.__max_metadata_size = max_metadata_size self.__max_metadata_size = max_metadata_size
# Complete metadatas will be added to the queue, to be retrieved and committed to the database. # Complete metadatas will be added to the queue, to be retrieved and committed to the database.
self.__metadata_queue = asyncio.Queue() # typing.Collection[typing.Tuple[InfoHash, Metadata]] self.__metadata_queue = asyncio.Queue() # typing.Collection[typing.Tuple[InfoHash, Metadata]]
@ -221,7 +221,7 @@ class SybilNode(asyncio.DatagramProtocol):
else: else:
peer_addr = (addr[0], port) peer_addr = (addr[0], port)
if not self._is_inforhash_new(info_hash): if not self._is_info_hash_new(info_hash):
return return
event_loop = asyncio.get_event_loop() event_loop = asyncio.get_event_loop()