+ if (ret < 0) {
+ consumer_del_stream(new_stream, NULL);
+ goto end_nosignal;
+ }
+ }
+
+ /* Send stream to the metadata thread */
+ if (new_stream->metadata_flag) {
+ do {
+ ret = write(ctx->consumer_metadata_pipe[1], &new_stream,
+ sizeof(new_stream));
+ } while (ret < 0 && errno == EINTR);
+ if (ret < 0) {
+ PERROR("write metadata pipe");
+ consumer_del_metadata_stream(new_stream, NULL);