mirror of
https://github.com/xcat2/confluent.git
synced 2024-11-22 01:22:00 +00:00
-Have master console multiplexer not crash because a handler would have crashed
-Have sockapi remove console session handler on client disconnect
This commit is contained in:
parent
8fa9c10784
commit
4880de94e8
@ -53,7 +53,10 @@ class _ConsoleHandler(object):
|
||||
#and shrink buffer
|
||||
self.flushbuffer()
|
||||
for rcpt in self.rcpts.itervalues():
|
||||
rcpt(data)
|
||||
try:
|
||||
rcpt(data)
|
||||
except:
|
||||
pass
|
||||
|
||||
def get_recent(self):
|
||||
"""Retrieve 'recent' data
|
||||
|
@ -3,6 +3,7 @@
|
||||
|
||||
# This is the socket api layer.
|
||||
# It implement unix and tls sockets
|
||||
#
|
||||
# TODO: SO_PEERCRED for unix socket
|
||||
import confluent.console as console
|
||||
import confluent.config as config
|
||||
@ -19,6 +20,7 @@ def sessionhdl(connection):
|
||||
while (1):
|
||||
data = connection.read()
|
||||
if not data:
|
||||
consession.destroy()
|
||||
return
|
||||
consession.write(data)
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user