qa: Treat mininode p2p exceptions as fatal
This commit is contained in:
parent
ce829855cf
commit
a7820422e0
1 changed files with 7 additions and 7 deletions
|
@ -1502,6 +1502,7 @@ class NodeConnCB(object):
|
|||
except:
|
||||
print("ERROR delivering %s (%s)" % (repr(message),
|
||||
sys.exc_info()[0]))
|
||||
raise
|
||||
|
||||
def get_deliver_sleep_time(self):
|
||||
with mininode_lock:
|
||||
|
@ -1701,13 +1702,10 @@ class NodeConn(asyncore.dispatcher):
|
|||
self.cb.on_close(self)
|
||||
|
||||
def handle_read(self):
|
||||
try:
|
||||
t = self.recv(8192)
|
||||
if len(t) > 0:
|
||||
self.recvbuf += t
|
||||
self.got_data()
|
||||
except:
|
||||
pass
|
||||
|
||||
def readable(self):
|
||||
return True
|
||||
|
@ -1773,8 +1771,10 @@ class NodeConn(asyncore.dispatcher):
|
|||
self.got_message(t)
|
||||
else:
|
||||
logger.warning("Received unknown command from %s:%d: '%s' %s" % (self.dstaddr, self.dstport, command, repr(msg)))
|
||||
raise ValueError("Unknown command: '%s'" % (command))
|
||||
except Exception as e:
|
||||
logger.exception('got_data:', repr(e))
|
||||
raise
|
||||
|
||||
def send_message(self, message, pushbuf=False):
|
||||
if self.state != "connected" and not pushbuf:
|
||||
|
|
Loading…
Reference in a new issue