summaryrefslogtreecommitdiff
path: root/c/sources/client.c
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--c/sources/client.c96
1 files changed, 96 insertions, 0 deletions
diff --git a/c/sources/client.c b/c/sources/client.c
new file mode 100644
index 0000000..672e3e8
--- /dev/null
+++ b/c/sources/client.c
@@ -0,0 +1,96 @@
+#define EZIPC_IMPL
+#include "ezipc.h"
+
+#include "common.h"
+
+
+int main(void)
+{
+ printf("EZIPC C Client\n");
+
+
+ printf("Connecting...");
+ fflush(stdout);
+
+ ezi_conn* conn = ezi_connect(EZIPC_TEST_PATH);
+ assert(conn);
+
+ printf(" DONE!\n");
+
+ msg msg_txt = { .type = MSG_TEXT };
+ msg msg_exit = { .type = MSG_EXIT };
+
+ bool running = true;
+ while(running)
+ {
+ char in[1024] = {0};
+ printf("send> ");
+ scanf("%[^\n]%*c", in);
+
+ if(strcmp(in, "exit") != 0)
+ {
+ strcpy((char*)msg_txt.data, in);
+ if(!ezi_send(conn, &msg_txt, sizeof(msg_txt)))
+ {
+ printf("Send error, resetting...\n");
+
+ ezi_disconnect(conn);
+ conn = ezi_connect(EZIPC_TEST_PATH);
+ assert(conn);
+
+ continue;
+ }
+ }
+ else
+ {
+ if(!ezi_send(conn, &msg_exit, sizeof(msg_exit)))
+ {
+ ezi_disconnect(conn);
+ exit(1);
+ }
+
+ break;
+ }
+
+ msg rmsg = {0};
+ size_t rsz = sizeof(rmsg);
+ if(!ezi_recv(conn, &rmsg, &rsz))
+ {
+ printf("Recv error, resetting...\n");
+
+ ezi_disconnect(conn);
+ conn = ezi_connect(EZIPC_TEST_PATH);
+ assert(conn);
+
+ continue;
+ }
+
+ switch(rmsg.type)
+ {
+ case MSG_OK:
+ {
+ printf("acknowledged!\n");
+
+ } break;
+
+ case MSG_EXIT:
+ {
+ running = false;
+ printf("told to exit...\n");
+
+ } break;
+
+ case MSG_TEXT:
+ {
+ printf("received: '%s'\n", (char*)rmsg.data);
+
+ } break;
+
+ default: exit(1);
+ }
+ }
+
+ ezi_disconnect(conn);
+ return 0;
+}
+