Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

Merge pull request #1957 from lbryio/dht_memory

Browse source 
add LRU to KademliaPeer creation
This commit is contained in:
Jack Robison 2019-02-26 10:10:33 -05:00 committed by GitHub
commit 573617d6b6
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
lbrynet/dht/peer.py
View file

@ -3,6 +3,8 @@ import asyncio
import logging import logging
import ipaddress import ipaddress
from binascii import hexlify from binascii import hexlify
from functools import lru_cache
from lbrynet.dht import constants from lbrynet.dht import constants
from lbrynet.dht.serialization.datagram import make_compact_address, make_compact_ip, decode_compact_address from lbrynet.dht.serialization.datagram import make_compact_address, make_compact_ip, decode_compact_address
@ -76,6 +78,7 @@ class PeerManager:
self._node_id_mapping[(address, udp_port)] = node_id self._node_id_mapping[(address, udp_port)] = node_id
self._node_id_reverse_mapping[node_id] = (address, udp_port) self._node_id_reverse_mapping[node_id] = (address, udp_port)
@lru_cache(maxsize=400)
def get_kademlia_peer(self, node_id: bytes, address: str, udp_port: int) -> 'KademliaPeer': def get_kademlia_peer(self, node_id: bytes, address: str, udp_port: int) -> 'KademliaPeer':
return KademliaPeer(self._loop, address, node_id, udp_port) return KademliaPeer(self._loop, address, node_id, udp_port)