MEDIUM: connection: add a flag to hold the transport layer
When we start logging SSL information, we need the SSL struct to be
present even past the conn_xprt_close() call. In order to achieve this,
we should use refcounting on the connection and the transport layer. At
the moment it's not worth using plain refcounting as only the logs require
this, so instead of real refcounting we just use a flag which will be set
by the log subsystem when SSL data need to be logged.
What happens then is that the xprt->close() call is ignored and the
transport layer is closed again during session_free(), after the log
line is emitted.
diff --git a/include/proto/connection.h b/include/proto/connection.h
index ff63e03..52b547c 100644
--- a/include/proto/connection.h
+++ b/include/proto/connection.h
@@ -46,11 +46,13 @@
}
/* Calls the close() function of the transport layer if any, and always unsets
- * the transport layer.
+ * the transport layer. However this is not done if the CO_FL_XPRT_TRACKED flag
+ * is set, which allows logs to take data from the transport layer very late if
+ * needed.
*/
static inline void conn_xprt_close(struct connection *conn)
{
- if (conn->xprt) {
+ if (conn->xprt && !(conn->flags & CO_FL_XPRT_TRACKED)) {
if (conn->xprt->close)
conn->xprt->close(conn);
conn->xprt = NULL;
diff --git a/include/types/connection.h b/include/types/connection.h
index 35ce1f5..5803c2c 100644
--- a/include/types/connection.h
+++ b/include/types/connection.h
@@ -145,6 +145,12 @@
* as DATA or SOCK on some implementations.
*/
CO_FL_POLL_SOCK = CO_FL_HANDSHAKE | CO_FL_WAIT_L4_CONN | CO_FL_WAIT_L6_CONN,
+
+ /* This last flag indicates that the transport layer is used (for instance
+ * by logs) and must not be cleared yet. The last call to conn_xprt_close()
+ * must be done after clearing this flag.
+ */
+ CO_FL_XPRT_TRACKED = 0x80000000,
};
/* target types */
diff --git a/src/session.c b/src/session.c
index ba074c8..7c218bf 100644
--- a/src/session.c
+++ b/src/session.c
@@ -548,6 +548,10 @@
http_end_txn(s);
+ /* ensure the client-side transport layer is destroyed */
+ s->si[0].conn.flags &= ~CO_FL_XPRT_TRACKED;
+ conn_xprt_close(&s->si[0].conn);
+
for (i = 0; i < s->store_count; i++) {
if (!s->store[i].ts)
continue;