/* vi: set et sw=4 ts=4 cino=t0,(0: */
/* -*- Mode: C; indent-tabs-mode: nil; c-basic-offset: 4 -*- */
/*
+ * This file is part of message-port.
+ *
* Copyright (C) 2013 Intel Corporation.
*
* Contact: Amarnath Valluri <amarnath.valluri@linux.intel.com>
*/
#include "manager.h"
+#include "common/dbus-error.h"
#include "common/log.h"
#include "dbus-manager.h"
#include "dbus-service.h"
+#include "utils.h"
G_DEFINE_TYPE (MsgPortManager, msgport_manager, G_TYPE_OBJECT)
return MSGPORT_MANAGER (g_object_ref (manager));
}
+/*
+ * It returns the serice pointer, if found with given owner, port_name and is_trusted
+ * It assues the given arguments are valid.
+ */
+MsgPortDbusService *
+_manager_get_service_internal (
+ MsgPortManager *manager,
+ MsgPortDbusManager *owner,
+ const gchar *port_name,
+ gboolean is_trusted)
+{
+ GList *service_list = g_hash_table_lookup (manager->priv->owner_service_map, owner);
+
+ DBG ("Checking for port '%s', is_tursted : %d owned by : %p('%s')",
+ port_name, is_trusted, owner, msgport_dbus_manager_get_app_id (owner));
+
+ while (service_list != NULL) {
+ MsgPortDbusService *dbus_service = MSGPORT_DBUS_SERVICE (service_list->data);
+
+ if ( !g_strcmp0 (port_name, msgport_dbus_service_get_port_name (dbus_service)) &&
+ is_trusted == msgport_dbus_service_get_is_trusted (dbus_service)) {
+ DBG (" Found with %d", msgport_dbus_service_get_id (dbus_service));
+ return dbus_service ;
+ }
+
+ service_list = service_list->next;
+ }
+
+ DBG (" Not Found");
+
+ return NULL;
+}
+
MsgPortDbusService *
msgport_manager_register_service (
MsgPortManager *manager,
GError **error)
{
GList *service_list = NULL; /* services list owned by a client */
- gboolean was_empty = TRUE;
+ gboolean list_was_empty = TRUE;
MsgPortDbusService *dbus_service = NULL;
- g_return_val_if_fail (manager && MSGPORT_IS_MANAGER (manager), NULL);
- g_return_val_if_fail (owner && MSGPORT_IS_DBUS_MANAGER (owner), NULL);
+ msgport_return_val_if_fail_with_error (manager && MSGPORT_IS_MANAGER (manager), NULL, error);
+ msgport_return_val_if_fail_with_error (owner && MSGPORT_IS_DBUS_MANAGER (owner), NULL, error);
+ msgport_return_val_if_fail_with_error (port_name && port_name[0], NULL, error);
- if ((service_list = (GList *)g_hash_table_lookup (manager->priv->owner_service_map, owner)) != NULL) {
- GList *list = NULL;
+ /* check if port already existing with given params */
+ dbus_service = _manager_get_service_internal (manager, owner, port_name, is_trusted);
+ if (dbus_service != NULL)
+ return dbus_service;
- for (list = service_list; list != NULL; list = list->next) {
- MsgPortDbusService *dbus_service = (MsgPortDbusService *)list->data;
-
- if ( !g_strcmp0 (port_name, msgport_dbus_service_get_port_name (dbus_service))) {
- /* FIXME: return EALREADY error */
- return NULL;
- }
- }
- }
-
- was_empty = (service_list == NULL);
-
- dbus_service = msgport_dbus_service_new (owner, port_name, is_trusted);
+ /* create new port/service */
+ dbus_service = msgport_dbus_service_new (owner, port_name, is_trusted, error);
if (!dbus_service) {
- /* FIXME : return NOMEMERY error */
+ ERR ("Failed to create new servcie");
return NULL;
}
/* cache newly created service */
GINT_TO_POINTER (msgport_dbus_service_get_id (dbus_service)),
(gpointer)dbus_service);
+ service_list = g_hash_table_lookup (manager->priv->owner_service_map, owner);
+ list_was_empty = (service_list == NULL);
+
/* append to list of services */
service_list = g_list_append (service_list, dbus_service);
- if (was_empty) {
+ if (list_was_empty) {
g_hash_table_insert (manager->priv->owner_service_map, owner, service_list);
}
return dbus_service;
}
+
MsgPortDbusService *
msgport_manager_get_service (
MsgPortManager *manager,
MsgPortDbusManager *owner,
- const gchar *remote_port_name,
- gboolean is_trusted)
+ const gchar *port_name,
+ gboolean is_trusted,
+ GError **error)
{
- GList *service_list = NULL;
- g_return_val_if_fail (manager && MSGPORT_IS_MANAGER (manager), NULL);
+ MsgPortDbusService *service = NULL;
- service_list = g_hash_table_lookup (manager->priv->owner_service_map, owner);
- while (service_list != NULL) {
- MsgPortDbusService *dbus_service = MSGPORT_DBUS_SERVICE (service_list->data);
+ msgport_return_val_if_fail_with_error (manager && MSGPORT_IS_MANAGER (manager), NULL, error);
+ msgport_return_val_if_fail_with_error (owner && MSGPORT_IS_DBUS_MANAGER (owner), NULL, error);
+ msgport_return_val_if_fail_with_error (port_name && port_name[0], NULL, error);
- if ( !g_strcmp0 (remote_port_name, msgport_dbus_service_get_port_name (dbus_service)) &&
- is_trusted == msgport_dbus_service_get_is_trusted (dbus_service)) {
- return dbus_service ;
- }
+ service = _manager_get_service_internal (manager, owner, port_name, is_trusted);
- service_list = service_list->next;
- }
+ if (!service && error)
+ *error = msgport_error_port_not_found (msgport_dbus_manager_get_app_id (owner), port_name);
- /* FIXME: return ENOTFOUND */
- return NULL;
+ return service;
}
MsgPortDbusService *
msgport_manager_get_service_by_id (
MsgPortManager *manager,
- guint service_id)
+ guint service_id,
+ GError **error)
{
MsgPortDbusService *dbus_service = NULL;
- g_return_val_if_fail (manager && MSGPORT_IS_MANAGER (manager), NULL);
+
+ msgport_return_val_if_fail_with_error (manager && MSGPORT_IS_MANAGER (manager), NULL, error);
+ msgport_return_val_if_fail_with_error (service_id != 0, NULL, error);
dbus_service = MSGPORT_DBUS_SERVICE (g_hash_table_lookup (
manager->priv->service_cache, GINT_TO_POINTER(service_id)));
}
static void
-_unref_dbus_manager_cb (gpointer data, gpointer user_data)
+_manager_unref_dbus_manager_cb (gpointer data, gpointer user_data)
{
- MsgPortDbusService *service = MSGPORT_DBUS_SERVICE (data);
MsgPortManager *manager = MSGPORT_MANAGER (user_data);
+ MsgPortDbusService *service = MSGPORT_DBUS_SERVICE (data);
guint id = msgport_dbus_service_get_id (service);
+#ifdef ENABLE_DEBUG
DBG ("Unregistering service %s:%s(%d)",
msgport_dbus_manager_get_app_id (msgport_dbus_service_get_owner (service)),
msgport_dbus_service_get_port_name (service), id);
+#endif
/* remove the service from id:service map,
* as its being unregisted */
g_hash_table_remove (manager->priv->service_cache, GINT_TO_POINTER(id));
}
/*
- * unregister all the services owned by a client
- */
-gboolean
-msgport_manager_unregister_services (
- MsgPortManager *manager,
- MsgPortDbusManager *owner)
-{
-DBG("{");
- GList *service_list = NULL;
- g_return_val_if_fail (manager && MSGPORT_IS_MANAGER (manager), FALSE);
-
- /* fetch sevice list owned by the client */
- service_list = g_hash_table_lookup (manager->priv->owner_service_map, owner);
- if (!service_list) {
- DBG(" No service found");
- return FALSE;
- }
-
- /* remove all the service from the list */
- g_list_foreach (service_list, _unref_dbus_manager_cb, manager);
- g_hash_table_remove (manager->priv->owner_service_map, owner);
-DBG("}");
- return TRUE;
-}
-
-/*
* unregister a signle service for given service id
*/
gboolean
msgport_manager_unregister_service (
MsgPortManager *manager,
- gint service_id)
+ gint service_id,
+ GError **error)
{
MsgPortDbusService *service = NULL;
MsgPortDbusManager *owner = NULL;
GList *service_list = NULL, *new_service_list = NULL;
- g_return_val_if_fail (manager && MSGPORT_IS_MANAGER (manager), FALSE);
+
+ msgport_return_val_if_fail_with_error (manager && MSGPORT_IS_MANAGER (manager), FALSE, error);
service = g_hash_table_lookup (manager->priv->service_cache, GINT_TO_POINTER (service_id));
- if (!service) return FALSE;
+ if (!service) {
+ if (error) *error = msgport_error_port_id_not_found_new (service_id);
+ return FALSE;
+ }
owner = msgport_dbus_service_get_owner (service);
return TRUE;
}
+/*
+ * unregister all the services owned by a client
+ */
+gboolean
+msgport_manager_unregister_services (
+ MsgPortManager *manager,
+ MsgPortDbusManager *owner,
+ GError **error)
+{
+
+ GList *service_list = NULL;
+
+ msgport_return_val_if_fail_with_error (manager && MSGPORT_IS_MANAGER (manager), FALSE, error);
+
+ /* fetch sevice list owned by the client */
+ service_list = g_hash_table_lookup (manager->priv->owner_service_map, owner);
+ if (!service_list) {
+ DBG("no services found on client '%p'", owner);
+ return TRUE;
+ }
+
+ /* remove all the service from the list */
+ g_list_foreach (service_list, _manager_unref_dbus_manager_cb, manager);
+ g_hash_table_remove (manager->priv->owner_service_map, owner);
+
+ return TRUE;
+}
projects / platform / core / appfw / message-port-dbus.git / blobdiff