lib-http: Fixed checking if istream or ostream needs waiting.

diff --git a/src/lib-http/http-client-request.c b/src/lib-http/http-client-request.c
index dda7ea46303a1b948b56b44b06cd71b534321bd1..e18ba10cb8c19850b806e8ef1ca9676eb26e17b0 100644 (file)
--- a/src/lib-http/http-client-request.c
+++ b/src/lib-http/http-client-request.c
@@ -856,7 +856,7 @@ int http_client_request_send_more(struct http_client_request *req,
                        /* finished sending payload */
                        http_client_request_finish_payload_out(req);
                }
-       } else if (i_stream_get_data_size(req->payload_input) > 0) {
+       } else if (i_stream_have_bytes_left(req->payload_input)) {
                /* output is blocking (server needs to act; enable timeout) */
                conn->output_locked = TRUE;
                if (!pipelined)

diff --git a/src/lib-http/http-server-response.c b/src/lib-http/http-server-response.c
index 56920ed1ce7ce588c2fc8bafd869cb6420939911..d9ffe98e5373aecf8d96064545125be46dab737d 100644 (file)
--- a/src/lib-http/http-server-response.c
+++ b/src/lib-http/http-server-response.c
@@ -526,7 +526,7 @@ int http_server_response_send_more(struct http_server_response *resp,
                }
                /* finished sending payload */
                http_server_response_finish_payload_out(resp);
-       } else if (i_stream_get_data_size(resp->payload_input) > 0) {
+       } else if (i_stream_have_bytes_left(resp->payload_input)) {
                /* output is blocking */
                conn->output_locked = TRUE;
                o_stream_set_flush_pending(output, TRUE);