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

make 5 attempts at block submission using detected value of submitblock or getblocktemplate

Browse Source
This commit is contained in:
Alan Penner 2014-01-20 17:46:56 -08:00 committed by Ahmed Bodiwala
parent 009519e295
commit d64c08f54c
1 changed files with 59 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

82
lib/bitcoin_rpc.py
View File

@ -22,7 +22,7 @@ class BitcoinRPC(object):
'Authorization': 'Basic %s' % self.credentials, 'Authorization': 'Basic %s' % self.credentials,
} }
client.HTTPClientFactory.noisy = False client.HTTPClientFactory.noisy = False
self.has_submitblock = False
def _call_raw(self, data): def _call_raw(self, data):
client.Headers client.Headers
return client.getPage( return client.getPage(
@ -45,40 +45,74 @@ class BitcoinRPC(object):
try: try:
log.info("Checking for submitblock") log.info("Checking for submitblock")
resp = (yield self._call('submitblock', [])) resp = (yield self._call('submitblock', []))
defer.returnValue(None) self.has_submitblock = Trie
except Exception, e: except Exception, e:
if (str(e) == "404 Not Found"): if (str(e) == "404 Not Found"):
log.debug("No submitblock detected.") log.debug("No submitblock detected.")
defer.returnValue(False) self.has_submitblock = False
elif (str(e) == "500 Internal Server Error"): elif (str(e) == "500 Internal Server Error"):
log.debug("submitblock detected.") log.debug("submitblock detected.")
defer.returnValue(True) self.has_submitblock = True
else: else:
log.debug("unknown submitblock check result.") log.debug("unknown submitblock check result.")
defer.returnValue(None) self.has_submitblock = True
self.has_submitblock = True
finally:
defer.returnValue(self.has_submitblock)
@defer.inlineCallbacks @defer.inlineCallbacks
def submitblock(self, block_hex, hash_hex): def submitblock(self, block_hex, hash_hex):
# Try submitblock if that fails, go to getblocktemplate #try 5 times? 500 Internal Server Error could mean random error or that TX messages setting is wrong
try: attempts = 0
log.debug("Submitting Block with Submit Block ") while True:
log.debug([block_hex,]) attempts += 1
resp = (yield self._call('submitblock', [block_hex,])) if self.has_submitblock == True:
except Exception: try:
try: log.debug("Submitting Block with submitblock: attempt #"+str(attempt))
log.exception("Submit Block Failed, does the coind have submitblock?") log.debug([block_hex,])
log.exception("Trying GetBlockTemplate") resp = (yield self._call('submitblock', [block_hex,]))
resp = (yield self._call('getblocktemplate', [{'mode': 'submit', 'data': block_hex}])) break
except Exception as e: except Exception as e:
log.exception("Both SubmitBlock and GetBlockTemplate failed. Problem Submitting block %s" % str(e)) if attempts > 5:
log.exception("Try Enabling TX Messages in config.py!") log.exception("submitblock failed. Problem Submitting block %s" % str(e))
raise log.exception("Try Enabling TX Messages in config.py!")
raise
else:
continue
elif self.has_submitblock == False:
try:
log.debug("Submitting Block with getblocktemplate submit: attempt #"+str(attempt))
log.debug([block_hex,])
resp = (yield self._call('getblocktemplate', [{'mode': 'submit', 'data': block_hex}]))
break
except Exception as e:
if attempts > 5:
log.exception("getblocktemplate submit failed. Problem Submitting block %s" % str(e))
log.exception("Try Enabling TX Messages in config.py!")
raise
else:
continue
else: # self.has_submitblock = None; unable to detect submitblock, try both
try:
log.debug("Submitting Block with submitblock")
log.debug([block_hex,])
resp = (yield self._call('submitblock', [block_hex,]))
break
except Exception as e:
try:
log.exception("submitblock Failed, does the coind have submitblock?")
log.exception("Trying GetBlockTemplate")
resp = (yield self._call('getblocktemplate', [{'mode': 'submit', 'data': block_hex}]))
break
except Exception as e:
if attempts > 5:
log.exception("submitblock failed. Problem Submitting block %s" % str(e))
log.exception("Try Enabling TX Messages in config.py!")
raise
else:
continue
if json.loads(resp)['result'] == None:
# make sure the block was created.
defer.returnValue((yield self.blockexists(hash_hex)))
else:
defer.returnValue(False)
@defer.inlineCallbacks @defer.inlineCallbacks
def getinfo(self): def getinfo(self):