diff options
Diffstat (limited to 'src/icipc-client.c')
-rw-r--r-- | src/icipc-client.c | 104 |
1 files changed, 104 insertions, 0 deletions
diff --git a/src/icipc-client.c b/src/icipc-client.c new file mode 100644 index 0000000..aa71b1f --- /dev/null +++ b/src/icipc-client.c @@ -0,0 +1,104 @@ +/* PipeWire AGL Cluster IPC + * + * Copyright © 2021 Collabora Ltd. + * @author Julian Bouzas <julian.bouzas@collabora.com> + * + * SPDX-License-Identifier: MIT + */ + +#include <pthread.h> +#include <assert.h> + +#include <spa/pod/builder.h> +#include <icipc/icipc.h> + +struct client_data { + struct icipc_client *c; + pthread_mutex_t mutex; + pthread_cond_t cond; + bool reply_received; +}; + +static void +reply_handler (struct icipc_sender *self, const uint8_t *buffer, size_t size, void *p) +{ + struct client_data *data = p; + const char *error = NULL; + const struct spa_pod *pod = icipc_client_send_request_finish (self, buffer, size, &error); + if (!pod) + printf ("error: %s\n", error ? error : "unknown"); + else + printf ("success!\n"); + + /* signal reply received */ + pthread_mutex_lock (&data->mutex); + data->reply_received = true; + pthread_cond_signal (&data->cond); + pthread_mutex_unlock (&data->mutex); +} + +int +main (int argc, char *argv[]) +{ + struct client_data data; + + if (argc < 2) { + printf ("usage: <server-path>\n"); + return -1; + } + + /* init */ + data.c = icipc_client_new (argv[1], true); + pthread_mutex_init (&data.mutex, NULL); + pthread_cond_init (&data.cond, NULL); + data.reply_received = false; + + while (true) { + char str[1024]; + + printf ("> "); + fgets (str, 1023, stdin); + + if (strncmp (str, "help", 4) == 0) { + printf ("help\tprints this message\n"); + printf ("quit\texits the client\n"); + printf ("send\tsends a request, usage: send <request-name> [args]\n"); + } else if (strncmp (str, "quit", 4) == 0) { + printf ("exiting...\n"); + break; + } else if (strncmp (str, "send", 4) == 0) { + char request_name[128]; + char request_args[1024]; + int n = sscanf(str, "send %s %s", request_name, request_args); + if (n <= 0) + continue; + + /* send request */ + if (n >= 2) { + /* TODO: for now we always create a string pod for args */ + struct { + struct spa_pod_string pod; + char str[1024]; + } args; + args.pod = SPA_POD_INIT_String(1024); + strncpy (args.str, request_args, 1024); + icipc_client_send_request (data.c, request_name, (const struct spa_pod *)&args, + reply_handler, &data); + } else { + icipc_client_send_request (data.c, request_name, NULL, reply_handler, &data); + } + + /* wait for reply */ + pthread_mutex_lock (&data.mutex); + while (!data.reply_received) + pthread_cond_wait (&data.cond, &data.mutex); + pthread_mutex_unlock (&data.mutex); + } + } + + /* clean up */ + pthread_cond_destroy (&data.cond); + pthread_mutex_destroy (&data.mutex); + icipc_client_free (data.c); + return 0; +} |