1 files changed, 73 insertions, 0 deletions
diff --git a/lib/mgmt_msg.h b/lib/mgmt_msg.h
new file mode 100644
index 0000000000..854875170b
--- /dev/null
+++ b/lib/mgmt_msg.h
@@ -0,0 +1,73 @@
+// SPDX-License-Identifier: GPL-2.0-or-later
+/*
+ * March 6 2023, Christian Hopps <chopps@labn.net>
+ *
+ * Copyright (c) 2023, LabN Consulting, L.L.C.
+ */
+#ifndef _MGMT_MSG_H
+#define _MGMT_MSG_H
+
+#include "stream.h"
+#include "thread.h"
+
+#define MGMT_MSG_MARKER (0x4D724B21u) /* ASCII - "MrK!"*/
+
+struct mgmt_msg_state {
+	struct stream *ins;
+	struct stream *outs;
+	struct stream_fifo inq;
+	struct stream_fifo outq;
+	uint64_t nrxm;		/* number of received messages */
+	uint64_t nrxb;		/* number of received bytes */
+	uint64_t ntxm;		/* number of sent messages */
+	uint64_t ntxb;		/* number of sent bytes */
+	size_t max_read_buf;	/* should replace with max time value */
+	size_t max_write_buf;	/* should replace with max time value */
+	size_t max_msg_sz;
+	char *idtag; /* identifying tag for messages */
+};
+
+struct mgmt_msg_hdr {
+	uint32_t marker;
+	uint32_t len;
+};
+
+enum mgmt_msg_rsched {
+	MSR_SCHED_BOTH,	  /* schedule both queue and read */
+	MSR_SCHED_STREAM, /* schedule read */
+	MSR_DISCONNECT,	  /* disconnect and start reconnecting */
+};
+
+enum mgmt_msg_wsched {
+	MSW_SCHED_NONE,	      /* no scheduling required */
+	MSW_SCHED_STREAM,     /* schedule writing */
+	MSW_SCHED_WRITES_OFF, /* toggle writes off */
+	MSW_DISCONNECT,	      /* disconnect and start reconnecting */
+};
+
+static inline uint8_t *msg_payload(struct mgmt_msg_hdr *mhdr)
+{
+	return (uint8_t *)(mhdr + 1);
+}
+
+typedef size_t (*mgmt_msg_packf)(void *msg, void *data);
+
+extern int mgmt_msg_connect(const char *path, size_t sendbuf, size_t recvbuf,
+			    const char *dbgtag);
+extern void mgmt_msg_destroy(struct mgmt_msg_state *ms);
+extern void mgmt_msg_init(struct mgmt_msg_state *ms, size_t max_read_buf,
+			  size_t max_write_buf, size_t max_msg_sz,
+			  const char *idtag);
+extern bool mgmt_msg_procbufs(struct mgmt_msg_state *ms,
+			      void (*handle_msg)(void *user, uint8_t *msg,
+						 size_t msglen),
+			      void *user, bool debug);
+extern enum mgmt_msg_rsched mgmt_msg_read(struct mgmt_msg_state *ms, int fd,
+					  bool debug);
+extern size_t mgmt_msg_reset_writes(struct mgmt_msg_state *ms);
+extern int mgmt_msg_send_msg(struct mgmt_msg_state *ms, void *msg, size_t len,
+			     size_t (*packf)(void *msg, void *buf), bool debug);
+extern enum mgmt_msg_wsched mgmt_msg_write(struct mgmt_msg_state *ms, int fd,
+					   bool debug);
+
+#endif /* _MGMT_MSG_H */