Add plugin support infrastructure

4 files changed, 172 insertions, 1 deletions

diff --git a/src/Makefile.am b/src/Makefile.am
index 2bf71061..2b1f677c 100644
--- a/src/Makefile.am
+++ b/src/Makefile.am
@@ -1,7 +1,7 @@
 
 sbin_PROGRAMS = ofonod
 
-ofonod_SOURCES = main.c ofono.h log.c
+ofonod_SOURCES = main.c ofono.h log.c plugin.c
 
 ofonod_LDADD = @GDBUS_LIBS@ @GLIB_LIBS@ @GTHREAD_LIBS@ -ldl
 
diff --git a/src/main.c b/src/main.c
index de49ff4a..5eccb2c8 100644
--- a/src/main.c
+++ b/src/main.c
@@ -29,6 +29,10 @@ int main(int argc, char *argv[])
 {
 	__ofono_log_init();
 
+	__ofono_plugin_init(NULL, NULL);
+
+	__ofono_plugin_cleanup();
+
 	__ofono_log_cleanup();
 
 	return 0;
diff --git a/src/ofono.h b/src/ofono.h
index 03b4eeb1..aca0f02f 100644
--- a/src/ofono.h
+++ b/src/ofono.h
@@ -27,3 +27,8 @@
 
 int __ofono_log_init(void);
 void __ofono_log_cleanup(void);
+
+#include <ofono/plugin.h>
+
+int __ofono_plugin_init(const char *pattern, const char *exclude);
+void __ofono_plugin_cleanup(void);
diff --git a/src/plugin.c b/src/plugin.c
new file mode 100644
index 00000000..9fdb3325
--- /dev/null
+++ b/src/plugin.c
@@ -0,0 +1,162 @@
+/*
+ *
+ *  oFono - Open Telephony stack for Linux
+ *
+ *  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 <dlfcn.h>
+
+#include <glib.h>
+
+#include "ofono.h"
+
+static GSList *plugins = NULL;
+
+struct ofono_plugin {
+	void *handle;
+	gboolean active;
+	struct ofono_plugin_desc *desc;
+};
+
+static gint compare_priority(gconstpointer a, gconstpointer b)
+{
+	const struct ofono_plugin *plugin1 = a;
+	const struct ofono_plugin *plugin2 = b;
+
+	return plugin2->desc->priority - plugin1->desc->priority;
+}
+
+static gboolean add_plugin(void *handle, struct ofono_plugin_desc *desc)
+{
+	struct ofono_plugin *plugin;
+
+	if (desc->init == NULL)
+		return FALSE;
+
+	if (g_str_equal(desc->version, OFONO_VERSION) == FALSE) {
+		DBG("version mismatch for %s", desc->description);
+		return FALSE;
+	}
+
+	plugin = g_try_new0(struct ofono_plugin, 1);
+	if (plugin == NULL)
+		return FALSE;
+
+	plugin->handle = handle;
+	plugin->active = FALSE;
+	plugin->desc = desc;
+
+	plugins = g_slist_insert_sorted(plugins, plugin, compare_priority);
+
+	return TRUE;
+}
+
+int __ofono_plugin_init(const char *pattern, const char *exclude)
+{
+	GSList *list;
+	GDir *dir;
+	const gchar *file;
+	gchar *filename;
+
+	DBG("");
+
+	dir = g_dir_open(PLUGINDIR, 0, NULL);
+	if (dir != NULL) {
+		while ((file = g_dir_read_name(dir)) != NULL) {
+			void *handle;
+			struct ofono_plugin_desc *desc;
+
+			if (g_str_has_prefix(file, "lib") == TRUE ||
+					g_str_has_suffix(file, ".so") == FALSE)
+				continue;
+
+			filename = g_build_filename(PLUGINDIR, file, NULL);
+
+			handle = dlopen(filename, RTLD_NOW);
+			if (handle == NULL) {
+				g_warning("Can't load %s: %s", filename,
+								dlerror());
+				g_free(filename);
+				continue;
+			}
+
+			g_free(filename);
+
+			desc = dlsym(handle, "ofono_plugin_desc");
+			if (desc == NULL) {
+				g_warning("Can't load symbol: %s", dlerror());
+				dlclose(handle);
+				continue;
+			}
+
+			if (exclude != NULL && g_pattern_match_simple(exclude,
+							desc->name) == TRUE) {
+				DBG("excluding %s", desc->description);
+				dlclose(handle);
+				continue;
+			}
+
+			if (pattern != NULL && g_pattern_match_simple(pattern,
+							desc->name) == FALSE) {
+				DBG("ignoring %s", desc->description);
+				dlclose(handle);
+				continue;
+			}
+
+			if (add_plugin(handle, desc) == FALSE)
+				dlclose(handle);
+		}
+
+		g_dir_close(dir);
+	}
+
+	for (list = plugins; list; list = list->next) {
+		struct ofono_plugin *plugin = list->data;
+
+		if (plugin->desc->init() < 0)
+			continue;
+
+		plugin->active = TRUE;
+	}
+
+	return 0;
+}
+
+void __ofono_plugin_cleanup(void)
+{
+	GSList *list;
+
+	DBG("");
+
+	for (list = plugins; list; list = list->next) {
+		struct ofono_plugin *plugin = list->data;
+
+		if (plugin->active == TRUE && plugin->desc->exit)
+			plugin->desc->exit();
+
+		dlclose(plugin->handle);
+
+		g_free(plugin);
+	}
+
+	g_slist_free(plugins);
+}