#include "stc-statistics.h"
#include "stc-restriction.h"
#include "stc-firewall.h"
-#include "stc-default-connection.h"
+#include "stc-pcap.h"
#include "stc-manager-util.h"
#include "stc-manager-plugin-appstatus.h"
#include "stc-manager-plugin-procfs.h"
+#include "stc-manager-plugin-monitor.h"
+#include "stc-manager-plugin-firewall.h"
#include "helper-iptables.h"
#define MANAGER_DBUS_ERROR_NAME "net.stc.manager.Error.Failed"
g_signal_connect(restriction, "handle-unset",
G_CALLBACK(handle_restriction_unset), stc);
+ g_signal_connect(restriction, "handle-set-list",
+ G_CALLBACK(handle_restriction_set_list), stc);
+
+ g_signal_connect(restriction, "handle-unset-list",
+ G_CALLBACK(handle_restriction_unset_list), stc);
+
/* Export the object (@manager takes its own reference to @object) */
g_dbus_object_manager_server_export(stc->obj_mgr,
G_DBUS_OBJECT_SKELETON(object));
return ret;
}
+static gboolean __stc_manager_gdbus_pcap_init(stc_s *stc)
+{
+ __STC_LOG_FUNC_ENTER__;
+ gboolean ret = TRUE;
+ gchar *s = NULL;
+
+ StcObjectSkeleton *object = NULL;
+ StcPcap *pcap = NULL;
+ s = g_strdup_printf(STC_DBUS_SERVICE_PCAP_PATH);
+
+ /* Add interface to default object path */
+ object = stc_object_skeleton_new(s);
+ g_free(s);
+
+ pcap = stc_pcap_skeleton_new();
+ stc_object_skeleton_set_pcap(object, pcap);
+ g_object_unref(pcap);
+
+ /* Register for method callbacks as signal callbacks */
+
+ g_signal_connect(pcap, "handle-start",
+ G_CALLBACK(handle_pcap_start),
+ stc);
+
+ g_signal_connect(pcap, "handle-stop",
+ G_CALLBACK(handle_pcap_stop),
+ stc);
+
+ g_signal_connect(pcap, "handle-get-all",
+ G_CALLBACK(handle_pcap_get_all),
+ stc);
+
+ g_signal_connect(pcap, "handle-find-all-devs",
+ G_CALLBACK(handle_pcap_find_all_devs),
+ stc);
+
+ /* Export the object (@manager takes its own reference to @object) */
+ g_dbus_object_manager_server_export(stc->obj_mgr,
+ G_DBUS_OBJECT_SKELETON(object));
+ g_object_unref(object);
+
+ stc->pcap_obj = (gpointer)pcap;
+
+ __STC_LOG_FUNC_EXIT__;
+ return ret;
+}
+
static gboolean __stc_manager_gdbus_manager_init(stc_s *stc)
{
__STC_LOG_FUNC_ENTER__;
/* Deinitialize and quit manager */
}
+ if (__stc_manager_gdbus_pcap_init(stc) == FALSE) {
+ STC_LOGE("Cannot signal connect to pcap"); //LCOV_EXCL_LINE
+ /* Deinitialize and quit manager */
+ }
+
if (__stc_manager_gdbus_manager_init(stc) == FALSE) {
STC_LOGE("Cannot signal connect to manager"); //LCOV_EXCL_LINE
/* Deinitialize and quit manager */
stc->connection);
iptables_init();
- stc_default_connection_monitor_init(stc);
+ stc_plugin_firewall_update();
+ stc_plugin_monitor_init_connection(stc);
stc_plugin_appstatus_register_state_changed_cb(stc,
stc_plugin_procfs_app_status_changed, NULL);
stc_s *stc = (stc_s *)stc_data;
stc_plugin_appstatus_deregister_state_changed_cb(stc);
- stc_default_connection_monitor_deinit(stc);
+ stc_plugin_monitor_deinit_connection(stc);
g_bus_unown_name(stc->gdbus_owner_id);
stc->statistics_obj = NULL;
stc->restriction_obj = NULL;
stc->firewall_obj = NULL;
+ stc->pcap_obj = NULL;
stc->manager_obj = NULL;
__STC_LOG_FUNC_EXIT__;
}
-GVariant *stc_manager_gdbus_call_sync(GDBusConnection *connection,
+API GVariant *stc_manager_gdbus_call_sync(GDBusConnection *connection,
const char *dest, const char *path,
const char *interface_name,
const char *method, GVariant *params)
return reply;
}
-guint stc_manager_gdbus_subscribe_signal(GDBusConnection *connection,
+API int stc_manager_gdbus_call_async(GDBusConnection *connection,
+ const char *dest, const char *path,
+ const char *interface_name,
+ const char *method, GVariant *params,
+ GAsyncReadyCallback notify_func,
+ void *user_data)
+{
+ if (connection == NULL) {
+ STC_LOGE("Failed to get GDBusconnection"); //LCOV_EXCL_LINE
+ return STC_ERROR_INVALID_PARAMETER; //LCOV_EXCL_LINE
+ }
+
+ g_dbus_connection_call(connection,
+ dest,
+ path,
+ interface_name,
+ method,
+ params,
+ NULL,
+ G_DBUS_CALL_FLAGS_NONE,
+ (5 * 1000), /* 5 seconds timeout */
+ NULL,
+ (GAsyncReadyCallback)notify_func,
+ (gpointer)user_data);
+
+ return STC_ERROR_NONE;
+}
+
+API guint stc_manager_gdbus_subscribe_signal(GDBusConnection *connection,
const gchar *sender,
const gchar *interface_name,
const gchar *member,
user_data_free_func);
}
-void stc_manager_gdbus_unsubscribe_signal(GDBusConnection *connection,
+API void stc_manager_gdbus_unsubscribe_signal(GDBusConnection *connection,
guint subscription_id)
{
if (connection == NULL) {
g_dbus_connection_signal_unsubscribe(connection, subscription_id);
}
-void stc_manager_gdbus_dict_foreach(GVariantIter *iter, dbus_dict_cb cb,
+API void stc_manager_gdbus_dict_foreach(GVariantIter *iter, dbus_dict_cb cb,
void *user_data)
{
__STC_LOG_FUNC_ENTER__;
while (g_variant_iter_loop(iter, "{sv}", &key, &value)) {
/* DEBUG_GDBUS_KEY_VALUE(key, value); */
- if (key && cb)
+ if (key)
cb(key, value, user_data);
}
__STC_LOG_FUNC_EXIT__;
}
-gboolean stc_manager_dbus_emit_signal(GDBusConnection *connection,
+API gboolean stc_manager_dbus_emit_signal(GDBusConnection *connection,
const gchar *object_path,
const gchar *interface_name,
const gchar *signal_name,
__STC_LOG_FUNC_ENTER__;
GVariant *return_parameters = NULL;
+ stc_set_keep_alive(TRUE);
+
STC_LOGI("stc manager stop");
return_parameters = g_variant_new("(i)", STC_ERROR_NONE);
char *err_str = NULL;
char cmd[STC_CMD_SIZE] = { 0, };
+ stc_set_keep_alive(TRUE);
+
if (option == NULL) {
STC_MANAGER_DBUS_REPLY_ERROR(invocation,
STC_ERROR_INVALID_PARAMETER);
char *err_str = NULL;
char cmd[STC_CMD_SIZE] = { 0, };
+ stc_set_keep_alive(TRUE);
+
if (option == NULL) {
STC_MANAGER_DBUS_REPLY_ERROR(invocation,
STC_ERROR_INVALID_PARAMETER);
projects / platform / core / connectivity / stc-manager.git / blobdiff