Bitmessage/PyBitmessage-2024-12-01
Archived
2
0
Fork 0
Code Issues 168 Pull Requests 53 Actions Packages Projects Releases 5 Wiki Activity

knownnodes quality fixes

Browse Source
This commit is contained in:
lakshyacis 2019-10-22 19:52:41 +05:30
parent ee5be28179
commit afce500085
No known key found for this signature in database
GPG Key ID: D2C539C8EC63E9EB
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/knownnodes.py
View File

@ -82,6 +82,7 @@ def pickle_deserialize_old_knownnodes(source):
def saveKnownNodes(dirName=None): def saveKnownNodes(dirName=None):
"""Save knownnodes to filesystem"""
if dirName is None: if dirName is None:
dirName = state.appdata dirName = state.appdata
with knownNodesLock: with knownNodesLock:
@ -90,6 +91,7 @@ def saveKnownNodes(dirName=None):
def addKnownNode(stream, peer, lastseen=None, is_self=False): def addKnownNode(stream, peer, lastseen=None, is_self=False):
"""Add a new node to the dict"""
knownNodes[stream][peer] = { knownNodes[stream][peer] = {
"lastseen": lastseen or time.time(), "lastseen": lastseen or time.time(),
"rating": 1 if is_self else 0, "rating": 1 if is_self else 0,
@ -98,6 +100,7 @@ def addKnownNode(stream, peer, lastseen=None, is_self=False):
def createDefaultKnownNodes(): def createDefaultKnownNodes():
"""Creating default Knownnodes"""
past = time.time() - 2418600 # 28 days - 10 min past = time.time() - 2418600 # 28 days - 10 min
for peer in DEFAULT_NODES: for peer in DEFAULT_NODES:
addKnownNode(1, peer, past) addKnownNode(1, peer, past)
@ -105,6 +108,7 @@ def createDefaultKnownNodes():
def readKnownNodes(): def readKnownNodes():
"""Load knownnodes from filesystem"""
try: try:
with open(state.appdata + 'knownnodes.dat', 'rb') as source: with open(state.appdata + 'knownnodes.dat', 'rb') as source:
with knownNodesLock: with knownNodesLock:
@ -131,6 +135,7 @@ def readKnownNodes():
def increaseRating(peer): def increaseRating(peer):
"""Increase rating of a peer node"""
increaseAmount = 0.1 increaseAmount = 0.1
maxRating = 1 maxRating = 1
with knownNodesLock: with knownNodesLock:
@ -145,6 +150,7 @@ def increaseRating(peer):
def decreaseRating(peer): def decreaseRating(peer):
"""Decrease rating of a peer node"""
decreaseAmount = 0.1 decreaseAmount = 0.1
minRating = -1 minRating = -1
with knownNodesLock: with knownNodesLock:
@ -159,6 +165,7 @@ def decreaseRating(peer):
def trimKnownNodes(recAddrStream=1): def trimKnownNodes(recAddrStream=1):
"""Triming Knownnodes"""
if len(knownNodes[recAddrStream]) < \ if len(knownNodes[recAddrStream]) < \
BMConfigParser().safeGetInt("knownnodes", "maxnodes"): BMConfigParser().safeGetInt("knownnodes", "maxnodes"):
return return