const bool acquired_reference = lttng_trace_chunk_get(
trace_chunk);
- assert(acquired_reference);
+ LTTNG_ASSERT(acquired_reference);
}
vstream->stream_file.trace_chunk = trace_chunk;
*/
if (stream->index_file == NULL) {
vstream->index_file = NULL;
- } else {
+ } else if (vstream->stream_file.trace_chunk) {
const uint32_t connection_major = stream->trace->session->major;
const uint32_t connection_minor = stream->trace->session->minor;
enum lttng_trace_chunk_status chunk_status;
* If we never received a data file for the current stream, delay the
* opening, otherwise open it right now.
*/
- if (stream->file) {
+ if (stream->file && vstream->stream_file.trace_chunk) {
int ret;
char file_path[LTTNG_PATH_MAX];
enum lttng_trace_chunk_status status;
iter.iter.node = &vstream->stream_n.node;
ret = lttng_ht_del(viewer_streams_ht, &iter);
- assert(!ret);
+ LTTNG_ASSERT(!ret);
}
static void viewer_stream_release(struct urcu_ref *ref)
* has been data written at some point, which will have set the
* tail.
*/
- assert(seq_tail != -1ULL);
+ LTTNG_ASSERT(seq_tail != -1ULL);
/*
* We need to resync because we lag behind tail.
*/