Refactor various watch functions

Use a common core kernel for all the watcher registrations /
notifications.  This is now done in watch.c

1 files changed, 104 insertions, 0 deletions

diff --git a/src/watch.c b/src/watch.c
new file mode 100644
index 00000000..9d5f8fbf
--- /dev/null
+++ b/src/watch.c
@@ -0,0 +1,104 @@
+/*
+ *
+ *  oFono - Open Source Telephony
+ *
+ *  Copyright (C) 2008-2009  Intel Corporation. All rights reserved.
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License version 2 as
+ *  published by the Free Software Foundation.
+ *
+ *  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 <glib.h>
+#include "ofono.h"
+
+struct ofono_watchlist *__ofono_watchlist_new(ofono_destroy_func destroy)
+{
+	struct ofono_watchlist *watchlist;
+
+	watchlist = g_new0(struct ofono_watchlist, 1);
+	watchlist->destroy = destroy;
+
+	return watchlist;
+}
+
+unsigned int __ofono_watchlist_add_item(struct ofono_watchlist *watchlist,
+					struct ofono_watchlist_item *item)
+{
+	item->id = ++watchlist->next_id;
+
+	watchlist->items = g_slist_prepend(watchlist->items, item);
+
+	return item->id;
+}
+
+gboolean __ofono_watchlist_remove_item(struct ofono_watchlist *watchlist,
+					unsigned int id)
+{
+	struct ofono_watchlist_item *item;
+	GSList *p;
+	GSList *c;
+
+	p = NULL;
+	c = watchlist->items;
+
+	while (c) {
+		item = c->data;
+
+		if (item->id != id) {
+			p = c;
+			c = c->next;
+			continue;
+		}
+
+		if (p)
+			p->next = c->next;
+		else
+			watchlist->items = c->next;
+
+		if (item->destroy)
+			item->destroy(item->notify_data);
+
+		if (watchlist->destroy)
+			watchlist->destroy(item);
+		g_slist_free_1(c);
+
+		return TRUE;
+	}
+
+	return FALSE;
+}
+
+void __ofono_watchlist_free(struct ofono_watchlist *watchlist)
+{
+	struct ofono_watchlist_item *item;
+	GSList *l;
+
+	for (l = watchlist->items; l; l = l->next) {
+		item = l->data;
+
+		if (item->destroy)
+			item->destroy(item->notify_data);
+
+		if (watchlist->destroy)
+			watchlist->destroy(item);
+	}
+
+	g_slist_free(watchlist->items);
+	watchlist->items = NULL;
+	g_free(watchlist);
+}