added pipe between worker threads

1 files changed, 4 insertions, 2 deletions

diff --git a/nopsyncd/qlistener.lua b/nopsyncd/qlistener.lua
index c850cc6..7594d68 100755
--- a/nopsyncd/qlistener.lua
+++ b/nopsyncd/qlistener.lua
@@ -30,7 +30,7 @@ function main_loop()
       os.exit(1)
    end
    
-   --while true do
+   while true do
       local msg, prio = mq.receive(q)
       if msg == nil then
          io.stderr:write("recv error: " .. prio .. "\n")
@@ -38,5 +38,7 @@ function main_loop()
       end
       
       print("received message '" .. msg .. "' with prio: " .. prio)
-   --end
+      
+      pipe.signal()
+   end
 end   
\ No newline at end of file