From 45df73c4c0d343cf4c6e1a9a5cb886553a2d6440 Mon Sep 17 00:00:00 2001
From: Axel Kittenberger <axkibe@gmail.com>
Date: Sun, 28 Nov 2010 09:37:43 +0000
Subject: [PATCH] multi monitor support

---
 lsyncd.c   | 20 +++++++++++---------
 lsyncd.lua | 51 +++++++++++++++++++++++++++++++++++++++++++++++++--
 2 files changed, 60 insertions(+), 11 deletions(-)

diff --git a/lsyncd.c b/lsyncd.c
index e244629..faf13a9 100644
--- a/lsyncd.c
+++ b/lsyncd.c
@@ -1486,7 +1486,15 @@ main1(int argc, char *argv[])
 			lua_pushstring(L, argv[argp++]);
 			lua_settable(L, -3);
 		}
-		if (lua_pcall(L, 1, 1, -3)) {
+		/* creates a table with the cores event monitor interfaces */
+		idx = 0;
+		lua_newtable(L);
+		while (monitors[idx]) {
+			lua_pushnumber(L, idx + 1);
+			lua_pushstring(L, monitors[idx++]);
+			lua_settable(L, -3);
+		}
+		if (lua_pcall(L, 2, 1, -3)) {
 			exit(-1); // ERRNO
 		}
 		s = lua_tostring(L, -1);
@@ -1543,17 +1551,11 @@ main1(int argc, char *argv[])
 	}
 
 	{
-		int idx = 1;
+		int idx = 0;
 		/* runs initialitions from runner 
 		 * lua code will set configuration and add watches */
 		load_runner_func(L, "initialize");
-		lua_newtable(L);
-		while (monitors[idx]) {
-			lua_pushnumber(L, idx);
-			lua_pushstring(L, monitors[idx++]);
-			lua_settable(L, -3);
-		}
-		if (lua_pcall(L, 1, 0, -3)) {
+		if (lua_pcall(L, 0, 0, -2)) {
 			exit(-1); // ERRNO
 		}
 		lua_pop(L, 1);
diff --git a/lsyncd.lua b/lsyncd.lua
index 0472f3a..01a1b2c 100644
--- a/lsyncd.lua
+++ b/lsyncd.lua
@@ -1697,6 +1697,30 @@ local Inotify = (function()
 	}
 end)()
 
+-----
+-- Holds information about the event monitor capabilities
+-- of the core.
+--
+local Monitors = (function()
+	-----
+	-- The cores monitor list
+	local list = {}
+
+	-----
+	-- initializes with info received from core
+	--
+	local function initialize(clist)
+		for k, v in ipairs(clist) do
+			list[k] = v
+		end
+	end
+
+	-- public interface
+	return { list = list,
+	         initialize = initialize 
+	}
+end)()
+
 ------
 -- Writes functions for the user for layer 3 configuration.
 --
@@ -2080,6 +2104,8 @@ OPTIONS:
   -log    scarce      Logs errors only
   -log    [Category]  Turns on logging for a debug category
   -logfile FILE       Writes log to FILE (DEFAULT: uses syslog)
+  -monitor NAME       Uses operating systems event montior NAME 
+                      (inotify/fanotify/fsevents)
   -nodaemon           Does not detach and logs to stdout/stderr
   -pidfile FILE       Writes Lsyncds PID into FILE
   -runner FILE        Loads Lsyncds lua part from FILE 
@@ -2107,8 +2133,14 @@ local clSettings = {}
 --          or simply 'true' if running with rsync bevaiour
 -- terminates on invalid arguments
 --
-function runner.configure(args)
+function runner.configure(args, monitors)
+	Monitors.initialize(monitors)
+
 	-- a list of all valid --options
+	-- first paramter is number of options
+	--       if < 0 the function checks existance
+	-- second paramter is function to call when in args 
+	--
 	local options = {
 		-- log is handled by core already.
 		log      = 
@@ -2117,6 +2149,19 @@ function runner.configure(args)
 			{1, function(file)
 				clSettings.logfile=file
 			end},
+		monitor = 
+			{-1, function(monitor)
+				if not monitor then
+					io.stdout:write("This Lsyncd supports these monitors:\n")
+					for _, v in ipairs(Monitors.list) do
+						io.stdout:write("   ",v,"\n")
+					end
+					io.stdout:write("\n");
+					lsyncd.terminate(-1); -- ERRNO
+				else
+					clSettings.monitor=monitor
+				end
+			end},
 		nodaemon = 
 			{0, function() 
 				clSettings.nodaemon=true 
@@ -2156,9 +2201,11 @@ function runner.configure(args)
 			end
 			local o = options[a]
 			if o then
-				if i + o[1] > #args then
+				if o[1] >= 0 and i + o[1] > #args then
 					log("Error",a," needs ",o[1]," arguments")
 					os.exit(-1) -- ERRNO
+				else
+					o[1] = -o[1]
 				end
 				if o[2] then
 					if o[1] == 0 then