Mercurial > dovecot > core-2.2

comparison src/director/director-connection.c @ 18664:502755a1af5f

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
director: Include useful statistics in process title.
author Timo Sirainen <tss@iki.fi>
date Wed, 13 May 2015 04:11:34 +0300
parents 1c268a7cc74a
children b7aed6290e7e
comparison
equal deleted inserted replaced
18663:1c268a7cc74a 18664:502755a1af5f
1494 1494
1495 static void director_connection_input(struct director_connection *conn) 1495 static void director_connection_input(struct director_connection *conn)
1496 { 1496 {
1497 struct director *dir = conn->dir; 1497 struct director *dir = conn->dir;
1498 char *line; 1498 char *line;
1499 uoff_t prev_offset;
1499 bool ret; 1500 bool ret;
1500 1501
1501 switch (i_stream_read(conn->input)) { 1502 switch (i_stream_read(conn->input)) {
1502 case 0: 1503 case 0:
1503 return; 1504 return;
1522 i_stream_skip(conn->input, i_stream_get_data_size(conn->input)); 1523 i_stream_skip(conn->input, i_stream_get_data_size(conn->input));
1523 return; 1524 return;
1524 } 1525 }
1525 1526
1526 director_sync_freeze(dir); 1527 director_sync_freeze(dir);
1528 prev_offset = conn->input->v_offset;
1527 while ((line = i_stream_next_line(conn->input)) != NULL) { 1529 while ((line = i_stream_next_line(conn->input)) != NULL) {
1530 dir->ring_traffic_input += conn->input->v_offset - prev_offset;
1531 prev_offset = conn->input->v_offset;
1532
1528 T_BEGIN { 1533 T_BEGIN {
1529 ret = director_connection_handle_line(conn, line); 1534 ret = director_connection_handle_line(conn, line);
1530 } T_END; 1535 } T_END;
1531 1536
1532 if (!ret) { 1537 if (!ret) {
1870 else { 1875 else {
1871 i_error("director(%s): Output buffer full, " 1876 i_error("director(%s): Output buffer full, "
1872 "disconnecting", conn->name); 1877 "disconnecting", conn->name);
1873 } 1878 }
1874 o_stream_close(conn->output); 1879 o_stream_close(conn->output);
1880 } else {
1881 conn->dir->ring_traffic_output += len;
1875 } 1882 }
1876 } 1883 }
1877 1884
1878 static void 1885 static void
1879 director_connection_ping_idle_timeout(struct director_connection *conn) 1886 director_connection_ping_idle_timeout(struct director_connection *conn)