From 4aff396b05136629fa0a8f99705749d84b2cfed7 Mon Sep 17 00:00:00 2001
From: sebres <serg.brester@sebres.de>
Date: Wed, 8 Jul 2015 11:10:05 +0200
Subject: [PATCH] deserialize "close" message not expected (was not
 serialized). closes #1103

---
 fail2ban/server/asyncserver.py | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/fail2ban/server/asyncserver.py b/fail2ban/server/asyncserver.py
index 4caa702f..a9be0ae2 100644
--- a/fail2ban/server/asyncserver.py
+++ b/fail2ban/server/asyncserver.py
@@ -65,14 +65,16 @@ class RequestHandler(asynchat.async_chat):
 
 	def found_terminator(self):
 		# Pop whole buffer
-		buf = self.__buffer
+		message = self.__buffer
 		self.__buffer = []		
 		# Joins the buffer items.
-		message = loads(CSPROTO.EMPTY.join(buf))
+		message = CSPROTO.EMPTY.join(message)
 		# Closes the channel if close was received
 		if message == CSPROTO.CLOSE:
 			self.close_when_done()
 			return
+		# Deserialize
+		message = loads(message)
 		# Gives the message to the transmitter.
 		message = self.__transmitter.proceed(message)
 		# Serializes the response.