From 89e6077152bb8020e8b4953521078bfefa33daf2 Mon Sep 17 00:00:00 2001 From: Stephan Bosch Date: Mon, 11 Nov 2019 18:55:37 +0100 Subject: [PATCH] lib-http: http-server-connection - Add http_server_connection_input_set_pending(). --- src/lib-http/http-server-connection.c | 8 +++++++- src/lib-http/http-server-private.h | 2 ++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/src/lib-http/http-server-connection.c b/src/lib-http/http-server-connection.c index f6ee6c4a83..94ac988934 100644 --- a/src/lib-http/http-server-connection.c +++ b/src/lib-http/http-server-connection.c @@ -68,6 +68,12 @@ http_server_connection_get_stats(struct http_server_connection *conn) return &conn->stats; } +void http_server_connection_input_set_pending( + struct http_server_connection *conn) +{ + i_stream_set_input_pending(conn->conn.input, TRUE); +} + void http_server_connection_input_halt(struct http_server_connection *conn) { connection_input_halt(&conn->conn); @@ -980,7 +986,7 @@ int http_server_connection_output(struct http_server_connection *conn) if (!http_server_connection_pipeline_is_full(conn)) { http_server_connection_input_resume(conn); if (pipeline_was_full && conn->conn.io != NULL) - i_stream_set_input_pending(conn->conn.input, TRUE); + http_server_connection_input_set_pending(conn); } return 1; diff --git a/src/lib-http/http-server-private.h b/src/lib-http/http-server-private.h index f0de94ca38..de9b6291d2 100644 --- a/src/lib-http/http-server-private.h +++ b/src/lib-http/http-server-private.h @@ -277,6 +277,8 @@ struct connection_list *http_server_connection_list_init(void); bool http_server_connection_shut_down(struct http_server_connection *conn); +void http_server_connection_input_set_pending( + struct http_server_connection *conn); void http_server_connection_input_halt(struct http_server_connection *conn); void http_server_connection_input_resume(struct http_server_connection *conn); -- 2.47.3