BUG/MINOR: connection: remove a few synchronous calls to polling updates
There were a few synchronous calls to polling updates in some functions
called from the connection handler. These ones are not needed and should
be replaced by more efficient and more debugable asynchronous calls.
diff --git a/src/connection.c b/src/connection.c
index 4bb497e..519a8f9 100644
--- a/src/connection.c
+++ b/src/connection.c
@@ -284,7 +284,7 @@
if (errno == EINTR)
continue;
if (errno == EAGAIN) {
- conn_sock_poll_recv(conn);
+ __conn_sock_poll_recv(conn);
return 0;
}
goto recv_abort;
@@ -455,7 +455,7 @@
goto fail;
fail:
- conn_sock_stop_both(conn);
+ __conn_sock_stop_both(conn);
conn->flags |= CO_FL_ERROR;
return 0;
}
diff --git a/src/proto_tcp.c b/src/proto_tcp.c
index 5edeeee..7285457 100644
--- a/src/proto_tcp.c
+++ b/src/proto_tcp.c
@@ -520,8 +520,8 @@
*/
if (connect(fd, (struct sockaddr *)&conn->addr.to, get_addr_len(&conn->addr.to)) < 0) {
if (errno == EALREADY || errno == EINPROGRESS) {
- conn_sock_stop_recv(conn);
- conn_sock_poll_send(conn);
+ __conn_sock_stop_recv(conn);
+ __conn_sock_poll_send(conn);
return 0;
}
@@ -544,7 +544,7 @@
*/
conn->flags |= CO_FL_ERROR;
- conn_sock_stop_both(conn);
+ __conn_sock_stop_both(conn);
return 0;
}
diff --git a/src/stream_interface.c b/src/stream_interface.c
index 9679e16..1507dcc 100644
--- a/src/stream_interface.c
+++ b/src/stream_interface.c
@@ -1035,7 +1035,7 @@
}
if ((chn->flags & CF_READ_DONTWAIT) || --read_poll <= 0) {
- conn_data_stop_recv(conn);
+ __conn_data_stop_recv(conn);
break;
}