cis-kuldeep/PyBitmessage-2021-04-27
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

neededPubkeys data structure now in shared module

Browse Source
This commit is contained in:
Jonathan Warren 2013-06-24 16:18:18 -04:00
parent c857f73d0b
commit 436fced04b
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/class_singleWorker.py
View File

@ -28,7 +28,7 @@ class singleWorker(threading.Thread):
shared.sqlLock.release() shared.sqlLock.release()
for row in queryreturn: for row in queryreturn:
toripe, = row toripe, = row
neededPubkeys[toripe] = 0 shared.neededPubkeys[toripe] = 0
# Initialize the shared.ackdataForWhichImWatching data structure using data # Initialize the shared.ackdataForWhichImWatching data structure using data
# from the sql database. # from the sql database.
@ -75,9 +75,9 @@ class singleWorker(threading.Thread):
self.doPOWForMyV3Pubkey(data) self.doPOWForMyV3Pubkey(data)
"""elif command == 'newpubkey': """elif command == 'newpubkey':
toAddressVersion,toStreamNumber,toRipe = data toAddressVersion,toStreamNumber,toRipe = data
if toRipe in neededPubkeys: if toRipe in shared.neededPubkeys:
print 'We have been awaiting the arrival of this pubkey.' print 'We have been awaiting the arrival of this pubkey.'
del neededPubkeys[toRipe] del shared.neededPubkeys[toRipe]
t = (toRipe,) t = (toRipe,)
shared.sqlLock.acquire() shared.sqlLock.acquire()
shared.sqlSubmitQueue.put('''UPDATE sent SET status='doingmsgpow' WHERE toripe=? AND status='awaitingpubkey' and folder='sent' ''') shared.sqlSubmitQueue.put('''UPDATE sent SET status='doingmsgpow' WHERE toripe=? AND status='awaitingpubkey' and folder='sent' ''')
@ -454,7 +454,7 @@ class singleWorker(threading.Thread):
shared.sqlSubmitQueue.put('commit') shared.sqlSubmitQueue.put('commit')
shared.sqlLock.release() shared.sqlLock.release()
else: # We don't have the needed pubkey. Set the status to 'awaitingpubkey' and request it if we haven't already else: # We don't have the needed pubkey. Set the status to 'awaitingpubkey' and request it if we haven't already
if toripe in neededPubkeys: if toripe in shared.neededPubkeys:
# We already sent a request for the pubkey # We already sent a request for the pubkey
t = (toaddress,) t = (toaddress,)
shared.sqlLock.acquire() shared.sqlLock.acquire()
@ -503,7 +503,7 @@ class singleWorker(threading.Thread):
shared.sqlSubmitQueue.put((toripe,)) shared.sqlSubmitQueue.put((toripe,))
queryreturn = shared.sqlReturnQueue.get() queryreturn = shared.sqlReturnQueue.get()
shared.sqlLock.release() shared.sqlLock.release()
if queryreturn == [] and toripe not in neededPubkeys: if queryreturn == [] and toripe not in shared.neededPubkeys:
# We no longer have the needed pubkey and we haven't requested # We no longer have the needed pubkey and we haven't requested
# it. # it.
shared.printLock.acquire() shared.printLock.acquire()
@ -789,7 +789,7 @@ class singleWorker(threading.Thread):
toAddress) + '. Please report this error to Atheros.') toAddress) + '. Please report this error to Atheros.')
shared.printLock.release() shared.printLock.release()
return return
neededPubkeys[ripe] = 0 shared.neededPubkeys[ripe] = 0
payload = pack('>Q', (int(time.time()) + random.randrange( payload = pack('>Q', (int(time.time()) + random.randrange(
-300, 300))) # the current time plus or minus five minutes. -300, 300))) # the current time plus or minus five minutes.
payload += encodeVarint(addressVersionNumber) payload += encodeVarint(addressVersionNumber)