}
/* If we received an error in add_channel, we need to report it. */
- if (ret != 0) {
+ if (ret < 0) {
ret = consumer_send_status_msg(sock, ret);
if (ret < 0) {
goto error_fatal;
}
}
+ if (msg.u.stream.no_monitor) {
+ DBG("Kernel consumer add stream %s in no monitor mode with"
+ "relayd id %" PRIu64, new_stream->name,
+ new_stream->relayd_stream_id);
+ break;
+ }
+
/* Get the right pipe where the stream will be sent. */
if (new_stream->metadata_flag) {
stream_pipe = ctx->consumer_metadata_pipe;
*/
break;
}
+ case LTTNG_CONSUMER_SNAPSHOT_CHANNEL:
+ {
+ ret = consumer_send_status_msg(sock, ret_code);
+ if (ret < 0) {
+ /* Somehow, the session daemon is not responding anymore. */
+ goto end_nosignal;
+ }
+ break;
+ }
default:
goto end_nosignal;
}