# HG changeset patch
# User Timo Sirainen <timo.sirainen@dovecot.fi>
# Date 1518079977 -7200
# Node ID bed6a1eb53f79088c7ce8572462d16643c5c844a
# Parent  08535865104c3284d0887e1ca0494cd312cf8d20
lib: Add connection_streams_changed()

Originally by Stephan Bosch

diff -r 08535865104c -r bed6a1eb53f7 src/lib/connection.c
--- a/src/lib/connection.c	Thu Feb 08 02:38:23 2018 +0200
+++ b/src/lib/connection.c	Thu Feb 08 10:52:57 2018 +0200
@@ -164,6 +164,16 @@
 	}
 }
 
+void connection_streams_changed(struct connection *conn)
+{
+	const struct connection_settings *set = &conn->list->set;
+
+	if (set->input_max_size != 0 && conn->io != NULL) {
+		io_remove(&conn->io);
+		conn->io = io_add_istream(conn->input, *conn->list->v.input, conn);
+	}
+}
+
 static void connection_client_connected(struct connection *conn, bool success)
 {
 	i_assert(conn->list->set.client);
diff -r 08535865104c -r bed6a1eb53f7 src/lib/connection.h
--- a/src/lib/connection.h	Thu Feb 08 02:38:23 2018 +0200
+++ b/src/lib/connection.h	Thu Feb 08 10:52:57 2018 +0200
@@ -127,6 +127,8 @@
 void connection_disconnect(struct connection *conn);
 void connection_deinit(struct connection *conn);
 
+void connection_streams_changed(struct connection *conn);
+
 /* Returns -1 = disconnected, 0 = nothing new, 1 = something new.
    If input_full_behavior is ALLOW, may return also -2 = buffer full. */
 int connection_input_read(struct connection *conn);