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

- Catched socket.error raised by socket.accept on some platform 

- Modified some socket settings

git-svn-id: https://fail2ban.svn.sourceforge.net/svnroot/fail2ban/trunk@555 a942ae1a-1317-0410-a47c-b1dcaea8d605
0.x
Cyril Jaquier 2007-03-07 20:53:37 +00:00
parent 0b9c41c015
commit 9cb7831758
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
server/ssocket.py
View File

@ -68,7 +68,7 @@ class SSocket(Thread):
#self.__ssock.bind(("localhost", 2222)) #self.__ssock.bind(("localhost", 2222))
self.__ssock.bind(sock) self.__ssock.bind(sock)
# Become a server socket # Become a server socket
self.__ssock.listen(5) self.__ssock.listen(1)
def run(self): def run(self):
self.__isRunning = True self.__isRunning = True
@ -80,6 +80,9 @@ class SSocket(Thread):
except socket.timeout: except socket.timeout:
# Do nothing here # Do nothing here
pass pass
except socket.error:
# Do nothing here
pass
self.__ssock.close() self.__ssock.close()
# Remove socket # Remove socket
if os.path.exists(self.__socket): if os.path.exists(self.__socket):
@ -122,7 +125,7 @@ class SocketWorker(Thread):
def __receive(sock): def __receive(sock):
msg = '' msg = ''
while msg.rfind(SSocket.END_STRING) == -1: while msg.rfind(SSocket.END_STRING) == -1:
chunk = sock.recv(6) chunk = sock.recv(128)
if chunk == '': if chunk == '':
raise RuntimeError, "socket connection broken" raise RuntimeError, "socket connection broken"
msg = msg + chunk msg = msg + chunk