added mutli threaded environment

calling qlistener and tcpserver threads

1 files changed, 42 insertions, 0 deletions

diff --git a/nopsyncd/qlistener.lua b/nopsyncd/qlistener.lua
new file mode 100755
index 0000000..c850cc6
--- /dev/null
+++ b/nopsyncd/qlistener.lua
@@ -0,0 +1,42 @@
+--
+--  rhnop
+--
+--  Copyright (C) 2011 Christian Pointner <equinox@helsinki.at>
+--
+--  This file is part of rhnop.
+--
+--  rhnop is free software: you can redistribute it and/or modify
+--  it under the terms of the GNU General Public License as published by
+--  the Free Software Foundation, either version 3 of the License, or
+--  any later version.
+--
+--  rhnop is distributed in the hope that it will be useful,
+--  but WITHOUT ANY WARRANTY; without even the implied warranty of
+--  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+--  GNU General Public License for more details.
+--
+--  You should have received a copy of the GNU General Public License
+--  along with rhnop. If not, see <http://www.gnu.org/licenses/>.
+--
+
+local queue_name = "/rhnop"
+
+mq = require "luamq"
+
+function main_loop()
+   local q, err = mq.create(queue_name, "ro")
+   if q == nil then
+      io.stderr:write("creation of message queue failed: " .. err .. "\n")
+      os.exit(1)
+   end
+   
+   --while true do
+      local msg, prio = mq.receive(q)
+      if msg == nil then
+         io.stderr:write("recv error: " .. prio .. "\n")
+         os.exit(2)
+      end
+      
+      print("received message '" .. msg .. "' with prio: " .. prio)
+   --end
+end   
\ No newline at end of file