From 067296e8eb54fd78793696e5d0d0edda6e54738c Mon Sep 17 00:00:00 2001
From: Timo Sirainen <timo.sirainen@open-xchange.com>
Date: Thu, 27 Oct 2022 11:54:29 +0300
Subject: [PATCH] replicator: Add "replication" category to events

---
 src/replication/replicator/doveadm-connection.c  | 1 +
 src/replication/replicator/dsync-client.c        | 2 ++
 src/replication/replicator/notify-connection.c   | 2 ++
 src/replication/replicator/replicator-queue.c    | 2 ++
 src/replication/replicator/replicator-settings.c | 4 ++++
 src/replication/replicator/replicator-settings.h | 1 +
 6 files changed, 12 insertions(+)

diff --git a/src/replication/replicator/doveadm-connection.c b/src/replication/replicator/doveadm-connection.c
index 143e6e7bfb..7b188a5705 100644
--- a/src/replication/replicator/doveadm-connection.c
+++ b/src/replication/replicator/doveadm-connection.c
@@ -324,6 +324,7 @@ void doveadm_connection_create(struct replicator_brain *brain, int fd)
 	client->brain = brain;
 	connection_init_server(doveadm_connections, &client->conn,
 			       "doveadm-client", fd, fd);
+	event_add_category(client->conn.event, &event_category_replication);
 }
 
 static struct connection_settings doveadm_conn_set = {
diff --git a/src/replication/replicator/dsync-client.c b/src/replication/replicator/dsync-client.c
index 650d642535..a0208e49c0 100644
--- a/src/replication/replicator/dsync-client.c
+++ b/src/replication/replicator/dsync-client.c
@@ -7,6 +7,7 @@
 #include "ostream.h"
 #include "str.h"
 #include "strescape.h"
+#include "replicator-settings.h"
 #include "dsync-client.h"
 
 #include <unistd.h>
@@ -45,6 +46,7 @@ dsync_client_init(const char *path, const char *dsync_params)
 	client->fd = -1;
 	client->dsync_params = i_strdup(dsync_params);
 	client->event = event_create(NULL);
+	event_add_category(client->event, &event_category_replication);
 	event_set_append_log_prefix(client->event, t_strdup_printf(
 		"%s: ", client->path));
 	return client;
diff --git a/src/replication/replicator/notify-connection.c b/src/replication/replicator/notify-connection.c
index c70f1404cc..3b14654f65 100644
--- a/src/replication/replicator/notify-connection.c
+++ b/src/replication/replicator/notify-connection.c
@@ -6,6 +6,7 @@
 #include "ostream.h"
 #include "strescape.h"
 #include "master-service.h"
+#include "replicator-settings.h"
 #include "replicator-queue-private.h"
 #include "notify-connection.h"
 
@@ -153,6 +154,7 @@ notify_connection_create(int fd, struct replicator_queue *queue)
 	conn = i_new(struct notify_connection, 1);
 	conn->refcount = 1;
 	conn->event = event_create(queue->event);
+	event_add_category(conn->event, &event_category_replication);
 	conn->queue = queue;
 	conn->fd = fd;
 	conn->input = i_stream_create_fd(fd, MAX_INBUF_SIZE);
diff --git a/src/replication/replicator/replicator-queue.c b/src/replication/replicator/replicator-queue.c
index 0a60202075..9465dad97a 100644
--- a/src/replication/replicator/replicator-queue.c
+++ b/src/replication/replicator/replicator-queue.c
@@ -9,6 +9,7 @@
 #include "strescape.h"
 #include "hash.h"
 #include "replicator-queue-private.h"
+#include "replicator-settings.h"
 
 #include <unistd.h>
 #include <fcntl.h>
@@ -109,6 +110,7 @@ replicator_queue_init(unsigned int full_sync_interval,
 			  str_hash, strcmp);
 	i_array_init(&queue->sync_lookups, 32);
 	queue->event = event_create(NULL);
+	event_add_category(queue->event, &event_category_replication);
 	return queue;
 }
 
diff --git a/src/replication/replicator/replicator-settings.c b/src/replication/replicator/replicator-settings.c
index 3965100d6b..beab0a359b 100644
--- a/src/replication/replicator/replicator-settings.c
+++ b/src/replication/replicator/replicator-settings.c
@@ -6,6 +6,10 @@
 #include "service-settings.h"
 #include "replicator-settings.h"
 
+struct event_category event_category_replication = {
+	.name = "replication"
+};
+
 /* <settings checks> */
 static struct file_listener_settings replicator_unix_listeners_array[] = {
 	{ "replicator", 0600, "$default_internal_user", "" },
diff --git a/src/replication/replicator/replicator-settings.h b/src/replication/replicator/replicator-settings.h
index 947bcf8e31..5e0f6569cb 100644
--- a/src/replication/replicator/replicator-settings.h
+++ b/src/replication/replicator/replicator-settings.h
@@ -12,5 +12,6 @@ struct replicator_settings {
 
 extern const struct setting_parser_info replicator_setting_parser_info;
 extern const struct replicator_settings *replicator_settings;
+extern struct event_category event_category_replication;
 
 #endif
-- 
2.47.3