ret = lttng_strncpy(consumer->dst.session_root_path,
uri->dst.path,
sizeof(consumer->dst.session_root_path));
+ if (ret) {
+ ret_code = LTTNG_ERR_FATAL;
+ goto error;
+ }
consumer->type = CONSUMER_DST_LOCAL;
break;
}
ret = kernel_metadata_flush_buffer(ksession->metadata_stream_fd);
if (ret < 0) {
ERR("Kernel metadata flush failed");
+ error_occurred = true;
}
}
ret = kernel_flush_buffer(kchan);
if (ret < 0) {
ERR("Kernel flush buffer error");
+ error_occurred = true;
}
}