lib-http: http-server-connection - Add http_server_connection_input_set_pending().

diff --git a/src/lib-http/http-server-connection.c b/src/lib-http/http-server-connection.c
index f6ee6c4a8370cb8eb2936fb4cccea1dbcdc0a2b7..94ac988934fbd7510a98a3ee0fae65ff677b403b 100644 (file)
--- 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 f0de94ca38ef5fe64b6c741d392e4e102ddf4305..de9b6291d28ff0b7a5e30c7d244662beb07ecbcf 100644 (file)
--- 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);