#ifndef _CONSUMER_H
#define _CONSUMER_H
+#include <algorithm>
#include <common/consumer/consumer.hpp>
#include <common/hashtable/hashtable.hpp>
#include <lttng/lttng.h>
+#include <lttng/trace-format-descriptor-internal.hpp>
#include <urcu/ref.h>
-#include <algorithm>
#include "snapshot.hpp"
const char *root_shm_path,
const char *shm_path,
struct lttng_trace_chunk *trace_chunk,
- const struct lttng_credentials *buffer_credentials);
+ const struct lttng_credentials *buffer_credentials,
+ const lttng::trace_format_descriptor& trace_format);
void consumer_init_add_stream_comm_msg(struct lttcomm_consumer_msg *msg,
uint64_t channel_key,
uint64_t stream_key,
unsigned int live_timer_interval,
bool is_in_live_session,
unsigned int monitor_timer_interval,
- struct lttng_trace_chunk *trace_chunk);
+ struct lttng_trace_chunk *trace_chunk,
+ const lttng::trace_format_descriptor& trace_format);
int consumer_is_data_pending(uint64_t session_id,
struct consumer_output *consumer);
int consumer_close_metadata(struct consumer_socket *socket,