Bitmessage/MiNode
3
0
Fork 1
Code Pull Requests 9 Actions Activity

POW tweaks

Browse Source
This commit is contained in:
TheKysek 2017-07-01 16:14:31 +02:00
parent c6f721db8e
commit 0b6bb7f932
No known key found for this signature in database
GPG Key ID: 50D9AF00D0B1C497
1 changed files with 6 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
minode/pow.py
View File

@ -1,4 +1,5 @@
import hashlib import hashlib
import logging
import multiprocessing import multiprocessing
import shared import shared
import struct import struct
@ -10,7 +11,7 @@ import structure
def _pow_worker(target, initial_hash, q): def _pow_worker(target, initial_hash, q):
nonce = 0 nonce = 0
print("target: {}, initial_hash: {}".format(target, initial_hash.hex())) logging.debug("target: {}, initial_hash: {}".format(target, initial_hash.hex()))
trial_value = target + 1 trial_value = target + 1
while trial_value > target: while trial_value > target:
@ -24,18 +25,16 @@ def _worker(obj):
q = multiprocessing.Queue() q = multiprocessing.Queue()
p = multiprocessing.Process(target=_pow_worker, args=(obj.pow_target(), obj.pow_initial_hash(), q)) p = multiprocessing.Process(target=_pow_worker, args=(obj.pow_target(), obj.pow_initial_hash(), q))
print("Starting POW process") logging.debug("Starting POW process")
t = time.time() t = time.time()
p.start() p.start()
nonce = q.get() nonce = q.get()
p.join() p.join()
print("Finished doing POW, nonce: {}, time: {}s".format(nonce, time.time() - t))
logging.debug("Finished doing POW, nonce: {}, time: {}s".format(nonce, time.time() - t))
obj = structure.Object(nonce, obj.expires_time, obj.object_type, obj.version, obj.stream_number, obj.object_payload) obj = structure.Object(nonce, obj.expires_time, obj.object_type, obj.version, obj.stream_number, obj.object_payload)
print("Object vector is {}".format(obj.vector.hex())) logging.debug("Object vector is {}".format(obj.vector.hex()))
print("Advertising in 10s")
time.sleep(10)
print("shared.objects len: {}".format(len(shared.objects)))
with shared.objects_lock: with shared.objects_lock:
shared.objects[obj.vector] = obj shared.objects[obj.vector] = obj
shared.vector_advertise_queue.put(obj.vector) shared.vector_advertise_queue.put(obj.vector)