From 2b09ce9bb2ceeb3fafe81923cfab69742c4abacb Mon Sep 17 00:00:00 2001 From: dnomd343 Date: Fri, 31 Dec 2021 10:52:53 +0800 Subject: [PATCH] feat: gdbus method demo --- gdbus-method-demo/CMakeLists.txt | 7 +++ gdbus-method-demo/client/CMakeLists.txt | 13 ++++++ gdbus-method-demo/client/client.c | 47 +++++++++++++++++++ gdbus-method-demo/gdbus/CMakeLists.txt | 4 ++ gdbus-method-demo/gdbus/interface.xml | 9 ++++ gdbus-method-demo/includes/client.h | 19 ++++++++ gdbus-method-demo/includes/server.h | 23 ++++++++++ gdbus-method-demo/server/CMakeLists.txt | 13 ++++++ gdbus-method-demo/server/server.c | 60 +++++++++++++++++++++++++ 9 files changed, 195 insertions(+) create mode 100644 gdbus-method-demo/CMakeLists.txt create mode 100644 gdbus-method-demo/client/CMakeLists.txt create mode 100644 gdbus-method-demo/client/client.c create mode 100644 gdbus-method-demo/gdbus/CMakeLists.txt create mode 100644 gdbus-method-demo/gdbus/interface.xml create mode 100644 gdbus-method-demo/includes/client.h create mode 100644 gdbus-method-demo/includes/server.h create mode 100644 gdbus-method-demo/server/CMakeLists.txt create mode 100644 gdbus-method-demo/server/server.c diff --git a/gdbus-method-demo/CMakeLists.txt b/gdbus-method-demo/CMakeLists.txt new file mode 100644 index 0000000..b6abe72 --- /dev/null +++ b/gdbus-method-demo/CMakeLists.txt @@ -0,0 +1,7 @@ +cmake_minimum_required(VERSION 3.16) +set(CMAKE_CXX_STANDARD 14) +project(gdbus_method_demo) + +add_subdirectory(gdbus) +add_subdirectory(client) +add_subdirectory(server) diff --git a/gdbus-method-demo/client/CMakeLists.txt b/gdbus-method-demo/client/CMakeLists.txt new file mode 100644 index 0000000..dc05456 --- /dev/null +++ b/gdbus-method-demo/client/CMakeLists.txt @@ -0,0 +1,13 @@ +cmake_minimum_required(VERSION 3.16) + +INCLUDE_DIRECTORIES(${PROJECT_SOURCE_DIR}/includes) +INCLUDE_DIRECTORIES(${PROJECT_SOURCE_DIR}/gdbus) +INCLUDE_DIRECTORIES(/usr/include/glib-2.0) +INCLUDE_DIRECTORIES(/usr/include/gio-unix-2.0) +INCLUDE_DIRECTORIES(/usr/lib/glib-2.0/include) +INCLUDE_DIRECTORIES(/usr/lib/i386-linux-gnu/glib-2.0/include) +INCLUDE_DIRECTORIES(/usr/lib/x86_64-linux-gnu/glib-2.0/include) +INCLUDE_DIRECTORIES(/usr/lib/aarch64-linux-gnu/glib-2.0/include) + +add_executable(client client.c ${PROJECT_SOURCE_DIR}/gdbus/gdbus_demo_gen.c) +target_link_libraries(client rt pthread gio-2.0 glib-2.0 gobject-2.0 gmodule-2.0 gthread-2.0) diff --git a/gdbus-method-demo/client/client.c b/gdbus-method-demo/client/client.c new file mode 100644 index 0000000..0e1844b --- /dev/null +++ b/gdbus-method-demo/client/client.c @@ -0,0 +1,47 @@ +#include "client.h" + +// 发送请求 +static void send_text(const gchar *input_arg, gchar **output_arg, GError **error) { + com_gdbus_demo_call_send_text_sync(proxy, input_arg, output_arg, NULL, error); // 发送请求 + if (*error != NULL) { // 发送请求失败 + g_print("Failed to call method: %s.\n", (*error)->message); + g_error_free(*error); + } + g_print("Return -> %s\n", *output_arg); + g_free(*output_arg); +} + +// 初始化DBus连接 +bool init_dbus_client() { + GError *proxy_error = NULL; + GError *connect_error = NULL; + connection = g_bus_get_sync(G_BUS_TYPE_SESSION, NULL, &connect_error); // 建立连接 + if (connect_error != NULL) { // 连接失败 + g_print("Failed to connect dbus: %s.\n", connect_error->message); + g_error_free(connect_error); + return false; + } + proxy = com_gdbus_demo_proxy_new_sync(connection, G_DBUS_PROXY_FLAGS_NONE, "com.gdbus.demo", + "/com/gdbus/object", NULL, &proxy_error); // 创建Proxy + if (proxy == 0) { // 创建Proxy失败 + g_print("Failed to create proxy: %s.\n", proxy_error->message); + g_error_free(proxy_error); + return false; + } + return true; +} + +int main() { + char str[100]; + GError *error = NULL; + gchar *output_arg = NULL; + if (!init_dbus_client()) { // 初始化DBus失败 + return 0; + } + g_print("DBus init successfully.\n"); // DBus连接成功 + for (;;) { // 死循环 + printf("> "); + scanf("%s", str); + send_text(str, &output_arg, &error); // 发送请求 + } +} diff --git a/gdbus-method-demo/gdbus/CMakeLists.txt b/gdbus-method-demo/gdbus/CMakeLists.txt new file mode 100644 index 0000000..3fb4501 --- /dev/null +++ b/gdbus-method-demo/gdbus/CMakeLists.txt @@ -0,0 +1,4 @@ +cmake_minimum_required(VERSION 3.16) + +EXECUTE_PROCESS(COMMAND gdbus-codegen --generate-c-code + ${PROJECT_SOURCE_DIR}/gdbus/gdbus_demo_gen ${PROJECT_SOURCE_DIR}/gdbus/interface.xml) diff --git a/gdbus-method-demo/gdbus/interface.xml b/gdbus-method-demo/gdbus/interface.xml new file mode 100644 index 0000000..2b3927e --- /dev/null +++ b/gdbus-method-demo/gdbus/interface.xml @@ -0,0 +1,9 @@ + + + + + + + + + diff --git a/gdbus-method-demo/includes/client.h b/gdbus-method-demo/includes/client.h new file mode 100644 index 0000000..25fdf1d --- /dev/null +++ b/gdbus-method-demo/includes/client.h @@ -0,0 +1,19 @@ +#ifndef _CLIENT_H_ +#define _CLIENT_H_ + +#include +#include +#include +#include +#include +#include +#include +#include "gdbus_demo_gen.h" + +static ComGdbusDemo *proxy = NULL; +static GDBusConnection *connection = NULL; + +bool init_dbus_client(); +static void send_text(const gchar*, gchar**, GError**); + +#endif diff --git a/gdbus-method-demo/includes/server.h b/gdbus-method-demo/includes/server.h new file mode 100644 index 0000000..70db20e --- /dev/null +++ b/gdbus-method-demo/includes/server.h @@ -0,0 +1,23 @@ +#ifndef _SERVER_H_ +#define _SERVER_H_ + +#include +#include +#include +#include +#include +#include +#include "gdbus_demo_gen.h" + +static GMainLoop *main_loop = NULL; +static ComGdbusDemo *skeleton = NULL; +static GDBusConnection *connection = NULL; + +void init_dbus_server(); +static void* start_main_loop(void*); +static void gdbus_acquired_callback(GDBusConnection*, const gchar*, gpointer); +static void gdbus_name_acquired_callback(GDBusConnection*, const gchar*, gpointer); +static void gdbus_name_lost_callback(GDBusConnection*, const gchar*, gpointer); +static gboolean receive_text(ComGdbusDemo*, GDBusMethodInvocation*, const gchar*, gpointer); + +#endif diff --git a/gdbus-method-demo/server/CMakeLists.txt b/gdbus-method-demo/server/CMakeLists.txt new file mode 100644 index 0000000..812f121 --- /dev/null +++ b/gdbus-method-demo/server/CMakeLists.txt @@ -0,0 +1,13 @@ +cmake_minimum_required(VERSION 3.16) + +INCLUDE_DIRECTORIES(${PROJECT_SOURCE_DIR}/includes) +INCLUDE_DIRECTORIES(${PROJECT_SOURCE_DIR}/gdbus) +INCLUDE_DIRECTORIES(/usr/include/glib-2.0) +INCLUDE_DIRECTORIES(/usr/include/gio-unix-2.0) +INCLUDE_DIRECTORIES(/usr/lib/glib-2.0/include) +INCLUDE_DIRECTORIES(/usr/lib/i386-linux-gnu/glib-2.0/include) +INCLUDE_DIRECTORIES(/usr/lib/x86_64-linux-gnu/glib-2.0/include) +INCLUDE_DIRECTORIES(/usr/lib/aarch64-linux-gnu/glib-2.0/include) + +add_executable(server server.c ${PROJECT_SOURCE_DIR}/gdbus/gdbus_demo_gen.c) +target_link_libraries(server rt pthread gio-2.0 glib-2.0 gobject-2.0 gmodule-2.0 gthread-2.0) diff --git a/gdbus-method-demo/server/server.c b/gdbus-method-demo/server/server.c new file mode 100644 index 0000000..f177cae --- /dev/null +++ b/gdbus-method-demo/server/server.c @@ -0,0 +1,60 @@ +#include "server.h" + +// 进程主循环函数 +static void* start_main_loop(void* args) { + g_main_loop_run(main_loop); // 进入主循环 +} + +// 接收请求 +static gboolean receive_text(ComGdbusDemo *object, GDBusMethodInvocation *invocation, const gchar *input, gpointer user_data) { + g_print("Receive -> %s\n", input); + com_gdbus_demo_complete_send_text(object, invocation, "OK"); // 返回数据 + return true; // 请求处理成功 +} + +// 如果无法建立与总线的连接会调用 name_lost_handler() +// 如果无法获取 bus-name，会先调用 bus_acquired_handler()，再调用 name_lost_handler() +// 如果已获得 bus-name ，会先调用 bus_acquired_handler()，再调用 name_acquired_handler() + +// GDBus Acquired 回调 +static void gdbus_acquired_callback(GDBusConnection *callback_connection, const gchar *name, gpointer user_data) { + GError *error = NULL; + skeleton = com_gdbus_demo_skeleton_new(); + g_signal_connect(skeleton, "handle-send-text", G_CALLBACK(receive_text), NULL); // 设置对象接口 + g_dbus_interface_skeleton_export(G_DBUS_INTERFACE_SKELETON(skeleton), callback_connection, + "/com/gdbus/object", &error); // 绑定到对象上 + if (error != 0) { + g_print("Failed to export object: %s.\n", error->message); + g_error_free(error); + g_main_loop_quit(main_loop); // 退出主循环 + return; + } + g_print("Skeleton load successfully.\n"); +} + +// GDBus Name Acquired 回调 +static void gdbus_name_acquired_callback(GDBusConnection *callback_connection, const gchar *name, gpointer user_data) { + g_print("Acquired bus-name success.\n"); +} + +// GDBus Name Lost 回调 +static void gdbus_name_lost_callback(GDBusConnection *callback_connection, const gchar *name, gpointer user_data) { + g_print("Name lost error: Failed to get bus-name.\n"); + g_main_loop_quit(main_loop); // 退出主循环 +} + +// 初始化DBus连接 +void init_dbus_server() { + main_loop = g_main_loop_new(NULL, FALSE); // 创建主循环对象 + // 申请 bus-name 并将结果给到回调函数 + g_bus_own_name(G_BUS_TYPE_SESSION, "com.gdbus.demo", G_BUS_NAME_OWNER_FLAGS_NONE, + &gdbus_acquired_callback, &gdbus_name_acquired_callback, + &gdbus_name_lost_callback, NULL, NULL); +} + +int main() { + pthread_t tid; + init_dbus_server(); // 初始化DBus + pthread_create(&tid, NULL, start_main_loop, NULL); // 创建线程 进入主循环 + for (;;) {} // 死循环 +}