diff options
| author | ruki <[email protected]> | 2022-07-05 23:19:12 +0800 |
|---|---|---|
| committer | ruki <[email protected]> | 2022-07-05 23:19:12 +0800 |
| commit | 75604a4d159a554bc6664f5d7a41f422fb256f20 (patch) | |
| tree | 124eb46a67fc018ea6d5fa2117fda6fb08b1e376 /xmake/modules/private/service/remote_cache/client.lua | |
| parent | 5ad5e57ffd468bdec13f292773c7413201a68184 (diff) | |
add connect timeout
Diffstat (limited to 'xmake/modules/private/service/remote_cache/client.lua')
| -rw-r--r-- | xmake/modules/private/service/remote_cache/client.lua | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/xmake/modules/private/service/remote_cache/client.lua b/xmake/modules/private/service/remote_cache/client.lua index 1b3656eaa..c006d93b3 100644 --- a/xmake/modules/private/service/remote_cache/client.lua +++ b/xmake/modules/private/service/remote_cache/client.lua @@ -94,7 +94,7 @@ function remote_cache_client:connect() -- do connect local addr = self:addr() local port = self:port() - local sock = assert(socket.connect(addr, port), "%s: server unreachable!", self) + local sock = assert(socket.connect(addr, port, {timeout = self:connect_timeout()}), "%s: server unreachable!", self) local session_id = self:session_id() local ok = false local errors @@ -137,7 +137,7 @@ function remote_cache_client:disconnect() end local addr = self:addr() local port = self:port() - local sock = socket.connect(addr, port) + local sock = socket.connect(addr, port, {timeout = self:connect_timeout()}) local session_id = self:session_id() local errors local ok = false @@ -440,7 +440,7 @@ function remote_cache_client:_sock_open() local addr = self:addr() local port = self:port() - local sock = socket.connect(addr, port) + local sock = socket.connect(addr, port, {timeout = self:connect_timeout()}) if not sock then self._UNREACHABLE = true raise("%s: server unreachable!", self) |
