|
|
@@ -175,7 +175,7 @@ class Server(object):
|
|
|
# self.socket.settimeout(1)
|
|
|
|
|
|
def start(self):
|
|
|
- curio.run(self.run):
|
|
|
+ curio.run(self.run)
|
|
|
|
|
|
async def run(self):
|
|
|
self.setup()
|
|
|
@@ -250,11 +250,11 @@ class Server(object):
|
|
|
self.unregister_handler(handler, socket)
|
|
|
self.unregister_conn(socket)
|
|
|
handler.close()
|
|
|
- else:
|
|
|
- lschat.info("Client:"+data.strip())
|
|
|
- socket_handler.handle(data)
|
|
|
- except Exception as e:
|
|
|
- lserver.error(e, exc_info=True)
|
|
|
+ else:
|
|
|
+ lschat.info("Client:"+data.strip())
|
|
|
+ socket_handler.handle(data)
|
|
|
+ except Exception as e:
|
|
|
+ lserver.error(e, exc_info=True)
|
|
|
|
|
|
|
|
|
class Client(threading.Thread):
|
