From 5a67db08a505b68118d3eeeb89d32f04724261ef Mon Sep 17 00:00:00 2001 From: ruki Date: Sun, 10 Apr 2022 20:19:43 +0800 Subject: send session id --- .../private/service/server/remote_build_server.lua | 15 ++++++++++----- 1 file changed, 10 insertions(+), 5 deletions(-) (limited to 'xmake/modules/private/service/server/remote_build_server.lua') diff --git a/xmake/modules/private/service/server/remote_build_server.lua b/xmake/modules/private/service/server/remote_build_server.lua index 606dd3c41..09dee6ba8 100644 --- a/xmake/modules/private/service/server/remote_build_server.lua +++ b/xmake/modules/private/service/server/remote_build_server.lua @@ -41,19 +41,24 @@ end -- handle connect message function remote_build_server:handle_connect(stream, msg) - local ok = stream:send_msg(message.new_connect()) and stream:flush() - vprint("%s: %s send %s", self, stream:sock(), ok and "ok" or "failed") + local session_id = msg:session_id() + local respmsg = msg:clone() + respmsg:body().xmakever = xmake.version():shortstr() + local ok = stream:send_msg(respmsg) and stream:flush() + vprint("%s: %s: : send %s", self, stream:sock(), session_id, ok and "ok" or "failed") end -- handle disconnect message function remote_build_server:handle_disconnect(stream, msg) - local ok = stream:send_msg(message.new_disconnect()) and stream:flush() - vprint("%s: %s send %s", self, stream:sock(), ok and "ok" or "failed") + local session_id = msg:session_id() + local respmsg = msg:clone() + local ok = stream:send_msg(respmsg) and stream:flush() + vprint("%s: %s: : send %s", self, stream:sock(), session_id, ok and "ok" or "failed") end -- on handle message function remote_build_server:on_handle(stream, msg) - vprint("%s: %s on handle message(%d)", self, stream:sock(), msg:code()) + vprint("%s: %s: : on handle message(%d)", self, stream:sock(), msg:session_id(), msg:code()) vprint(msg:body()) if msg:is_connect() then self:handle_connect(stream, msg) -- cgit v1.3.1