RanchiMall/stratum-mining
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix error when subscription is none add try catch

Browse Source
This commit is contained in:
obigal 2013-12-17 20:32:36 -05:00
parent e2b06d2839
commit a107473d9c
1 changed files with 14 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
mining/subscription.py
View File

@ -24,6 +24,8 @@ class MiningSubscription(Subscription):
# Push new job to subscribed clients # Push new job to subscribed clients
for subscription in Pubsub.iterate_subscribers(cls.event): for subscription in Pubsub.iterate_subscribers(cls.event):
try:
if subscription != None:
session = subscription.connection_ref().get_session() session = subscription.connection_ref().get_session()
session.setdefault('authorized', {}) session.setdefault('authorized', {})
if session['authorized'].keys(): if session['authorized'].keys():
@ -33,6 +35,9 @@ class MiningSubscription(Subscription):
subscription.emit_single(work_id, prevhash, coinb1, coinb2, merkle_branch, version, nbits, ntime, clean_jobs) subscription.emit_single(work_id, prevhash, coinb1, coinb2, merkle_branch, version, nbits, ntime, clean_jobs)
else: else:
subscription.emit_single(job_id, prevhash, coinb1, coinb2, merkle_branch, version, nbits, ntime, clean_jobs) subscription.emit_single(job_id, prevhash, coinb1, coinb2, merkle_branch, version, nbits, ntime, clean_jobs)
except Exception as e:
log.exception("Error broadcasting work to client %s" % str(e))
pass
cnt = Pubsub.get_subscription_count(cls.event) cnt = Pubsub.get_subscription_count(cls.event)
log.info("BROADCASTED to %d connections in %.03f sec" % (cnt, (Interfaces.timestamper.time() - start))) log.info("BROADCASTED to %d connections in %.03f sec" % (cnt, (Interfaces.timestamper.time() - start)))