small fix to coresendmsg and client disconnects no longer log as an exception
This commit is contained in:
parent
d46aaa1005
commit
bc1ef88f82
2 changed files with 8 additions and 5 deletions
|
@ -506,7 +506,10 @@ class CoreRequestHandler(SocketServer.BaseRequestHandler):
|
||||||
while True:
|
while True:
|
||||||
try:
|
try:
|
||||||
message = self.receive_message()
|
message = self.receive_message()
|
||||||
except (IOError, EOFError):
|
except EOFError:
|
||||||
|
logger.info("client disconnected")
|
||||||
|
break
|
||||||
|
except IOError:
|
||||||
logger.exception("error receiving message")
|
logger.exception("error receiving message")
|
||||||
break
|
break
|
||||||
|
|
||||||
|
|
|
@ -98,7 +98,7 @@ def connect_to_session(sock, requested):
|
||||||
connect to the first one.
|
connect to the first one.
|
||||||
"""
|
"""
|
||||||
# request the session list
|
# request the session list
|
||||||
tlvdata = coreapi.CoreSessionTlv.pack(SessionTlvs.NUMBER.value, "0")
|
tlvdata = coreapi.CoreSessionTlv.pack(SessionTlvs.NUMBER.value, "")
|
||||||
flags = MessageFlags.STRING.value
|
flags = MessageFlags.STRING.value
|
||||||
smsg = coreapi.CoreSessionMessage.pack(flags, tlvdata)
|
smsg = coreapi.CoreSessionMessage.pack(flags, tlvdata)
|
||||||
sock.sendall(smsg)
|
sock.sendall(smsg)
|
||||||
|
@ -130,9 +130,9 @@ def connect_to_session(sock, requested):
|
||||||
print "requested session not found!"
|
print "requested session not found!"
|
||||||
return False
|
return False
|
||||||
|
|
||||||
print "joining session %s..." % session
|
print "joining session: %s" % session
|
||||||
tlvdata = coreapi.CoreSessionTlv.pack(SessionTlvs.NUMBER, session)
|
tlvdata = coreapi.CoreSessionTlv.pack(SessionTlvs.NUMBER.value, session)
|
||||||
flags = MessageFlags.ADD
|
flags = MessageFlags.ADD.value
|
||||||
smsg = coreapi.CoreSessionMessage.pack(flags, tlvdata)
|
smsg = coreapi.CoreSessionMessage.pack(flags, tlvdata)
|
||||||
sock.sendall(smsg)
|
sock.sendall(smsg)
|
||||||
return True
|
return True
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue