Handle IPC responses on another thread

Author: archigup

include/ggl/attr.h

@@ -96,6 +96,16 @@
 #define NULL_TERMINATED_STRING_ARG(pos)
 #endif
 
+#ifdef __has_attribute
+#if __has_attribute(access)
+#define ACCESS(...) __attribute__((access(__VA_ARGS__)))
+#endif
+#endif
+
+#ifndef ACCESS
+#define ACCESS(...)
+#endif
+
 #ifdef __has_attribute
 #if __has_attribute(cold)
 #define COLD __attribute__((cold))
@@ -116,4 +126,14 @@
 #define CONST
 #endif
 
+#ifdef __has_attribute
+#if __has_attribute(flag_enum)
+#define FLAG_ENUM __attribute__((flag_enum))
+#endif
+#endif
+
+#ifndef FLAG_ENUM
+#define FLAG_ENUM
+#endif
+
 #endif

include/ggl/error.h

@@ -43,6 +43,8 @@ typedef enum NODISCARD GglError {
     GGL_ERR_REMOTE,
     /// Expected non-ok status
     GGL_ERR_EXPECTED,
+    /// Request timed out
+    GGL_ERR_TIMEOUT,
 } GglError;
 
 const char *ggl_strerror(GglError err);

priv_include/ggl/eventstream/rpc.h

@@ -21,7 +21,7 @@ typedef enum {
 } EventStreamMessageType;
 
 /// `:message-flags` header flags
-typedef enum {
+typedef enum FLAG_ENUM {
     EVENTSTREAM_CONNECTION_ACCEPTED = 1,
     EVENTSTREAM_TERMINATE_STREAM = 2,
 } EventStreamMessageFlags;

priv_include/ggl/ipc/client_priv.h

@@ -9,6 +9,17 @@
 #include <ggl/buffer.h>
 #include <ggl/error.h>
 
+/// Maximum size of eventstream packet.
+/// Can be configured with `-D GGL_IPC_MAX_MSG_LEN=<N>`.
+#ifndef GGL_IPC_MAX_MSG_LEN
+#define GGL_IPC_MAX_MSG_LEN 10000
+#endif
+
+/// Maximum size IPC functions will wait for server response
+#ifndef GGL_IPC_RESPONSE_TIMEOUT
+#define GGL_IPC_RESPONSE_TIMEOUT 10
+#endif
+
 /// Connect to GG-IPC server using component name.
 /// If svcuid is non-null, it will be filled with the component's identity
 /// token. Buffer must be able to hold at least GGL_IPC_SVCUID_STR_LEN.

src/error.c

@@ -40,6 +40,8 @@ const char *ggl_strerror(GglError err) {
         return "REMOTE";
     case GGL_ERR_EXPECTED:
         return "EXPECTED";
+    case GGL_ERR_TIMEOUT:
+        return "TIMEOUT";
     }
 
     assert(false);