github
/
fail2ban
mirror of https://github.com/fail2ban/fail2ban
1
0
Fork 0
Code Issues Releases Wiki Activity

deserialize "close" message not expected (was not serialized). 

closes #1103
pull/1108/head
sebres 2015-07-08 11:10:05 +02:00
parent 1ebea39ec5
commit 4aff396b05
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
fail2ban/server/asyncserver.py
View File

@ -65,14 +65,16 @@ class RequestHandler(asynchat.async_chat):
def found_terminator(self): def found_terminator(self):
# Pop whole buffer # Pop whole buffer
buf = self.__buffer message = self.__buffer
self.__buffer = [] self.__buffer = []
# Joins the buffer items. # Joins the buffer items.
message = loads(CSPROTO.EMPTY.join(buf)) message = CSPROTO.EMPTY.join(message)
# Closes the channel if close was received # Closes the channel if close was received
if message == CSPROTO.CLOSE: if message == CSPROTO.CLOSE:
self.close_when_done() self.close_when_done()
return return
# Deserialize
message = loads(message)
# Gives the message to the transmitter. # Gives the message to the transmitter.
message = self.__transmitter.proceed(message) message = self.__transmitter.proceed(message)
# Serializes the response. # Serializes the response.