diff --git a/include/haproxy/sink-t.h b/include/haproxy/sink-t.h index 399d87a4b..a0de3d15a 100644 --- a/include/haproxy/sink-t.h +++ b/include/haproxy/sink-t.h @@ -40,6 +40,7 @@ struct sink_forward_target { struct server *srv; // used server struct appctx *appctx; // appctx of current session size_t ofs; // ring buffer reader offset + struct sink *sink; // the associated sink struct sink_forward_target *next; __decl_thread(HA_SPINLOCK_T lock); // lock to protect current struct }; diff --git a/src/sink.c b/src/sink.c index 59391859e..681f363f8 100644 --- a/src/sink.c +++ b/src/sink.c @@ -1005,6 +1005,7 @@ struct sink *sink_new_from_logsrv(struct logsrv *logsrv) /* insert into sink_forward_targets * list into sink */ + sft->sink = sink; sft->next = sink->sft; sink->sft = sft;