changeset 22650:e010a312c871

director: Deduplicate code into director_connection_set_connected()
author Timo Sirainen <timo.sirainen@dovecot.fi>
date Sun, 05 Nov 2017 22:37:27 +0200
parents bb7c452e3662
children 61402b07ad0a
files src/director/director-connection.c
diffstat 1 files changed, 8 insertions(+), 4 deletions(-) [+]
line wrap: on
line diff
--- a/src/director/director-connection.c	Sun Nov 05 22:27:41 2017 +0200
+++ b/src/director/director-connection.c	Sun Nov 05 22:37:27 2017 +0200
@@ -2083,6 +2083,12 @@
 		(long long)time(NULL)));
 }
 
+static void director_connection_set_connected(struct director_connection *conn)
+{
+	conn->connected = TRUE;
+	conn->connected_time = ioloop_timeval;
+}
+
 struct director_connection *
 director_connection_init_in(struct director *dir, int fd,
 			    const struct ip_addr *ip)
@@ -2091,8 +2097,7 @@
 
 	conn = director_connection_init_common(dir, fd);
 	conn->in = TRUE;
-	conn->connected = TRUE;
-	conn->connected_time = ioloop_timeval;
+	director_connection_set_connected(conn);
 	conn->name = i_strdup_printf("%s/in", net_ip2addr(ip));
 	conn->io = io_add(conn->fd, IO_READ, director_connection_input, conn);
 	conn->to_ping = timeout_add(DIRECTOR_CONNECTION_ME_TIMEOUT_MSECS,
@@ -2113,8 +2118,7 @@
 		director_connection_disconnected(&conn, strerror(err));
 		return;
 	}
-	conn->connected_time = ioloop_timeval;
-	conn->connected = TRUE;
+	director_connection_set_connected(conn);
 	o_stream_set_flush_callback(conn->output,
 				    director_connection_output, conn);