X-Git-Url: http://git.lttng.org./?a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fsession.c;h=e7a99080727e5be1552462d2640da335e9b0fd24;hb=fcf4d551b695cfdb6fe26d21f0509d08ef89b312;hp=f47b24f8fda696c4f50c2a02dd80209d581f5a44;hpb=9a78c92e24e1f689a7fb0229516c6b1761615077;p=lttng-tools.git diff --git a/src/bin/lttng-relayd/session.c b/src/bin/lttng-relayd/session.c index f47b24f8f..e7a990807 100644 --- a/src/bin/lttng-relayd/session.c +++ b/src/bin/lttng-relayd/session.c @@ -211,7 +211,8 @@ unlock: } cds_list_for_each_entry_rcu(stream, &session->recv_list, recv_node) { - stream_close(stream); + /* Close streams which have not been published yet. */ + try_stream_close(stream); } rcu_unlock: rcu_read_unlock();