diff --git a/include/proto/connection.h b/include/proto/connection.h index e4f4de90c..c7caeea2b 100644 --- a/include/proto/connection.h +++ b/include/proto/connection.h @@ -179,66 +179,6 @@ static inline void conn_cond_update_polling(struct connection *c) conn_stop_polling(c); } -/***** Event manipulation primitives for use by DATA I/O callbacks *****/ -/* The __conn_* versions do not propagate to lower layers and are only meant - * to be used by handlers called by the connection handler. The other ones - * may be used anywhere. - */ -static inline void __conn_xprt_want_recv(struct connection *c) -{ - if (conn_ctrl_ready(c)) - fd_want_recv(c->handle.fd); -} - -static inline void __conn_xprt_stop_recv(struct connection *c) -{ - if (conn_ctrl_ready(c)) - fd_stop_recv(c->handle.fd); -} - -static inline void __conn_xprt_want_send(struct connection *c) -{ - if (conn_ctrl_ready(c)) - fd_want_send(c->handle.fd); -} - -static inline void __conn_xprt_stop_send(struct connection *c) -{ - if (conn_ctrl_ready(c)) - fd_stop_send(c->handle.fd); -} - -static inline void __conn_xprt_stop_both(struct connection *c) -{ - if (conn_ctrl_ready(c)) - fd_stop_both(c->handle.fd); -} - -static inline void conn_xprt_want_recv(struct connection *c) -{ - __conn_xprt_want_recv(c); -} - -static inline void conn_xprt_stop_recv(struct connection *c) -{ - __conn_xprt_stop_recv(c); -} - -static inline void conn_xprt_want_send(struct connection *c) -{ - __conn_xprt_want_send(c); -} - -static inline void conn_xprt_stop_send(struct connection *c) -{ - __conn_xprt_stop_send(c); -} - -static inline void conn_xprt_stop_both(struct connection *c) -{ - __conn_xprt_stop_both(c); -} - /* read shutdown, called from the rcv_buf/rcv_pipe handlers when * detecting an end of connection. */ diff --git a/src/connection.c b/src/connection.c index c58db5874..06f2b7bc2 100644 --- a/src/connection.c +++ b/src/connection.c @@ -245,7 +245,7 @@ int conn_fd_check(struct connection *conn) */ fdtab[fd].linger_risk = 0; conn->flags |= CO_FL_ERROR | CO_FL_SOCK_RD_SH | CO_FL_SOCK_WR_SH; - __conn_xprt_stop_both(conn); + conn_stop_polling(conn); return 0; wait: