1 /*
2 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
3 *
4 * Copyright 2025 Olaf Wintermann. All rights reserved.
5 *
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted provided that the following conditions are met:
8 *
9 * 1. Redistributions of source code must retain the above copyright
10 * notice, this list of conditions and the following disclaimer.
11 *
12 * 2. Redistributions in binary form must reproduce the above copyright
13 * notice, this list of conditions and the following disclaimer in the
14 * documentation and/or other materials provided with the distribution.
15 *
16 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
17 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
18 * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
19 * ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDER OR CONTRIBUTORS BE
20 * LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
21 * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
22 * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
23 * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
24 * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
25 * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
26 * POSSIBILITY OF SUCH DAMAGE.
27 */
28
29 #ifndef UIC_MESSAGE_H
30 #define UIC_MESSAGE_H
31
32
33 #include <cx/string.h>
34 #include <cx/json.h>
35 #include <cx/buffer.h>
36
37 #ifndef _WIN32
38 #include <pthread.h>
39 #endif
40
41
42 #ifdef __cplusplus
43 extern "C" {
44 #endif
45
46
47 typedef struct UiMessageHandler UiMessageHandler;
48
49 typedef void(*msg_received_callback)(cxstring msg);
50
51 struct UiMessageHandler {
52 int (*start)(UiMessageHandler *handler);
53 int (*stop)(UiMessageHandler *handler);
54 int (*send)(UiMessageHandler *handler, cxstring msg);
55
56 msg_received_callback callback;
57 };
58
59 typedef struct UiSimpleMessageHandler {
60 UiMessageHandler handler;
61 int in;
62 int out;
63 #ifndef _WIN32
64 pthread_t in_thread;
65 pthread_t out_thread;
66 pthread_mutex_t queue_lock;
67 pthread_mutex_t avlbl_lock;
68 pthread_cond_t available;
69 #endif
70 CxBuffer *outbuf;
71 int stop;
72 } UiSimpleMessageHandler;
73
74 int uic_message_send_(UiMessageHandler *handler, cxstring msg);
75 #define uic_message_send(handler, msg) uic_message_send_(handler, cx_strcast(msg))
76
77 UiMessageHandler* uic_simple_msg_handler(int in, int out, msg_received_callback callback);
78 int uic_simple_msg_handler_start(UiMessageHandler *handler);
79 int uic_simple_msg_handler_stop(UiMessageHandler *handler);
80 int uic_simple_msg_handler_send(UiMessageHandler *handler, cxstring msg);
81
82 void* uic_simple_msg_handler_in_thread(void *data);
83 void* uic_simple_msg_handler_out_thread(void *data);
84
85
86 #ifdef __cplusplus
87 }
88 #endif
89
90 #endif /* UIC_MESSAGE_H */
91
92