#include <babeltrace/compat/send.h>
#include <babeltrace/compat/string.h>
#include <babeltrace/compat/mman.h>
+#include <babeltrace/babeltrace-internal.h>
#include "lttng-live.h"
#include "lttng-viewer-abi.h"
#define ACTIVE_POLL_DELAY 100 /* ms */
-/*
- * Memory allocation zeroed
- */
-#define zmalloc(x) calloc(1, x)
-
-#ifndef max_t
-#define max_t(type, a, b) \
- ((type) (a) > (type) (b) ? (type) (a) : (type) (b))
-#endif
-
static void ctf_live_packet_seek(struct bt_stream_pos *stream_pos,
size_t index, int whence);
static int add_traces(struct lttng_live_ctx *ctx);
int ret = 0;
stream->metadata_fp_write =
- babeltrace_open_memstream(metadata_buf, size);
+ bt_open_memstream(metadata_buf, size);
if (!stream->metadata_fp_write) {
perror("Metadata open_memstream");
ret = -1;
metadata = viewer_stream->ctf_trace->metadata_stream;
metadata->ctf_trace->metadata_fp =
- babeltrace_fmemopen(metadata_buf,
+ bt_fmemopen(metadata_buf,
metadata->metadata_len, "rb");
if (!metadata->ctf_trace->metadata_fp) {
perror("Metadata fmemopen");
}
} while (ret > 0 || !len_read);
- if (babeltrace_close_memstream(metadata_buf, &size,
+ if (bt_close_memstream(metadata_buf, &size,
metadata_stream->metadata_fp_write)) {
- perror("babeltrace_close_memstream");
+ perror("bt_close_memstream");
}
metadata_stream->metadata_fp_write = NULL;
goto end_free;
}
- trace->metadata_fp = babeltrace_fmemopen(metadata_buf,
+ trace->metadata_fp = bt_fmemopen(metadata_buf,
stream->metadata_len, "rb");
if (!trace->metadata_fp) {
perror("Metadata fmemopen");