doveadm_settings->doveadm_port);
net_set_nonblock(conn->fd, TRUE);
conn->input = i_stream_create_fd(conn->fd, MAX_INBUF_SIZE);
- conn->io = io_add_istream(conn->input, server_connection_input, conn);
conn->output = o_stream_create_fd(conn->fd, (size_t)-1);
o_stream_set_flush_callback(conn->output, server_connection_output, conn);
o_stream_set_no_error_handling(conn->output, TRUE);
server_connection_destroy(&conn);
return -1;
}
+ conn->io = io_add_istream(conn->input, server_connection_input, conn);
conn->state = SERVER_REPLY_STATE_DONE;
o_stream_nsend_str(conn->output, DOVEADM_SERVER_PROTOCOL_VERSION_LINE"\n");