X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=formats%2Flttng-live%2Flttng-live-comm.c;h=e3cab91457fbf8ee2b6316a9bc4b31ad6143c7e6;hb=2a6d197b310aef3510ed3173236ce266381e96ee;hp=fee43c2bed51a8c647d8138f696117df5361fb42;hpb=8ace20bfc87729d45edc4e1a2aa6bec330580d91;p=babeltrace.git diff --git a/formats/lttng-live/lttng-live-comm.c b/formats/lttng-live/lttng-live-comm.c index fee43c2b..e3cab914 100644 --- a/formats/lttng-live/lttng-live-comm.c +++ b/formats/lttng-live/lttng-live-comm.c @@ -631,8 +631,7 @@ retry: memset(&rq, 0, sizeof(rq)); rq.stream_id = htobe64(stream->id); - /* Already in big endian. */ - rq.offset = offset; + rq.offset = htobe64(offset); rq.len = htobe32(len); ret_len = lttng_live_send(ctx->control_sock, &cmd, sizeof(cmd)); @@ -706,8 +705,8 @@ retry: goto error; } - if (len <= 0) { - goto end; + if (len == 0) { + goto error; } if (len > stream->mmap_size) { @@ -1110,7 +1109,7 @@ retry: printf_verbose("get_data_packet for stream %" PRIu64 "\n", viewer_stream->id); ret = get_data_packet(session->ctx, pos, viewer_stream, - be64toh(cur_index->offset), + cur_index->offset, cur_index->packet_size / CHAR_BIT); if (ret == -2) { goto retry;