PyBitmessage/src/queues.py

import Queue
from class_objectProcessorQueue import ObjectProcessorQueue

workerQueue = Queue.Queue()
UISignalQueue = Queue.Queue()
addressGeneratorQueue = Queue.Queue()
# receiveDataThreads dump objects they hear on the network into this queue to be processed.
objectProcessorQueue = ObjectProcessorQueue()
invQueue = Queue.Queue()
portCheckerQueue = Queue.Queue()
peerDiscoveryQueue = Queue.Queue()
apiAddressGeneratorReturnQueue = Queue.Queue(
    )  # The address generator thread uses this queue to get information back to the API thread.
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 7 years ago			`import Queue`
			`from class_objectProcessorQueue import ObjectProcessorQueue`

			`workerQueue = Queue.Queue()`
			`UISignalQueue = Queue.Queue()`
			`addressGeneratorQueue = Queue.Queue()`
			`# receiveDataThreads dump objects they hear on the network into this queue to be processed.`
			`objectProcessorQueue = ObjectProcessorQueue()`
Asyncore updates - asyncore is now on by default - inv announcements implemented - bandwidth limit implemented / fixed - stats on download / upload speed now work - make prints into logger - limit knownNodes to 20k as it was before - green light fixed - other minor fixes 7 years ago			`invQueue = Queue.Queue()`
Asyncore update - Network status UI works but current speed isn't implemented yet - Track per connection and global transferred bytes - Add locking to write queue so that other threads can put stuff there - send ping on timeout (instead of closing the connection) - implement open port checker (untested, never triggered yet) - error handling on IO 7 years ago			`portCheckerQueue = Queue.Queue()`
Asyncore update - bugfixes - UDP socket for local peer discovery - new function assembleAddr to unify creating address command - open port checker functionality (inactive) - sendBigInv is done in a thread separate from the network IO thread 7 years ago			`peerDiscoveryQueue = Queue.Queue()`
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 7 years ago			`apiAddressGeneratorReturnQueue = Queue.Queue(`
			`) # The address generator thread uses this queue to get information back to the API thread.`