MEDIUM: connection: inform si_alloc_conn() whether existing conn is OK or not
When allocating a new connection, only the caller knows whether it's
acceptable to reuse the previous one or not. Let's pass this information
to si_alloc_conn() which will do the cleanup if the connection is not
acceptable.
diff --git a/include/proto/connection.h b/include/proto/connection.h
index be9d712..e172cfe 100644
--- a/include/proto/connection.h
+++ b/include/proto/connection.h
@@ -126,7 +126,8 @@
}
/* Force to close the connection whatever the tracking state. This is mainly
- * used on the error path where the tracking does not make sense.
+ * used on the error path where the tracking does not make sense, or to kill
+ * an idle connection we want to abort immediately.
*/
static inline void conn_force_close(struct connection *conn)
{
diff --git a/include/proto/stream_interface.h b/include/proto/stream_interface.h
index 5408f1e..588b83e 100644
--- a/include/proto/stream_interface.h
+++ b/include/proto/stream_interface.h
@@ -212,11 +212,15 @@
applet->release(si);
}
+/* Try to allocate a new connection and assign it to the interface. If
+ * a connection was previously allocated and the <reuse> flag is set,
+ * it is returned unmodified. Otherwise it is reset.
+ */
/* Returns the stream interface's existing connection if one such already
* exists, or tries to allocate and initialize a new one which is then
* assigned to the stream interface.
*/
-static inline struct connection *si_alloc_conn(struct stream_interface *si)
+static inline struct connection *si_alloc_conn(struct stream_interface *si, int reuse)
{
struct connection *conn;
@@ -225,8 +229,13 @@
*/
if (si->end) {
conn = objt_conn(si->end);
- if (conn)
+ if (conn) {
+ if (!reuse) {
+ conn_force_close(conn);
+ conn_init(conn);
+ }
return conn;
+ }
/* it was an applet then */
si_release_endpoint(si);
}