adjustment for getting session from udp client
This commit is contained in:
parent
02bcdf617d
commit
76524abbc2
1 changed files with 7 additions and 2 deletions
|
@ -1123,9 +1123,9 @@ class CoreRequestHandler(SocketServer.BaseRequestHandler):
|
||||||
if execute_server:
|
if execute_server:
|
||||||
try:
|
try:
|
||||||
logger.info("executing: %s", execute_server)
|
logger.info("executing: %s", execute_server)
|
||||||
|
# assumed to be udp server
|
||||||
if not isinstance(self.server, CoreServer):
|
if not isinstance(self.server, CoreServer):
|
||||||
server = self.server.mainserver
|
server = self.server.mainserver
|
||||||
# assumed to be udp server
|
|
||||||
else:
|
else:
|
||||||
server = self.server
|
server = self.server
|
||||||
if message.flags & MessageFlags.STRING.value:
|
if message.flags & MessageFlags.STRING.value:
|
||||||
|
@ -1469,8 +1469,13 @@ class CoreRequestHandler(SocketServer.BaseRequestHandler):
|
||||||
i += 1
|
i += 1
|
||||||
else:
|
else:
|
||||||
if message.flags & MessageFlags.STRING.value and not message.flags & MessageFlags.ADD.value:
|
if message.flags & MessageFlags.STRING.value and not message.flags & MessageFlags.ADD.value:
|
||||||
|
# assumed to be udp server
|
||||||
|
if not isinstance(self.server, CoreServer):
|
||||||
|
server = self.server.mainserver
|
||||||
|
else:
|
||||||
|
server = self.server
|
||||||
# status request flag: send list of sessions
|
# status request flag: send list of sessions
|
||||||
return self.server.to_session_message(),
|
return server.to_session_message(),
|
||||||
|
|
||||||
# handle ADD or DEL flags
|
# handle ADD or DEL flags
|
||||||
for session_id in session_ids:
|
for session_id in session_ids:
|
||||||
|
|
Loading…
Add table
Reference in a new issue