PyBitmessage-2024-12-18/src/knownnodes.py

import pickle
import threading

import state

knownNodesLock = threading.Lock()
knownNodes = {}

knownNodesMax = 20000
knownNodesTrimAmount = 2000

def saveKnownNodes(dirName = None):
    if dirName is None:
        dirName = state.appdata
    with knownNodesLock:
        with open(dirName + 'knownnodes.dat', 'wb') as output:
            pickle.dump(knownNodes, output)

def trimKnownNodes(recAddrStream = 1):
    if len(knownNodes[recAddrStream]) < knownNodesMax:
        return
    with knownNodesLock:
        oldestList = sorted(knownNodes[recAddrStream], key=knownNodes[recAddrStream].get)[:knownNodeTrimAmount]
        for oldest in oldestList:
            del knownNodes[recAddrStream][oldest]
knownNodes refactoring and shutdown fixes - saveKnownNodes replaced the repeated pickle.dump - with knownNodesLock instead of acquire/release - outgoingSynSender had an unnecessary loop during shutdown causing excessive CPU usage / GUI freezing 2017-02-09 11:53:33 +01:00			`import pickle`
Reduce cyclic dependencies - rearranged code to reduce cyclic dependencies - doCleanShutdown is separated in shutdown.py - shared queues are separated in queues.py - some default values were moved to defaults.py - knownnodes partially moved to knownnodes.py 2017-02-08 13:41:56 +01:00			`import threading`

knownNodes refactoring and shutdown fixes - saveKnownNodes replaced the repeated pickle.dump - with knownNodesLock instead of acquire/release - outgoingSynSender had an unnecessary loop during shutdown causing excessive CPU usage / GUI freezing 2017-02-09 11:53:33 +01:00			`import state`

Reduce cyclic dependencies - rearranged code to reduce cyclic dependencies - doCleanShutdown is separated in shutdown.py - shared queues are separated in queues.py - some default values were moved to defaults.py - knownnodes partially moved to knownnodes.py 2017-02-08 13:41:56 +01:00			`knownNodesLock = threading.Lock()`
			`knownNodes = {}`

Bootstrap provider mode and minor knownNodes changes - if knownNodes grows to 20000, instead of ignoring new nodes, forget the 1000 oldest ones - drop connection after sendaddr if too many connections, even if it's an outbound one - if maximum total connections are lower than maximum outbound connections, active bootstrap provider mode - in this mode, check all addresses received before announcing them - so basically it only annouces those addresses it successfully connected to 2017-02-27 23:31:12 +01:00			`knownNodesMax = 20000`
			`knownNodesTrimAmount = 2000`

knownNodes refactoring and shutdown fixes - saveKnownNodes replaced the repeated pickle.dump - with knownNodesLock instead of acquire/release - outgoingSynSender had an unnecessary loop during shutdown causing excessive CPU usage / GUI freezing 2017-02-09 11:53:33 +01:00			`def saveKnownNodes(dirName = None):`
			`if dirName is None:`
			`dirName = state.appdata`
			`with knownNodesLock:`
			`with open(dirName + 'knownnodes.dat', 'wb') as output:`
			`pickle.dump(knownNodes, output)`
Bootstrap provider mode and minor knownNodes changes - if knownNodes grows to 20000, instead of ignoring new nodes, forget the 1000 oldest ones - drop connection after sendaddr if too many connections, even if it's an outbound one - if maximum total connections are lower than maximum outbound connections, active bootstrap provider mode - in this mode, check all addresses received before announcing them - so basically it only annouces those addresses it successfully connected to 2017-02-27 23:31:12 +01:00
			`def trimKnownNodes(recAddrStream = 1):`
			`if len(knownNodes[recAddrStream]) < knownNodesMax:`
			`return`
			`with knownNodesLock:`
			`oldestList = sorted(knownNodes[recAddrStream], key=knownNodes[recAddrStream].get)[:knownNodeTrimAmount]`
			`for oldest in oldestList:`
			`del knownNodes[recAddrStream][oldest]`