#include <types_internal.h>
#include <context_trigger_types_internal.h>
#include <Json.h>
-#include "server.h"
+#include "Server.h"
#include "access_control/Privilege.h"
#include "Request.h"
#include "ProviderHandler.h"
#include <app_manager.h>
#include <types_internal.h>
-#include "server.h"
+#include "Server.h"
#include "ClientRequest.h"
#include "access_control/PeerCreds.h"
#include "DBusServer.h"
return;
}
- server::send_request(request);
+ Server::sendRequest(request);
}
void DBusServer::__onRequestReceived(GDBusConnection *conn, const gchar *sender,
void DBusServer::__onNameAcquired(GDBusConnection *conn, const gchar *name, gpointer userData)
{
_SI("Dbus name acquired: %s", name);
- server::activate();
+ Server::activate();
}
void DBusServer::__onNameLost(GDBusConnection *conn, const gchar *name, gpointer userData)
GDBusConnection *__connection;
GDBusNodeInfo *__nodeInfo;
- friend class server;
+ friend class Server;
}; /* class ctx::DBusServer */
#include <types_internal.h>
#include <Json.h>
#include "access_control/Privilege.h"
-#include "server.h"
+#include "Server.h"
#include "Request.h"
#include "ProviderHandler.h"
--- /dev/null
+/*
+ * Copyright (c) 2015 Samsung Electronics Co., Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#include <stdlib.h>
+#include <new>
+#include <glib.h>
+#include <glib-object.h>
+
+#include <types_internal.h>
+#include "DBusServer.h"
+#include "db_mgr_impl.h"
+#include "ContextManagerImpl.h"
+#include "trigger/Trigger.h"
+#include "Server.h"
+
+static GMainLoop *mainloop = NULL;
+static bool started = false;
+
+static ctx::ContextManagerImpl *__contextMgr = NULL;
+static ctx::db_manager_impl *__databaseMgr = NULL;
+static ctx::DBusServer *__dbusHandle = NULL;
+static ctx::trigger::Trigger *__contextTrigger = NULL;
+
+/* TODO: re-organize activation & deactivation processes */
+void ctx::Server::initialize()
+{
+ _I("Init MainLoop");
+ mainloop = g_main_loop_new(NULL, FALSE);
+
+ _I("Init Dbus Connection");
+ __dbusHandle = new(std::nothrow) ctx::DBusServer();
+ IF_FAIL_VOID_TAG(__dbusHandle, _E, "Memory allocation failed");
+ IF_FAIL_VOID_TAG(__dbusHandle->__init(), _E, "Initialization Failed");
+
+ // Start the main loop
+ _I(CYAN("Launching Context-Service"));
+ g_main_loop_run(mainloop);
+}
+
+void ctx::Server::activate()
+{
+ IF_FAIL_VOID(!started);
+
+ bool result = false;
+
+ _I("Init Database Manager");
+ __databaseMgr = new(std::nothrow) ctx::db_manager_impl();
+ IF_FAIL_CATCH_TAG(__databaseMgr, _E, "Memory allocation failed");
+ db_manager::set_instance(__databaseMgr);
+ result = __databaseMgr->init();
+ IF_FAIL_CATCH_TAG(result, _E, "Initialization Failed");
+
+ _I("Init Context Manager");
+ __contextMgr = new(std::nothrow) ctx::ContextManagerImpl();
+ IF_FAIL_CATCH_TAG(__contextMgr, _E, "Memory allocation failed");
+ context_manager::setInstance(__contextMgr);
+ result = __contextMgr->init();
+ IF_FAIL_CATCH_TAG(result, _E, "Initialization Failed");
+
+ _I("Init Context Trigger");
+ __contextTrigger = new(std::nothrow) ctx::trigger::Trigger();
+ IF_FAIL_CATCH_TAG(__contextTrigger, _E, "Memory allocation failed");
+ result = __contextTrigger->init(__contextMgr);
+ IF_FAIL_CATCH_TAG(result, _E, "Initialization Failed");
+
+ started = true;
+ _I(CYAN("Context-Service Launched"));
+ return;
+
+CATCH:
+ _E(RED("Launching Failed"));
+
+ // Stop the main loop
+ g_main_loop_quit(mainloop);
+}
+
+void ctx::Server::release()
+{
+ _I(CYAN("Terminating Context-Service"));
+ _I("Release Context Trigger");
+ if (__contextTrigger)
+ __contextTrigger->release();
+
+ _I("Release Analyzer Manager");
+ if (__contextMgr)
+ __contextMgr->release();
+
+ _I("Release Dbus Connection");
+ if (__dbusHandle)
+ __dbusHandle->__release();
+
+ _I("Close the Database");
+ if (__databaseMgr)
+ __databaseMgr->release();
+
+ g_main_loop_unref(mainloop);
+
+ delete __contextTrigger;
+ delete __contextMgr;
+ delete __dbusHandle;
+ delete __databaseMgr;
+}
+
+static gboolean __postponeRequestAssignment(gpointer data)
+{
+ ctx::Server::sendRequest(static_cast<ctx::RequestInfo*>(data));
+ return FALSE;
+}
+
+void ctx::Server::sendRequest(ctx::RequestInfo* request)
+{
+ if (!started) {
+ _W("Service not ready...");
+ g_idle_add(__postponeRequestAssignment, request);
+ return;
+ }
+
+ if (!__contextTrigger->assignRequest(request)) {
+ __contextMgr->assignRequest(request);
+ }
+}
+
+static void __signalHandler(int signo)
+{
+ _I("SIGNAL %d received", signo);
+
+ // Stop the main loop
+ g_main_loop_quit(mainloop);
+}
+
+int main(int argc, char* argv[])
+{
+ static struct sigaction signalAction;
+ signalAction.sa_handler = __signalHandler;
+ sigemptyset(&signalAction.sa_mask);
+
+ sigaction(SIGINT, &signalAction, NULL);
+ sigaction(SIGHUP, &signalAction, NULL);
+ sigaction(SIGTERM, &signalAction, NULL);
+ sigaction(SIGQUIT, &signalAction, NULL);
+ sigaction(SIGABRT, &signalAction, NULL);
+
+#if !defined(GLIB_VERSION_2_36)
+ g_type_init();
+#endif
+
+ ctx::Server::initialize();
+ ctx::Server::release();
+
+ return EXIT_SUCCESS;
+}
--- /dev/null
+/*
+ * Copyright (c) 2015 Samsung Electronics Co., Ltd.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+#ifndef _CONTEXT_SERVER_H_
+#define _CONTEXT_SERVER_H_
+
+namespace ctx {
+
+ class RequestInfo;
+
+ class Server {
+ public:
+ static void initialize();
+ static void activate();
+ static void release();
+ static void sendRequest(RequestInfo* request);
+
+ };
+
+} /* namespace ctx */
+
+#endif /* End of _CONTEXT_SERVER_H_ */
#include <types_internal.h>
#include "PeerCreds.h"
-ctx::Credentials::Credentials(char *_packageId, char *_client, char *_session, char *_user) :
- packageId(_packageId),
- client(_client),
- session(_session),
- user(_user)
+ctx::Credentials::Credentials(char *pkgId, char *cli, char *sess, char *usr) :
+ packageId(pkgId),
+ client(cli),
+ session(sess),
+ user(usr)
{
}
char *client; /* default: smack label */
char *session;
char *user; /* default: UID */
- Credentials(char *_packageId, char *_client, char *_session, char *_user);
+ Credentials(char *pkgId, char *cli, char *sess, char *usr);
~Credentials();
};
#include <list>
#include <tzplatform_config.h>
#include <ScopeMutex.h>
-#include "server.h"
+#include "Server.h"
#include "db_mgr_impl.h"
#define CONTEXT_DB_PATH tzplatform_mkpath(TZ_USER_DB, ".context-service.db")
+++ /dev/null
-/*
- * Copyright (c) 2015 Samsung Electronics Co., Ltd.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#include <stdlib.h>
-#include <new>
-#include <glib.h>
-#include <glib-object.h>
-
-#include <types_internal.h>
-#include "DBusServer.h"
-#include "db_mgr_impl.h"
-#include "ContextManagerImpl.h"
-#include "trigger/Trigger.h"
-#include "server.h"
-
-static GMainLoop *mainloop = NULL;
-static bool started = false;
-
-static ctx::ContextManagerImpl *context_mgr = NULL;
-static ctx::db_manager_impl *database_mgr = NULL;
-static ctx::DBusServer *dbus_handle = NULL;
-static ctx::trigger::Trigger *context_trigger = NULL;
-
-/* TODO: re-organize activation & deactivation processes */
-void ctx::server::initialize()
-{
- _I("Init MainLoop");
- mainloop = g_main_loop_new(NULL, FALSE);
-
- _I("Init Dbus Connection");
- dbus_handle = new(std::nothrow) ctx::DBusServer();
- IF_FAIL_VOID_TAG(dbus_handle, _E, "Memory allocation failed");
- IF_FAIL_VOID_TAG(dbus_handle->__init(), _E, "Initialization Failed");
-
- // Start the main loop
- _I(CYAN("Launching Context-Service"));
- g_main_loop_run(mainloop);
-}
-
-void ctx::server::activate()
-{
- IF_FAIL_VOID(!started);
-
- bool result = false;
-
- _I("Init Database Manager");
- database_mgr = new(std::nothrow) ctx::db_manager_impl();
- IF_FAIL_CATCH_TAG(database_mgr, _E, "Memory allocation failed");
- db_manager::set_instance(database_mgr);
- result = database_mgr->init();
- IF_FAIL_CATCH_TAG(result, _E, "Initialization Failed");
-
- _I("Init Context Manager");
- context_mgr = new(std::nothrow) ctx::ContextManagerImpl();
- IF_FAIL_CATCH_TAG(context_mgr, _E, "Memory allocation failed");
- context_manager::setInstance(context_mgr);
- result = context_mgr->init();
- IF_FAIL_CATCH_TAG(result, _E, "Initialization Failed");
-
- _I("Init Context Trigger");
- context_trigger = new(std::nothrow) ctx::trigger::Trigger();
- IF_FAIL_CATCH_TAG(context_trigger, _E, "Memory allocation failed");
- result = context_trigger->init(context_mgr);
- IF_FAIL_CATCH_TAG(result, _E, "Initialization Failed");
-
- started = true;
- _I(CYAN("Context-Service Launched"));
- return;
-
-CATCH:
- _E(RED("Launching Failed"));
-
- // Stop the main loop
- g_main_loop_quit(mainloop);
-}
-
-void ctx::server::release()
-{
- _I(CYAN("Terminating Context-Service"));
- _I("Release Context Trigger");
- if (context_trigger)
- context_trigger->release();
-
- _I("Release Analyzer Manager");
- if (context_mgr)
- context_mgr->release();
-
- _I("Release Dbus Connection");
- if (dbus_handle)
- dbus_handle->__release();
-
- _I("Close the Database");
- if (database_mgr)
- database_mgr->release();
-
- g_main_loop_unref(mainloop);
-
- delete context_trigger;
- delete context_mgr;
- delete dbus_handle;
- delete database_mgr;
-}
-
-static gboolean postpone_request_assignment(gpointer data)
-{
- ctx::server::send_request(static_cast<ctx::RequestInfo*>(data));
- return FALSE;
-}
-
-void ctx::server::send_request(ctx::RequestInfo* request)
-{
- if (!started) {
- _W("Service not ready...");
- g_idle_add(postpone_request_assignment, request);
- return;
- }
-
- if (!context_trigger->assignRequest(request)) {
- context_mgr->assignRequest(request);
- }
-}
-
-static void signal_handler(int signo)
-{
- _I("SIGNAL %d received", signo);
-
- // Stop the main loop
- g_main_loop_quit(mainloop);
-}
-
-int main(int argc, char* argv[])
-{
- static struct sigaction signal_action;
- signal_action.sa_handler = signal_handler;
- sigemptyset(&signal_action.sa_mask);
-
- sigaction(SIGINT, &signal_action, NULL);
- sigaction(SIGHUP, &signal_action, NULL);
- sigaction(SIGTERM, &signal_action, NULL);
- sigaction(SIGQUIT, &signal_action, NULL);
- sigaction(SIGABRT, &signal_action, NULL);
-
-#if !defined(GLIB_VERSION_2_36)
- g_type_init();
-#endif
-
- ctx::server::initialize();
- ctx::server::release();
-
- return EXIT_SUCCESS;
-}
+++ /dev/null
-/*
- * Copyright (c) 2015 Samsung Electronics Co., Ltd.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-#ifndef __CONTEXT_SERVER_H__
-#define __CONTEXT_SERVER_H__
-
-namespace ctx {
-
- class RequestInfo;
-
- class server {
- public:
- static void initialize();
- static void activate();
- static void release();
- static void send_request(RequestInfo* request);
-
- };
-
-} /* namespace ctx */
-
-#endif /* End of __CONTEXT_SERVER_H__ */
projects / platform / core / context / context-service.git / commitdiff