diff options
Diffstat (limited to 'src/daq/nginx-lua/s5-nginx.lua')
-rw-r--r-- | src/daq/nginx-lua/s5-nginx.lua | 8 |
1 files changed, 3 insertions, 5 deletions
diff --git a/src/daq/nginx-lua/s5-nginx.lua b/src/daq/nginx-lua/s5-nginx.lua index 475a576..13925c5 100644 --- a/src/daq/nginx-lua/s5-nginx.lua +++ b/src/daq/nginx-lua/s5-nginx.lua @@ -123,7 +123,8 @@ function _SFIVE.fetch() local ok, err = ngx.say(sfive_data:get(k)) if not ok then ngx.log(ngx.ERR, "SFive(fetch): failed to send data set: ", err) - break + lock:unlock("fetch") + return end sfive_data:delete(k) end @@ -141,10 +142,7 @@ function _SFIVE.fetch() end ngx.sleep(0.1) end - ok, err = lock:unlock("fetch") - if not ok then - ngx.log(ngx.ERR, "SFive(fetch): unlock error: " .. err) - end + lock:unlock("fetch") end end |