summaryrefslogtreecommitdiffstats
path: root/src/log/doveadm-connection.c
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-28 09:51:24 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-28 09:51:24 +0000
commitf7548d6d28c313cf80e6f3ef89aed16a19815df1 (patch)
treea3f6f2a3f247293bee59ecd28e8cd8ceb6ca064a /src/log/doveadm-connection.c
parentInitial commit. (diff)
downloaddovecot-f7548d6d28c313cf80e6f3ef89aed16a19815df1.tar.xz
dovecot-f7548d6d28c313cf80e6f3ef89aed16a19815df1.zip
Adding upstream version 1:2.3.19.1+dfsg1.upstream/1%2.3.19.1+dfsg1upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/log/doveadm-connection.c')
-rw-r--r--src/log/doveadm-connection.c86
1 files changed, 86 insertions, 0 deletions
diff --git a/src/log/doveadm-connection.c b/src/log/doveadm-connection.c
new file mode 100644
index 0000000..77872ac
--- /dev/null
+++ b/src/log/doveadm-connection.c
@@ -0,0 +1,86 @@
+/* Copyright (c) 2013-2018 Dovecot authors, see the included COPYING file */
+
+#include "lib.h"
+#include "ostream.h"
+#include "str.h"
+#include "strescape.h"
+#include "master-service.h"
+#include "log-error-buffer.h"
+#include "doveadm-connection.h"
+
+#include <unistd.h>
+
+struct doveadm_connection {
+ struct log_error_buffer *errorbuf;
+
+ int fd;
+ struct ostream *output;
+};
+
+static void doveadm_connection_destroy(struct doveadm_connection **_conn);
+
+static int doveadm_connection_send_errors(struct doveadm_connection *conn)
+{
+ struct log_error_buffer_iter *iter;
+ const struct log_error *error;
+ string_t *str = t_str_new(256);
+ int ret = 0;
+
+ iter = log_error_buffer_iter_init(conn->errorbuf);
+ while ((error = log_error_buffer_iter_next(iter)) != NULL) {
+ str_truncate(str, 0);
+ str_printfa(str, "%s\t%ld\t",
+ failure_log_type_names[error->type],
+ (long)error->timestamp);
+ str_append_tabescaped(str, error->prefix);
+ str_append_c(str, '\t');
+ str_append_tabescaped(str, error->text);
+ str_append_c(str, '\n');
+ if (o_stream_send(conn->output,
+ str_data(str), str_len(str)) < 0) {
+ ret = -1;
+ break;
+ }
+ }
+ log_error_buffer_iter_deinit(&iter);
+ return ret;
+}
+
+static int doveadm_output(struct doveadm_connection *conn)
+{
+ if (o_stream_flush(conn->output) != 0) {
+ /* error / finished */
+ doveadm_connection_destroy(&conn);
+ }
+ return 1;
+}
+
+void doveadm_connection_create(struct log_error_buffer *errorbuf, int fd)
+{
+ struct doveadm_connection *conn;
+
+ conn = i_new(struct doveadm_connection, 1);
+ conn->errorbuf = errorbuf;
+ conn->fd = fd;
+ conn->output = o_stream_create_fd(conn->fd, SIZE_MAX);
+ if (doveadm_connection_send_errors(conn) < 0)
+ doveadm_connection_destroy(&conn);
+ else {
+ o_stream_set_flush_callback(conn->output, doveadm_output, conn);
+ o_stream_set_flush_pending(conn->output, TRUE);
+ }
+}
+
+static void doveadm_connection_destroy(struct doveadm_connection **_conn)
+{
+ struct doveadm_connection *conn = *_conn;
+
+ *_conn = NULL;
+
+ o_stream_destroy(&conn->output);
+ if (close(conn->fd) < 0)
+ i_error("close(doveadm connection) failed: %m");
+ i_free(conn);
+
+ master_service_client_connection_destroyed(master_service);
+}