/* * *  BlueZ - Bluetooth protocol stack for Linux * *  Copyright (C) 2006-2008  Marcel Holtmann <marcel@holtmann.org> * * *  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., 51 Franklin St, Fifth Floor, Boston, MA  02110-1301  USA * */#ifdef HAVE_CONFIG_H#include <config.h>#endif#include <unistd.h>#include <stdlib.h>#include <string.h>#include <sys/inotify.h>#ifndef IN_ONLYDIR#define IN_ONLYDIR 0x01000000#endif#include <glib.h>#include "logging.h"#include "notify.h"static GIOChannel *io = NULL;static int fd = -1;static int wd = -1;static char *name = NULL;static notify_func callback = NULL;static gboolean io_event(GIOChannel *chan, GIOCondition cond, gpointer data){	unsigned char buf[129], *ptr = buf;	gsize len;	GIOError err;	if (cond & (G_IO_HUP | G_IO_ERR))		return FALSE;	memset(buf, 0, sizeof(buf));	err = g_io_channel_read(chan, (gchar *) buf, sizeof(buf) - 1, &len);	if (err != G_IO_ERROR_NONE) {		if (err == G_IO_ERROR_AGAIN)			return TRUE;		error("Reading from inotify channel failed");		return FALSE;	}			while (len >= sizeof(struct inotify_event)) {		struct inotify_event *evt = (struct inotify_event *) ptr;		if (evt->wd == wd && callback) {			if (evt->mask & (IN_CREATE | IN_MOVED_TO))				callback(NOTIFY_CREATE, evt->name, NULL);			if (evt->mask & (IN_DELETE | IN_MOVED_FROM))				callback(NOTIFY_DELETE, evt->name, NULL);			if (evt->mask & IN_MODIFY)				callback(NOTIFY_MODIFY, evt->name, NULL);		}		len -= sizeof(struct inotify_event) + evt->len;		ptr += sizeof(struct inotify_event) + evt->len;	}	return TRUE;}void notify_init(void){	if (fd != -1)		return;	fd = inotify_init();	if (fd < 0) {		error("Creation of inotify context failed");		return;	}	io = g_io_channel_unix_new(fd);	if (!io) {		error("Creation of inotify channel failed");		return;	}	g_io_add_watch(io, G_IO_IN | G_IO_ERR | G_IO_HUP, io_event, NULL);}void notify_close(void){	if (fd == -1)		return;	if (wd != -1) {		inotify_rm_watch(fd, wd);		wd = -1;	}	if (io) {		g_io_channel_unref(io);		io = NULL;	}	close(fd);	fd = -1;	if (name) {		free(name);		name = NULL;	}}void notify_add(const char *pathname, notify_func func, void *user_data){	if (fd == -1 || wd != -1)		return;	if (name)		free(name);	name = strdup(pathname);	if (!name)		return;	wd = inotify_add_watch(fd, pathname,		IN_ONLYDIR | IN_CREATE | IN_DELETE | IN_MODIFY | IN_MOVE);	if (wd < 0)		error("Creation of watch for %s failed", pathname);	callback = func;}void notify_remove(const char *pathname){	if (fd == -1 || wd == -1)		return;	inotify_rm_watch(fd, wd);	wd = -1;	callback = NULL;}