From 71ca67ca1aa99493d436c8a167bcfabe1eac2053 Mon Sep 17 00:00:00 2001 From: Christian Pointner Date: Sun, 19 Oct 2014 00:42:49 +0200 Subject: fixed fetch error handling --- src/daq/nginx-lua/s5-nginx.lua | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) (limited to 'src/daq/nginx-lua') 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 -- cgit v1.2.3