use better syntax
This commit is contained in:
parent
51edef7665
commit
5c1e7360f2
|
@ -704,14 +704,11 @@ class receiveDataThread(threading.Thread):
|
||||||
|
|
||||||
if messageEncodingType != 0:
|
if messageEncodingType != 0:
|
||||||
t = (fromAddress,)
|
t = (fromAddress,)
|
||||||
shared.sqlLock.acquire()
|
with shared.sqlLock:
|
||||||
shared.sqlSubmitQueue.put(
|
shared.sqlSubmitQueue.put(
|
||||||
'''SELECT receiving_identity FROM subscriptions WHERE address=?''')
|
'''SELECT receiving_identity FROM subscriptions WHERE address=?''')
|
||||||
shared.sqlSubmitQueue.put(t)
|
shared.sqlSubmitQueue.put(t)
|
||||||
queryreturn = shared.sqlReturnQueue.get()
|
queryreturn = shared.sqlReturnQueue.get()
|
||||||
shared.sqlLock.release()
|
|
||||||
|
|
||||||
print('queryreturn: {}'.format(queryreturn))
|
|
||||||
for row in queryreturn:
|
for row in queryreturn:
|
||||||
receivingIdentity, = row
|
receivingIdentity, = row
|
||||||
|
|
||||||
|
|
Reference in New Issue
Block a user