ret = 0;
+ cds_list_del(&metadata_stream->send_node);
+ consumer_stream_destroy(metadata_stream, NULL);
+ metadata_channel->metadata_stream = NULL;
error:
rcu_read_unlock();
return ret;
break;
}
- ret = consumer_send_relayd_stream(new_stream, NULL);
- if (ret < 0) {
- consumer_stream_free(new_stream);
- goto end_nosignal;
+ /* Send stream to relayd if the stream has an ID. */
+ if (new_stream->net_seq_idx != (uint64_t) -1ULL) {
+ ret = consumer_send_relayd_stream(new_stream, NULL);
+ if (ret < 0) {
+ consumer_stream_free(new_stream);
+ goto end_nosignal;
+ }
}
/* Get the right pipe where the stream will be sent. */