From 90538b10af6321eee8f3f4b950199c5ff817d76f Mon Sep 17 00:00:00 2001 From: "Bora M. Alper" Date: Fri, 7 Jul 2017 13:31:29 +0300 Subject: [PATCH] removed unused metadata queue --- magneticod/magneticod/dht.py | 5 ----- 1 file changed, 5 deletions(-) diff --git a/magneticod/magneticod/dht.py b/magneticod/magneticod/dht.py index 9491088..ff703b7 100644 --- a/magneticod/magneticod/dht.py +++ b/magneticod/magneticod/dht.py @@ -45,16 +45,11 @@ class SybilNode(asyncio.DatagramProtocol): self.__parent_futures = {} # type: typing.Dict[InfoHash, asyncio.Future] self.__database = database self.__max_metadata_size = max_metadata_size - # 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._is_writing_paused = False self._tick_task = None logging.info("SybilNode %s initialized!", self.__true_id.hex().upper()) - def metadata_q(self): - return self.__metadata_queue - async def launch(self, address): await asyncio.get_event_loop().create_datagram_endpoint(lambda: self, local_addr=address) logging.info("SybliNode is launched on %s!", address)