blob: a323132a6a5f0ace6d6427b0751bd7d23b3be85d (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
|
--!A cross-platform build utility based on Lua
--
-- Licensed under the Apache License, Version 2.0 (the "License");
-- you may not use this file except in compliance with the License.
-- You may obtain a copy of the License at
--
-- http://www.apache.org/licenses/LICENSE-2.0
--
-- Unless required by applicable law or agreed to in writing, software
-- distributed under the License is distributed on an "AS IS" BASIS,
-- WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
-- See the License for the specific language governing permissions and
-- limitations under the License.
--
-- Copyright (C) 2015-present, TBOOX Open Source Group.
--
-- @author ruki
-- @file remote_build_server.lua
--
-- imports
import("private.service.config")
import("private.service.socket_stream")
import("private.service.message")
import("private.service.server.server")
-- define module
local remote_build_server = remote_build_server or server()
local super = remote_build_server:class()
-- init server
function remote_build_server:init(daemon)
super.init(self, daemon)
if self:daemon() then
config.load()
end
local listen = assert(config.get("remote_build.server.listen"), "config(remote_build.server.listen): not found!")
super.listen_set(self, listen)
super.handler_set(self, self.on_handle)
end
-- handle ping message
function remote_build_server:handle_ping(sock, msg)
local stream = socket_stream(sock)
if stream:send_msg(message.new_ping()) and stream:flush() then
print("send ok")
end
end
-- on handle message
function remote_build_server:on_handle(sock, msg)
if msg:is_ping() then
self:handle_ping(sock, msg)
end
end
-- get class
function remote_build_server:class()
return remote_build_server
end
function remote_build_server:__tostring()
return "<remote_build_server>"
end
function main(daemon)
local instance = remote_build_server()
instance:init(daemon ~= nil)
return instance
end
|