X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fstream.c;h=3c61e3532e1fd2b810b278f9cb9c5c98391444af;hp=06e82b29198a082476c34b5d215cc3a083ad14bf;hb=927617721d01b4a676356787f7792799e3c84223;hpb=4147107d9646011a1cdb7166a9810065927af99c diff --git a/src/bin/lttng-relayd/stream.c b/src/bin/lttng-relayd/stream.c index 06e82b291..3c61e3532 100644 --- a/src/bin/lttng-relayd/stream.c +++ b/src/bin/lttng-relayd/stream.c @@ -1052,6 +1052,7 @@ int stream_update_index(struct relay_stream *stream, uint64_t net_seq_num, uint64_t data_offset; struct relay_index *index; + assert(stream->trace_chunk); ASSERT_LOCKED(stream->lock); /* Get data offset because we are about to update the index. */ data_offset = htobe64(stream->tracefile_size_current); @@ -1133,9 +1134,7 @@ int stream_complete_packet(struct relay_stream *stream, size_t packet_total_size stream->prev_data_seq = sequence_number; ret = try_rotate_stream_data(stream); - if (ret < 0) { - goto end; - } + end: return ret; }