X-Git-Url: http://git.lttng.org/?p=lttngtop.git;a=blobdiff_plain;f=src%2Fnetwork-live.c;h=46a5b4d2d0c317cd80de5be78c527b24c7871452;hp=1fb761ef828878ef9279343b7b214ee9a6bef42d;hb=38e240608abcec56b7bee5a076e3992c835de834;hpb=d2f1452b66e796412c4b0c1c73608b156659a650 diff --git a/src/network-live.c b/src/network-live.c index 1fb761e..46a5b4d 100644 --- a/src/network-live.c +++ b/src/network-live.c @@ -35,7 +35,7 @@ #include #include "lttng-viewer.h" -#include "lttng-index.h" +#include "ctf-index.h" #include "network-live.h" #include @@ -220,27 +220,6 @@ error: return ret; } -int write_index_header(int fd) -{ - struct lttng_packet_index_file_hdr hdr; - int ret; - - memcpy(hdr.magic, INDEX_MAGIC, sizeof(hdr.magic)); - hdr.index_major = htobe32(INDEX_MAJOR); - hdr.index_minor = htobe32(INDEX_MINOR); - - do { - ret = write(fd, &hdr, sizeof(hdr)); - } while (ret < 0 && errno == EINTR); - if (ret < 0) { - perror("write index header"); - goto error; - } - -error: - return ret; -} - static int attach_session(int id, int begin) { @@ -675,6 +654,11 @@ void ctf_live_packet_seek(struct bt_stream_pos *stream_pos, size_t index, pos->content_size = packet_index.content_size; pos->mmap_base_offset = 0; pos->offset = 0; + if (packet_index.offset == EOF) { + pos->offset = EOF; + } else { + pos->offset = 0; + } file_stream->parent.cycles_timestamp = packet_index.timestamp_end; file_stream->parent.real_timestamp = ctf_get_real_timestamp(