cowrie/cowrie
1
0
Fork 0
mirror of https://github.com/cowrie/cowrie.git synced 2025-07-01 18:07:27 -04:00
Code Issues Packages Projects Releases Wiki Activity

Fix #805

Browse Source
This commit is contained in:
Michel Oosterhof
2018-07-11 12:36:37 +04:00
parent 1db627b7f8
commit 5438fd6a73
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
cowrie/output/mysql.py
View File

@ -34,7 +34,8 @@ class ReconnectingConnectionPool(adbapi.ConnectionPool):
self, interaction, *args, **kw) self, interaction, *args, **kw)
except MySQLdb.OperationalError as e: except MySQLdb.OperationalError as e:
if e[0] not in (2003, 2006, 2013): if e[0] not in (2003, 2006, 2013):
raise log.msg("RCP: got error {0}, retrying operation".format(e)) log.msg("RCP: got error {0}, retrying operation".format(e))
raise e
conn = self.connections.get(self.threadID()) conn = self.connections.get(self.threadID())
self.disconnect(conn) self.disconnect(conn)
# Try the interaction again # Try the interaction again
@ -208,7 +209,7 @@ class Output(cowrie.core.output.Output):
self.simpleQuery( self.simpleQuery(
'UPDATE `sessions` SET `termsize` = %s WHERE `id` = %s', 'UPDATE `sessions` SET `termsize` = %s WHERE `id` = %s',
('%sx%s' % (entry['width'], entry['height']), ('%sx%s' % (entry['width'], entry['height']),
entry["session"])) entry["session"]))
elif entry["eventid"] == 'cowrie.session.closed': elif entry["eventid"] == 'cowrie.session.closed':
self.simpleQuery( self.simpleQuery(