]> git.ipfire.org Git - thirdparty/dovecot/core.git/commitdiff
global: Replace (void)o_stream_send*() with o_stream_nsend*()
authorTimo Sirainen <timo.sirainen@dovecot.fi>
Wed, 23 May 2018 11:38:05 +0000 (14:38 +0300)
committerTimo Sirainen <timo.sirainen@dovecot.fi>
Wed, 4 Jul 2018 18:33:06 +0000 (18:33 +0000)
src/auth/auth-master-connection.c
src/lib-http/http-transfer-chunked.c
src/lib-http/test-http-server-errors.c
src/lib-http/test-http-transfer.c
src/lib-storage/index/dbox-common/dbox-file-fix.c
src/lib-storage/index/mbox/mbox-sync-rewrite.c

index 9a3c9dd63d958a5d3437a4f041ab080b9fb67a61..d8782311133701e408a655f1616034048efe67b3 100644 (file)
@@ -176,7 +176,7 @@ master_input_cache_flush(struct auth_master_connection *conn, const char *args)
        } else {
                count = auth_cache_clear_users(passdb_cache, list+1);
        }
-       (void)o_stream_send_str(conn->output,
+       o_stream_nsend_str(conn->output,
                t_strdup_printf("OK\t%s\t%u\n", list[0], count));
        return TRUE;
 }
index fa57f52c23cd2a1186d61350ac3e9484734ea917..16e45543ac320cfa1035bd94cfde52d4c3ac6fc6 100644 (file)
@@ -565,7 +565,7 @@ http_transfer_chunked_ostream_close(struct iostream_private *stream,
        struct http_transfer_chunked_ostream *tcstream =
                (struct http_transfer_chunked_ostream *)stream;
 
-       (void)o_stream_send(tcstream->ostream.parent, "0\r\n\r\n", 5);
+       o_stream_nsend(tcstream->ostream.parent, "0\r\n\r\n", 5);
        (void)o_stream_flush(&tcstream->ostream.ostream);
        if (close_parent)
                o_stream_close(tcstream->ostream.parent);
index 0771a0a8c565f82841876292c5dc34090ee6708f..b184c72d1402b5230decc54b95c01db697f46d6f 100644 (file)
@@ -94,7 +94,7 @@ test_slow_request_input(struct client_connection *conn ATTR_UNUSED)
 static void
 test_slow_request_connected(struct client_connection *conn)
 {
-       (void)o_stream_send_str(conn->conn.output,
+       o_stream_nsend_str(conn->conn.output,
                "GET / HTTP/1.1\r\n"
                "Host: example.com\r\n"
                "\r\n");
@@ -194,7 +194,7 @@ static void test_slow_request(void)
 static void
 test_hanging_request_payload_connected(struct client_connection *conn)
 {
-       (void)o_stream_send_str(conn->conn.output,
+       o_stream_nsend_str(conn->conn.output,
                "GET / HTTP/1.1\r\n"
                "Host: example.com\r\n"
                "Content-Length: 1000\r\n"
@@ -329,7 +329,7 @@ static void test_hanging_request_payload(void)
 static void
 test_hanging_response_payload_connected(struct client_connection *conn)
 {
-       (void)o_stream_send_str(conn->conn.output,
+       o_stream_nsend_str(conn->conn.output,
                "GET / HTTP/1.1\r\n"
                "Host: example.com\r\n"
                "Content-Length: 18\r\n"
@@ -432,7 +432,7 @@ static void test_hanging_response_payload(void)
 static void
 test_excessive_payload_length_connected1(struct client_connection *conn)
 {
-       (void)o_stream_send_str(conn->conn.output,
+       o_stream_nsend_str(conn->conn.output,
                "GET / HTTP/1.1\r\n"
                "Host: example.com\r\n"
                "Content-Length: 150\r\n"
@@ -452,7 +452,7 @@ test_client_excessive_payload_length1(unsigned int index)
 static void
 test_excessive_payload_length_connected2(struct client_connection *conn)
 {
-       (void)o_stream_send_str(conn->conn.output,
+       o_stream_nsend_str(conn->conn.output,
                "GET / HTTP/1.1\r\n"
                "Host: example.com\r\n"
                "Transfer-Encoding: chunked\r\n"
index 6cb3485de19db243afa329b9046cec253199b2b5..88c428bda50a980791b7ff7c6e747fb2ad430b41 100644 (file)
@@ -200,7 +200,7 @@ static void test_http_transfer_chunked_input_invalid(void)
 
                buffer_set_used_size(payload_buffer, 0);
                output = o_stream_create_buffer(payload_buffer);
-               (void)o_stream_send_istream(output, chunked);
+               o_stream_nsend_istream(output, chunked);
                test_out("payload read failure", chunked->stream_errno != 0);
                i_stream_unref(&chunked);
                o_stream_destroy(&output);
index 1178387679ff44fd50245b3a809c106a836069e7..af96dd165634c51e09a5770dac0cd1fecd8d1324 100644 (file)
@@ -236,7 +236,7 @@ stream_copy(struct dbox_file *file, struct ostream *output,
        int ret = 0;
 
        input = i_stream_create_limit(file->input, count);
-       (void)o_stream_send_istream(output, input);
+       o_stream_nsend_istream(output, input);
 
        if (input->stream_errno != 0) {
                mail_storage_set_critical(&file->storage->storage,
index 37aaf2c3f4ee90545a4d514f9f6942375add841c..cc3496006494e4330e18b13a7353313f15d45d74 100644 (file)
@@ -40,7 +40,7 @@ int mbox_move(struct mbox_sync_context *sync_ctx,
        /* we're moving data within a file. it really shouldn't be failing at
           this point or we're corrupted. */
        input = i_stream_create_limit(sync_ctx->file_input, size);
-       (void)o_stream_send_istream(output, input);
+       o_stream_nsend_istream(output, input);
        if (input->stream_errno != 0) {
                mailbox_set_critical(&mbox->box,
                        "read() failed with mbox: %s",