} 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;
}
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);
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");
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"
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"
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"
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"
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);
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,
/* 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",