From: Timo Sirainen Date: Sun, 5 Nov 2017 20:37:27 +0000 (+0200) Subject: director: Deduplicate code into director_connection_set_connected() X-Git-Tag: 2.2.34~239 X-Git-Url: http://git.ipfire.org/?a=commitdiff_plain;h=46f33a010ce498b9d2da21b857032cac598a66fb;p=thirdparty%2Fdovecot%2Fcore.git director: Deduplicate code into director_connection_set_connected() --- diff --git a/src/director/director-connection.c b/src/director/director-connection.c index 72087cfae8..fac54d4b09 100644 --- 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);