#include "autoconfig.h"
#ifdef RCL_MONITOR
/* Copyright (C) 2006 J.F.Dockes 
 *   This program 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 2 of the License, or
 *   (at your option) any later version.
 *
 *   This program 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 this program; if not, write to the
 *   Free Software Foundation, Inc.,
 *   59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 */
#include "autoconfig.h"

#include <errno.h>
#include <cstdio>
#include <cstring>
#include "safesysstat.h"
#include "safeunistd.h"

#include "log.h"
#include "rclmon.h"
#include "rclinit.h"
#include "fstreewalk.h"
#include "pathut.h"

/**
 * Recoll real time monitor event receiver. This file has code to interface 
 * to FAM or inotify and place events on the event queue.
 */

/** A small virtual interface for monitors. Lets
 *  either fam/gamin or raw imonitor hide behind 
 */
class RclMonitor {
public:
    RclMonitor()
	: saved_errno(0)
    {
    }

    virtual ~RclMonitor() 
    {
    }
    virtual bool addWatch(const string& path, bool isDir) = 0;
    virtual bool getEvent(RclMonEvent& ev, int msecs = -1) = 0;
    virtual bool ok() const = 0;
    // Does this monitor generate 'exist' events at startup?
    virtual bool generatesExist() const = 0; 

    // Save significant errno after monitor calls
    int saved_errno;
};

// Monitor factory. We only have one compiled-in kind at a time, no
// need for a 'kind' parameter
static RclMonitor *makeMonitor();

/** 
 * Create directory watches during the initial file system tree walk.
 *
 * This class is a callback for the file system tree walker
 * class. The callback method alternatively creates the directory
 * watches and flushes the event queue (to avoid a possible overflow
 * while we create the watches)
 */
class WalkCB : public FsTreeWalkerCB {
public:
    WalkCB(RclConfig *conf, RclMonitor *mon, RclMonEventQueue *queue,
        FsTreeWalker& walker)
	: m_config(conf), m_mon(mon), m_queue(queue), m_walker(walker)
    {}
    virtual ~WalkCB() 
    {}

    virtual FsTreeWalker::Status 
    processone(const string &fn, const struct stat *st, 
               FsTreeWalker::CbFlag flg)
    {
	MONDEB(("rclMonRcvRun: processone %s m_mon %p m_mon->ok %d\n", 
		 fn.c_str(), m_mon, m_mon?m_mon->ok():0));

        if (flg == FsTreeWalker::FtwDirEnter || 
            flg == FsTreeWalker::FtwDirReturn) {
            m_config->setKeyDir(fn);
            // Set up skipped patterns for this subtree. 
            m_walker.setSkippedNames(m_config->getSkippedNames());
        }

	if (flg == FsTreeWalker::FtwDirEnter) {
	    // Create watch when entering directory, but first empty
	    // whatever events we may already have on queue
	    while (m_queue->ok() && m_mon->ok()) {
		RclMonEvent ev;
		if (m_mon->getEvent(ev, 0)) {
		    if (ev.m_etyp !=  RclMonEvent::RCLEVT_NONE)
			m_queue->pushEvent(ev);
		} else {
		    MONDEB("rclMonRcvRun: no event pending\n");
		    break;
		}
	    }
	    if (!m_mon || !m_mon->ok())
		return FsTreeWalker::FtwError;
	    // We do nothing special if addWatch fails for a reasonable reason
	    if (!m_mon->addWatch(fn, true)) {
		if (m_mon->saved_errno != EACCES && 
		    m_mon->saved_errno != ENOENT)
		    return FsTreeWalker::FtwError;
	    }
	} else if (!m_mon->generatesExist() && 
		   flg == FsTreeWalker::FtwRegular) {
	    // Have to synthetize events for regular files existence
	    // at startup because the monitor does not do it
	    // Note 2011-09-29: no sure this is actually needed. We just ran
	    //  an incremental indexing pass (before starting the
	    //  monitor). Why go over the files once more ? The only
	    //  reason I can see would be to catch modifications that
	    //  happen between the incremental and the start of
	    //  monitoring ? There should be another way: maybe start
	    //  monitoring without actually handling events (just
	    //  queue), then run incremental then start handling
	    //  events ? But we also have to do it on a directory
	    //  move! So keep it
	    RclMonEvent ev;
	    ev.m_path = fn;
	    ev.m_etyp = RclMonEvent::RCLEVT_MODIFY;
	    m_queue->pushEvent(ev);
	}
	return FsTreeWalker::FtwOk;
    }

private:
    RclConfig         *m_config;
    RclMonitor        *m_mon;
    RclMonEventQueue  *m_queue;
    FsTreeWalker&      m_walker;
};

/** Main thread routine: create watches, then forever wait for and queue events */
void *rclMonRcvRun(void *q)
{
    RclMonEventQueue *queue = (RclMonEventQueue *)q;

    LOGDEB("rclMonRcvRun: running\n" );
    recoll_threadinit();
    // Make a local copy of the configuration as it doesn't like
    // concurrent accesses. It's ok to copy it here as the other
    // thread will not work before we have sent events.
    RclConfig lconfig(*queue->getConfig());

    // Create the fam/whatever interface object
    RclMonitor *mon;
    if ((mon = makeMonitor()) == 0) {
	LOGERR("rclMonRcvRun: makeMonitor failed\n" );
	queue->setTerminate();
	return 0;
    }


    // Get top directories from config 
    vector<string> tdl = lconfig.getTopdirs();
    if (tdl.empty()) {
	LOGERR("rclMonRcvRun:: top directory list (topdirs param.) notfound in config or Directory list parse error" );
	queue->setTerminate();
	return 0;
    }

    // Walk the directory trees to add watches
    FsTreeWalker walker;
    walker.setSkippedPaths(lconfig.getDaemSkippedPaths());
    WalkCB walkcb(&lconfig, mon, queue, walker);
    for (vector<string>::iterator it = tdl.begin(); it != tdl.end(); it++) {
	lconfig.setKeyDir(*it);
	// Adjust the follow symlinks options
	bool follow;
	if (lconfig.getConfParam("followLinks", &follow) && 
	    follow) {
	    walker.setOpts(FsTreeWalker::FtwFollow);
	} else {
	    walker.setOpts(FsTreeWalker::FtwOptNone);
	}
	LOGDEB("rclMonRcvRun: walking "  << *it << "\n" );
	if (walker.walk(*it, walkcb) != FsTreeWalker::FtwOk) {
	    LOGERR("rclMonRcvRun: tree walk failed\n" );
	    goto terminate;
	}
	if (walker.getErrCnt() > 0) {
	    LOGINFO("rclMonRcvRun: fs walker errors: "  << (walker.getReason()) << "\n" );
	}
    }

    {
	bool doweb = false;
	lconfig.getConfParam("processwebqueue", &doweb);
	if (doweb) {
	    string webqueuedir = lconfig.getWebQueueDir();
	    if (!mon->addWatch(webqueuedir, true)) {
		LOGERR("rclMonRcvRun: addwatch (webqueuedir) failed\n" );
		if (mon->saved_errno != EACCES && mon->saved_errno != ENOENT)
		    goto terminate;
	    }
	}
    }

    // Forever wait for monitoring events and add them to queue:
    MONDEB("rclMonRcvRun: waiting for events. q->ok(): " << queue->ok() <<
           std::endl);
    while (queue->ok() && mon->ok()) {
	RclMonEvent ev;
	// Note: I could find no way to get the select
	// call to return when a signal is delivered to the process
	// (it goes to the main thread, from which I tried to close or
	// write to the select fd, with no effect). So set a 
	// timeout so that an intr will be detected
	if (mon->getEvent(ev, 2000)) {
	    // Don't push events for skipped files. This would get
	    // filtered on the processing side anyway, but causes
	    // unnecessary wakeups and messages. Do not test
            // skippedPaths here, this would be incorrect (because a
            // topdir can be under a skippedPath and this was handled
            // while adding the watches).
	    lconfig.setKeyDir(path_getfather(ev.m_path));
	    walker.setSkippedNames(lconfig.getSkippedNames());
	    if (walker.inSkippedNames(path_getsimple(ev.m_path)))
		continue;

	    if (ev.m_etyp == RclMonEvent::RCLEVT_DIRCREATE) {
		// Recursive addwatch: there may already be stuff
		// inside this directory. Ie: files were quickly
		// created, or this is actually the target of a
		// directory move. This is necessary for inotify, but
		// it seems that fam/gamin is doing the job for us so
		// that we are generating double events here (no big
		// deal as prc will sort/merge).
		LOGDEB("rclMonRcvRun: walking new dir "  << (ev.m_path) << "\n" );
		if (walker.walk(ev.m_path, walkcb) != FsTreeWalker::FtwOk) {
		    LOGERR("rclMonRcvRun: walking new dir "  << (ev.m_path) << ": "  << (walker.getReason()) << "\n" );
		    goto terminate;
		}
		if (walker.getErrCnt() > 0) {
		    LOGINFO("rclMonRcvRun: fs walker errors: "  << (walker.getReason()) << "\n" );
		}
	    }

	    if (ev.m_etyp !=  RclMonEvent::RCLEVT_NONE)
		queue->pushEvent(ev);
	}
    }

terminate:
    queue->setTerminate();
    LOGINFO("rclMonRcvRun: monrcv thread routine returning\n" );
    return 0;
}

// Utility routine used by both the fam/gamin and inotify versions to get 
// rid of the id-path translation for a moved dir
bool eraseWatchSubTree(map<int, string>& idtopath, const string& top)
{
    bool found = false;
    MONDEB("Clearing map for [" << top << "]\n");
    map<int,string>::iterator it = idtopath.begin();
    while (it != idtopath.end()) {
	if (it->second.find(top) == 0) {
	    found = true;
	    idtopath.erase(it++);
	} else {
	    it++;
	}
    }
    return found;
}

// We dont compile both the inotify and the fam interface and inotify
// has preference
#ifndef RCL_USE_INOTIFY
#ifdef RCL_USE_FAM
//////////////////////////////////////////////////////////////////////////
/** Fam/gamin -based monitor class */
#include <fam.h>
#include <sys/select.h>
#include <setjmp.h>
#include <signal.h>

/** FAM based monitor class. We have to keep a record of FAM watch
    request numbers to directory names as the event only contain the
    request number and file name, not the full path */
class RclFAM : public RclMonitor {
public:
    RclFAM();
    virtual ~RclFAM();
    virtual bool addWatch(const string& path, bool isdir);
    virtual bool getEvent(RclMonEvent& ev, int msecs = -1);
    bool ok() const {return m_ok;}
    virtual bool generatesExist() const {return true;}

private:
    bool m_ok;
    FAMConnection m_conn;
    void close() {
	FAMClose(&m_conn);
	m_ok = false;
    }
    map<int,string> m_idtopath;
    const char *event_name(int code);
};

// Translate event code to string (debug)
const char *RclFAM::event_name(int code)
{
    static const char *famevent[] = {
        "",
        "FAMChanged",
        "FAMDeleted",
        "FAMStartExecuting",
        "FAMStopExecuting",
        "FAMCreated",
        "FAMMoved",
        "FAMAcknowledge",
        "FAMExists",
        "FAMEndExist"
    };
    static char unknown_event[30];
 
    if (code < FAMChanged || code > FAMEndExist) {
        sprintf(unknown_event, "unknown (%d)", code);
        return unknown_event;
    }
    return famevent[code];
}

RclFAM::RclFAM()
    : m_ok(false)
{
    if (FAMOpen2(&m_conn, "Recoll")) {
	LOGERR("RclFAM::RclFAM: FAMOpen2 failed, errno "  << (errno) << "\n" );
	return;
    }
    m_ok = true;
}

RclFAM::~RclFAM()
{
    if (ok())
	FAMClose(&m_conn);
}

static jmp_buf jbuf;
static void onalrm(int sig)
{
    longjmp(jbuf, 1);
}
bool RclFAM::addWatch(const string& path, bool isdir)
{
    if (!ok())
	return false;
    bool ret = false;

    MONDEB("RclFAM::addWatch: adding " << path << std::endl);

    // It happens that the following call block forever. 
    // We'd like to be able to at least terminate on a signal here, but
    // gamin forever retries its write call on EINTR, so it's not even useful
    // to unblock signals. SIGALRM is not used by the main thread, so at least
    // ensure that we exit after gamin gets stuck.
    if (setjmp(jbuf)) {
	LOGERR("RclFAM::addWatch: timeout talking to FAM\n" );
	return false;
    }
    signal(SIGALRM, onalrm);
    alarm(20);
    FAMRequest req;
    if (isdir) {
	if (FAMMonitorDirectory(&m_conn, path.c_str(), &req, 0) != 0) {
	    LOGERR("RclFAM::addWatch: FAMMonitorDirectory failed\n" );
	    goto out;
	}
    } else {
	if (FAMMonitorFile(&m_conn, path.c_str(), &req, 0) != 0) {
	    LOGERR("RclFAM::addWatch: FAMMonitorFile failed\n" );
	    goto out;
	}
    }
    m_idtopath[req.reqnum] = path;
    ret = true;

out:
    alarm(0);
    return ret;
}

// Note: return false only for queue empty or error 
// Return EVT_NONE for bad event to keep queue processing going
bool RclFAM::getEvent(RclMonEvent& ev, int msecs)
{
    if (!ok())
	return false;
    MONDEB("RclFAM::getEvent:\n");

    fd_set readfds;
    int fam_fd = FAMCONNECTION_GETFD(&m_conn);
    FD_ZERO(&readfds);
    FD_SET(fam_fd, &readfds);

    MONDEB("RclFAM::getEvent: select. fam_fd is " << fam_fd << std::endl);
    // Fam / gamin is sometimes a bit slow to send events. Always add
    // a little timeout, because if we fail to retrieve enough events,
    // we risk deadlocking in addwatch()
    if (msecs == 0)
	msecs = 2;
    struct timeval timeout;
    if (msecs >= 0) {
	timeout.tv_sec = msecs / 1000;
	timeout.tv_usec = (msecs % 1000) * 1000;
    }
    int ret;
    if ((ret=select(fam_fd+1, &readfds, 0, 0, msecs >= 0 ? &timeout : 0)) < 0) {
	LOGERR("RclFAM::getEvent: select failed, errno "  << (errno) << "\n" );
	close();
	return false;
    } else if (ret == 0) {
	// timeout
	MONDEB("RclFAM::getEvent: select timeout\n");
	return false;
    }

    MONDEB("RclFAM::getEvent: select returned " << ret << std::endl);

    if (!FD_ISSET(fam_fd, &readfds))
	return false;

    // ?? 2011/03/15 gamin v0.1.10. There is initially a single null
    // byte on the connection so the first select always succeeds. If
    // we then call FAMNextEvent we stall. Using FAMPending works
    // around the issue, but we did not need this in the past and this
    // is most weird.
    if (FAMPending(&m_conn) <= 0) {
	MONDEB("RclFAM::getEvent: FAMPending says no events\n");
	return false;
    }

    MONDEB("RclFAM::getEvent: call FAMNextEvent\n");
    FAMEvent fe;
    if (FAMNextEvent(&m_conn, &fe) < 0) {
	LOGERR("RclFAM::getEvent: FAMNextEvent failed, errno "  << (errno) << "\n" );
	close();
	return false;
    }
    MONDEB("RclFAM::getEvent: FAMNextEvent returned\n");
    
    map<int,string>::const_iterator it;
    if ((!path_isabsolute(fe.filename)) && 
	(it = m_idtopath.find(fe.fr.reqnum)) != m_idtopath.end()) {
	ev.m_path = path_cat(it->second, fe.filename);
    } else {
	ev.m_path = fe.filename;
    }

    MONDEB("RclFAM::getEvent: " << event_name(fe.code) < " " <<
           ev.m_path << std::endl);

    switch (fe.code) {
    case FAMCreated:
	if (path_isdir(ev.m_path)) {
	    ev.m_etyp = RclMonEvent::RCLEVT_DIRCREATE;
	    break;
	}
	/* FALLTHROUGH */
    case FAMChanged:
    case FAMExists:
	// Let the other side sort out the status of this file vs the db
	ev.m_etyp = RclMonEvent::RCLEVT_MODIFY;
	break;

    case FAMMoved: 
    case FAMDeleted:
	ev.m_etyp = RclMonEvent::RCLEVT_DELETE;
	// We would like to signal a directory here to enable cleaning
	// the subtree (on a dir move), but can't test the actual file
	// which is gone, and fam doesn't tell us if it's a dir or reg. 
	// Let's rely on the fact that a directory should be watched
	if (eraseWatchSubTree(m_idtopath, ev.m_path)) 
	    ev.m_etyp |= RclMonEvent::RCLEVT_ISDIR;
	break;

    case FAMStartExecuting:
    case FAMStopExecuting:
    case FAMAcknowledge:
    case FAMEndExist:
    default:
	// Have to return something, this is different from an empty queue,
	// esp if we are trying to empty it...
	if (fe.code != FAMEndExist)
	    LOGDEB("RclFAM::getEvent: got other event "  << (fe.code) << "!\n" );
	ev.m_etyp = RclMonEvent::RCLEVT_NONE;
	break;
    }
    return true;
}
#endif // RCL_USE_FAM
#endif // ! INOTIFY

#ifdef RCL_USE_INOTIFY
//////////////////////////////////////////////////////////////////////////
/** Inotify-based monitor class */
#include <sys/inotify.h>
#include <sys/select.h>

class RclIntf : public RclMonitor {
public:
    RclIntf()
	: m_ok(false), m_fd(-1), m_evp(0), m_ep(0)
    {
	if ((m_fd = inotify_init()) < 0) {
	    LOGERR("RclIntf:: inotify_init failed, errno "  << (errno) << "\n" );
	    return;
	}
	m_ok = true;
    }
    virtual ~RclIntf()
    {
	close();
    }

    virtual bool addWatch(const string& path, bool isdir);
    virtual bool getEvent(RclMonEvent& ev, int msecs = -1);
    bool ok() const {return m_ok;}
    virtual bool generatesExist() const {return false;}

private:
    bool m_ok;
    int m_fd;
    map<int,string> m_idtopath; // Watch descriptor to name
#define EVBUFSIZE (32*1024)
    char m_evbuf[EVBUFSIZE]; // Event buffer
    char *m_evp; // Pointer to next event or 0
    char *m_ep;  // Pointer to end of events
    const char *event_name(int code);
    void close() {
	if (m_fd >= 0) {
	    ::close(m_fd);
	    m_fd = -1;
	}
	m_ok = false;
    }
};

const char *RclIntf::event_name(int code) 
{
    code &= ~(IN_ISDIR|IN_ONESHOT);
    switch (code) {
    case IN_ACCESS: return "IN_ACCESS";
    case IN_MODIFY: return "IN_MODIFY";
    case IN_ATTRIB: return "IN_ATTRIB";
    case IN_CLOSE_WRITE: return "IN_CLOSE_WRITE";
    case IN_CLOSE_NOWRITE: return "IN_CLOSE_NOWRITE";
    case IN_CLOSE: return "IN_CLOSE";
    case IN_OPEN: return "IN_OPEN";
    case IN_MOVED_FROM: return "IN_MOVED_FROM";
    case IN_MOVED_TO: return "IN_MOVED_TO";
    case IN_MOVE: return "IN_MOVE";
    case IN_CREATE: return "IN_CREATE";
    case IN_DELETE: return "IN_DELETE";
    case IN_DELETE_SELF: return "IN_DELETE_SELF";
    case IN_MOVE_SELF: return "IN_MOVE_SELF";
    case IN_UNMOUNT: return "IN_UNMOUNT";
    case IN_Q_OVERFLOW: return "IN_Q_OVERFLOW";
    case IN_IGNORED: return "IN_IGNORED";
    default: {
	static char msg[50];
	sprintf(msg, "Unknown event 0x%x", code);
	return msg;
    }
    };
}

bool RclIntf::addWatch(const string& path, bool)
{
   if (!ok())
       return false;
   MONDEB("RclIntf::addWatch: adding " << path << std::endl);
    // CLOSE_WRITE is covered through MODIFY. CREATE is needed for mkdirs
    uint32_t mask = IN_MODIFY | IN_CREATE
        | IN_MOVED_FROM | IN_MOVED_TO | IN_DELETE
	// IN_ATTRIB used to be not needed to receive extattr
	// modification events, which was a bit weird because only ctime is
	// set, and now it is...
	| IN_ATTRIB
#ifdef IN_DONT_FOLLOW
	| IN_DONT_FOLLOW
#endif
#ifdef IN_EXCL_UNLINK
	| IN_EXCL_UNLINK
#endif
	;
    int wd;
    if ((wd = inotify_add_watch(m_fd, path.c_str(), mask)) < 0) {
	saved_errno = errno;
        LOGERR("RclIntf::addWatch: inotify_add_watch failed. errno "  << (saved_errno) << "\n" );
        if (errno == ENOSPC) {
            LOGERR("RclIntf::addWatch: ENOSPC error may mean that you needincrease the inotify kernel constants. See inotify(7)\n" );
        }
	return false;
    }
    m_idtopath[wd] = path;
    return true;
}

// Note: return false only for queue empty or error 
// Return EVT_NONE for bad event to keep queue processing going
bool RclIntf::getEvent(RclMonEvent& ev, int msecs)
{
    if (!ok())
	return false;
    ev.m_etyp = RclMonEvent::RCLEVT_NONE;
    MONDEB("RclIntf::getEvent:\n");

    if (m_evp == 0) {
	fd_set readfds;
	FD_ZERO(&readfds);
	FD_SET(m_fd, &readfds);
	struct timeval timeout;
	if (msecs >= 0) {
	    timeout.tv_sec = msecs / 1000;
	    timeout.tv_usec = (msecs % 1000) * 1000;
	}
	int ret;
	MONDEB("RclIntf::getEvent: select\n");
	if ((ret=select(m_fd + 1, &readfds, 0, 0, msecs >= 0 ? &timeout : 0)) < 0) {
	    LOGERR("RclIntf::getEvent: select failed, errno "  << (errno) << "\n" );
	    close();
	    return false;
	} else if (ret == 0) {
	    MONDEB("RclIntf::getEvent: select timeout\n");
	    // timeout
	    return false;
	}
	MONDEB("RclIntf::getEvent: select returned\n");

	if (!FD_ISSET(m_fd, &readfds))
	    return false;
	int rret;
	if ((rret=read(m_fd, m_evbuf, sizeof(m_evbuf))) <= 0) {
	    LOGERR("RclIntf::getEvent: read failed, "  << sizeof(m_evbuf) <<
                   "->"  << rret << " errno "  << errno << "\n");
	    close();
	    return false;
	}
	m_evp = m_evbuf;
	m_ep = m_evbuf + rret;
    }

    struct inotify_event *evp = (struct inotify_event *)m_evp;
    m_evp += sizeof(struct inotify_event);
    if (evp->len > 0)
	m_evp += evp->len;
    if (m_evp >= m_ep)
	m_evp = m_ep = 0;
    
    map<int,string>::const_iterator it;
    if ((it = m_idtopath.find(evp->wd)) == m_idtopath.end()) {
	LOGERR("RclIntf::getEvent: unknown wd "  << (evp->wd) << "\n" );
	return true;
    }
    ev.m_path = it->second;

    if (evp->len > 0) {
	ev.m_path = path_cat(ev.m_path, evp->name);
    }

    MONDEB("RclIntf::getEvent: " << event_name(evp->mask) << " " <<
           ev.m_path << std::endl);

    if ((evp->mask & IN_MOVED_FROM) && (evp->mask & IN_ISDIR)) {
	// We get this when a directory is renamed. Erase the subtree
	// entries in the map. The subsequent MOVED_TO will recreate
	// them. This is probably not needed because the watches
	// actually still exist in the kernel, so that the wds
	// returned by future addwatches will be the old ones, and the
	// map will be updated in place. But still, this feels safer
	eraseWatchSubTree(m_idtopath, ev.m_path);
    }

    // IN_ATTRIB used to be not needed, but now it is
    if (evp->mask & (IN_MODIFY|IN_ATTRIB)) {
	ev.m_etyp = RclMonEvent::RCLEVT_MODIFY;
    } else if (evp->mask & (IN_DELETE | IN_MOVED_FROM)) {
	ev.m_etyp = RclMonEvent::RCLEVT_DELETE;
	if (evp->mask & IN_ISDIR)
	    ev.m_etyp |= RclMonEvent::RCLEVT_ISDIR;
    } else if (evp->mask & (IN_CREATE | IN_MOVED_TO)) {
	if (evp->mask & IN_ISDIR) {
	    ev.m_etyp = RclMonEvent::RCLEVT_DIRCREATE;
	} else {
	    // We used to return null event because we would get a
	    // modify event later, but it seems not to be the case any
	    // more (10-2011). So generate MODIFY event
	    ev.m_etyp = RclMonEvent::RCLEVT_MODIFY;
	}
    } else if (evp->mask & (IN_IGNORED)) {
	if (!m_idtopath.erase(evp->wd)) {
	    LOGDEB0("Got IGNORE event for unknown watch\n" );
	} else {
	    eraseWatchSubTree(m_idtopath, ev.m_path);
	}
    } else {
	LOGDEB("RclIntf::getEvent: unhandled event "  << (event_name(evp->mask)) << " 0x"  << (evp->mask) << " "  << (ev.m_path) << "\n" );
	return true;
    }
    return true;
}

#endif // RCL_USE_INOTIFY


///////////////////////////////////////////////////////////////////////
// The monitor 'factory'
static RclMonitor *makeMonitor()
{
#ifdef RCL_USE_INOTIFY
    return new RclIntf;
#endif
#ifndef RCL_USE_INOTIFY
#ifdef RCL_USE_FAM    
    return new RclFAM;
#endif
#endif
    LOGINFO("RclMonitor: neither Inotify nor Fam was compiled as file system change notification interface\n" );
    return 0;
}
#endif // RCL_MONITOR