Start work on worker->main pipe interface

1 files changed, 33 insertions, 0 deletions

diff --git a/src/libserver/rspamd_control.h b/src/libserver/rspamd_control.h
index ddca143cc..24874e785 100644
--- a/src/libserver/rspamd_control.h
+++ b/src/libserver/rspamd_control.h
@@ -38,6 +38,10 @@ enum rspamd_control_type {
 	RSPAMD_CONTROL_MAX
 };
 
+enum rspamd_srv_type {
+	RSPAMD_SRV_SOCKETPAIR = 0,
+};
+
 struct rspamd_control_command {
 	enum rspamd_control_type type;
 	union {
@@ -72,6 +76,29 @@ struct rspamd_control_reply {
 	} reply;
 };
 
+#define PAIR_ID_LEN 16
+struct rspamd_srv_command {
+	enum rspamd_srv_type type;
+	guint64 id;
+	union {
+		struct {
+			gint af;
+			gchar pair_id[PAIR_ID_LEN];
+			guint pair_num;
+		} spair;
+	} cmd;
+};
+
+struct rspamd_srv_reply {
+	enum rspamd_srv_type type;
+	guint64 id;
+	union {
+		struct {
+			gint code;
+		} spair;
+	} reply;
+};
+
 typedef gboolean (*rspamd_worker_control_handler) (struct rspamd_main *rspamd_main,
 		struct rspamd_worker *worker, gint fd,
 		struct rspamd_control_command *cmd,
@@ -97,4 +124,10 @@ void rspamd_control_worker_add_cmd_handler (struct rspamd_worker *worker,
 		rspamd_worker_control_handler handler,
 		gpointer ud);
 
+/**
+ * Start watching on srv pipe
+ */
+void rspamd_main_start_watching (struct rspamd_worker *worker,
+		struct event_base *ev_base);
+
 #endif