director: Deduplicate code into director_connection_set_connected()

diff --git a/src/director/director-connection.c b/src/director/director-connection.c
index 72087cfae883bad9e7aa8aa89a45e0eb739f837b..fac54d4b092e3661ebf0de976d1d1710e0e0f25c 100644 (file)
--- a/src/director/director-connection.c
+++ b/src/director/director-connection.c
@@ -2083,6 +2083,12 @@ static void director_connection_send_handshake(struct director_connection *conn)
                (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 @@ director_connection_init_in(struct director *dir, int fd,
 
        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 @@ static void director_connection_connected(struct director_connection *conn)
                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);