]> git.ipfire.org Git - thirdparty/dovecot/core.git/commitdiff
lib: Reformat connection.c.
authorStephan Bosch <stephan.bosch@dovecot.fi>
Thu, 28 Feb 2019 09:12:43 +0000 (10:12 +0100)
committerVille Savolainen <ville.savolainen@dovecot.fi>
Fri, 28 Jun 2019 07:09:33 +0000 (10:09 +0300)
src/lib/connection.c

index 9de2ce313c30de922189a8731d906b37f05f4bf2..f4ab3cfbb9c5918601f217b7a28c8ec2768237d7 100644 (file)
@@ -50,7 +50,8 @@ void connection_input_default(struct connection *conn)
        if (!conn->handshake_received &&
            conn->v.handshake != NULL) {
                if ((ret = conn->v.handshake(conn)) < 0) {
-                       connection_closed(conn, CONNECTION_DISCONNECT_HANDSHAKE_FAILED);
+                       connection_closed(
+                               conn, CONNECTION_DISCONNECT_HANDSHAKE_FAILED);
                        return;
                } else if (ret == 0) {
                        return;
@@ -178,8 +179,10 @@ int connection_input_line_default(struct connection *conn, const char *line)
                        ret = 1; /* continue reading */
                else if (ret > 0)
                        connection_handshake_ready(conn);
-               else
-                       conn->disconnect_reason = CONNECTION_DISCONNECT_HANDSHAKE_FAILED;
+               else {
+                       conn->disconnect_reason =
+                               CONNECTION_DISCONNECT_HANDSHAKE_FAILED;
+               }
                return ret;
        } else if (!conn->handshake_received) {
                /* we don't do handshakes */
@@ -282,12 +285,16 @@ static void connection_client_connected(struct connection *conn, bool success)
        i_assert(conn->list->set.client);
 
        conn->connect_finished = ioloop_timeval;
-       event_add_timeval(conn->event, "connect_finished_time", &ioloop_timeval);
+       event_add_timeval(conn->event, "connect_finished_time",
+                         &ioloop_timeval);
 
-       if (success)
-               e_debug(e->event(), "Client connected (fd=%d)", conn->fd_in);
-       else
-               e_debug(e->event(), "Client connection failed (fd=%d)", conn->fd_in);
+       if (success) {
+               e_debug(e->event(), "Client connected (fd=%d)",
+                       conn->fd_in);
+       } else {
+               e_debug(e->event(), "Client connection failed (fd=%d)",
+                       conn->fd_in);
+       }
 
        if (success)
                connection_init_streams(conn);
@@ -309,8 +316,10 @@ void connection_init(struct connection_list *list,
        i_free(conn->name);
 
        if (list->set.input_idle_timeout_secs != 0 &&
-           conn->input_idle_timeout_secs == 0)
-               conn->input_idle_timeout_secs = list->set.input_idle_timeout_secs;
+           conn->input_idle_timeout_secs == 0) {
+               conn->input_idle_timeout_secs =
+                       list->set.input_idle_timeout_secs;
+       }
 
        if (conn->event == NULL)
                conn->event = event_create(conn->event_parent);
@@ -429,12 +438,13 @@ void connection_init_client_unix(struct connection_list *list,
        event_field_clear(conn->event, "client_port");
 
        event_set_append_log_prefix(conn->event,
-                                   t_strdup_printf("(%s): ", basename(conn->name)));
+                                   t_strdup_printf("(%s): ",
+                                                   basename(conn->name)));
 }
 
 void connection_init_from_streams(struct connection_list *list,
-                           struct connection *conn, const char *name,
-                           struct istream *input, struct ostream *output)
+                                 struct connection *conn, const char *name,
+                                 struct istream *input, struct ostream *output)
 {
        i_assert(name != NULL);
 
@@ -491,10 +501,12 @@ int connection_client_connect(struct connection *conn)
        if (conn->port != 0) {
                fd = net_connect_ip(&conn->ip, conn->port,
                        (conn->my_ip.family != 0 ? &conn->my_ip : NULL));
-       } else if (conn->list->set.unix_client_connect_msecs == 0)
+       } else if (conn->list->set.unix_client_connect_msecs == 0) {
                fd = net_connect_unix(conn->name);
-       else
-               fd = net_connect_unix_with_retries(conn->name, conn->list->set.unix_client_connect_msecs);
+       } else {
+               fd = net_connect_unix_with_retries(
+                       conn->name, conn->list->set.unix_client_connect_msecs);
+       }
        if (fd == -1)
                return -1;
        conn->fd_in = conn->fd_out = fd;
@@ -505,7 +517,8 @@ int connection_client_connect(struct connection *conn)
            conn->list->set.delayed_unix_client_connected_callback) {
                conn->io = io_add_to(conn->ioloop, conn->fd_out, IO_WRITE,
                                     connection_socket_connected, conn);
-               e_debug(conn->event, "Waiting for connect (fd=%d) to finish for max %u msecs",
+               e_debug(conn->event,
+                       "Waiting for connect (fd=%d) to finish for max %u msecs",
                        fd, set->client_connect_timeout_msecs);
                if (set->client_connect_timeout_msecs != 0) {
                        conn->to = timeout_add_to(conn->ioloop,
@@ -531,7 +544,8 @@ void connection_disconnect(struct connection *conn)
        if (conn->disconnected)
                return;
        connection_update_counters(conn);
-       /* client connects to a Server, and Server gets connection from Client */
+       /* client connects to a Server, and Server gets connection from Client
+        */
        const char *ename = conn->list->set.client ?
                "server_connection_disconnected" :
                "client_connection_disconnected";
@@ -579,7 +593,8 @@ int connection_input_read(struct connection *conn)
                /* buffer full */
                switch (conn->list->set.input_full_behavior) {
                case CONNECTION_BEHAVIOR_DESTROY:
-                       connection_closed(conn, CONNECTION_DISCONNECT_BUFFER_FULL);
+                       connection_closed(conn,
+                                         CONNECTION_DISCONNECT_BUFFER_FULL);
                        return -1;
                case CONNECTION_BEHAVIOR_ALLOW:
                        return -2;
@@ -627,16 +642,19 @@ const char *connection_disconnect_reason(struct connection *conn)
 const char *connection_input_timeout_reason(struct connection *conn)
 {
        if (conn->last_input_tv.tv_sec != 0) {
-               int diff = timeval_diff_msecs(&ioloop_timeval, &conn->last_input_tv);
+               int diff = timeval_diff_msecs(&ioloop_timeval,
+                                             &conn->last_input_tv);
                return t_strdup_printf("No input for %u.%03u secs",
                                       diff/1000, diff%1000);
        } else if (conn->connect_finished.tv_sec != 0) {
-               int diff = timeval_diff_msecs(&ioloop_timeval, &conn->connect_finished);
+               int diff = timeval_diff_msecs(&ioloop_timeval,
+                                             &conn->connect_finished);
                return t_strdup_printf(
                        "No input since connected %u.%03u secs ago",
                        diff/1000, diff%1000);
        } else {
-               int diff = timeval_diff_msecs(&ioloop_timeval, &conn->connect_started);
+               int diff = timeval_diff_msecs(&ioloop_timeval,
+                                             &conn->connect_started);
                return t_strdup_printf("connect() timed out after %u.%03u secs",
                                       diff/1000, diff%1000);
        }