diff options
| author | ruki <[email protected]> | 2022-05-21 09:18:25 +0800 |
|---|---|---|
| committer | ruki <[email protected]> | 2022-05-21 09:18:25 +0800 |
| commit | 9b07378b1e3bea7d02c3d9d556a09f71ae53d610 (patch) | |
| tree | 9a99c3bd50686cde98332211ae744e201ef3e516 /xmake/modules/private/service/remote_cache/server.lua | |
| parent | 3387f817869fa72eaef44cae85220223cc5514f5 (diff) | |
clean files for remote cache
Diffstat (limited to 'xmake/modules/private/service/remote_cache/server.lua')
| -rw-r--r-- | xmake/modules/private/service/remote_cache/server.lua | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/xmake/modules/private/service/remote_cache/server.lua b/xmake/modules/private/service/remote_cache/server.lua index 354e9abf8..c62a15e84 100644 --- a/xmake/modules/private/service/remote_cache/server.lua +++ b/xmake/modules/private/service/remote_cache/server.lua @@ -86,6 +86,13 @@ function remote_cache_server:_on_handle(stream, msg) self._SESSIONS[session_id] = nil else assert(session:is_connected(), "session has not been connected!") + if msg:is_push() then + session:push(respmsg) + elseif msg:is_pull() then + session:pull(respmsg) + elseif msg:is_clean() then + session:clean() + end end return true end, |