[babeltrace.git] / src / ctf-writer / stream.h

/*
 * SPDX-License-Identifier: MIT
 *
 * Copyright 2013, 2014 Jérémie Galarneau <jeremie.galarneau@efficios.com>
 *
 * The Common Trace Format (CTF) Specification is available at
 * http://www.efficios.com/ctf
 */

#ifndef BABELTRACE_CTF_WRITER_STREAM_INTERNAL_H
#define BABELTRACE_CTF_WRITER_STREAM_INTERNAL_H

#include "common/assert.h"
#include "common/macros.h"
#include <babeltrace2-ctf-writer/stream.h>
#include "ctfser/ctfser.h"
#include <stdint.h>

#include "assert-pre.h"
#include "object.h"
#include "stream.h"
#include "utils.h"

struct bt_ctf_stream_common;

struct bt_ctf_stream_common {
	struct bt_ctf_object base;
	int64_t id;
	struct bt_ctf_stream_class_common *stream_class;
	GString *name;
};

int bt_ctf_stream_common_initialize(
		struct bt_ctf_stream_common *stream,
		struct bt_ctf_stream_class_common *stream_class, const char *name,
		uint64_t id, bt_ctf_object_release_func release_func);

void bt_ctf_stream_common_finalize(struct bt_ctf_stream_common *stream);

static inline
struct bt_ctf_stream_class_common *bt_ctf_stream_common_borrow_class(
		struct bt_ctf_stream_common *stream)
{
	BT_ASSERT_DBG(stream);
	return stream->stream_class;
}

static inline
const char *bt_ctf_stream_common_get_name(struct bt_ctf_stream_common *stream)
{
	BT_CTF_ASSERT_PRE_NON_NULL(stream, "Stream");
	return stream->name ? stream->name->str : NULL;
}

static inline
int64_t bt_ctf_stream_common_get_id(struct bt_ctf_stream_common *stream)
{
	int64_t ret;

	BT_CTF_ASSERT_PRE_NON_NULL(stream, "Stream");
	ret = stream->id;
	if (ret < 0) {
		BT_LOGT("Stream's ID is not set: addr=%p, name=\"%s\"",
			stream, bt_ctf_stream_common_get_name(stream));
	}

	return ret;
}

struct bt_ctf_stream {
	struct bt_ctf_stream_common common;
	struct bt_ctf_field *packet_header;
	struct bt_ctf_field *packet_context;

	/* Array of pointers to bt_ctf_event for the current packet */
	GPtrArray *events;
	struct bt_ctfser ctfser;
	unsigned int flushed_packet_count;
	uint64_t discarded_events;
	uint64_t last_ts_end;
};

struct bt_ctf_stream *bt_ctf_stream_create_with_id(
		struct bt_ctf_stream_class *stream_class,
		const char *name, uint64_t id);

#endif /* BABELTRACE_CTF_WRITER_STREAM_INTERNAL_H */
Commit	Line	Data
	1	/*
	2	* SPDX-License-Identifier: MIT
	3	*
	4	* Copyright 2013, 2014 Jérémie Galarneau <jeremie.galarneau@efficios.com>
	5	*
	6	* The Common Trace Format (CTF) Specification is available at
	7	* http://www.efficios.com/ctf
	8	*/
	9
	10	#ifndef BABELTRACE_CTF_WRITER_STREAM_INTERNAL_H
	11	#define BABELTRACE_CTF_WRITER_STREAM_INTERNAL_H
	12
	13	#include "common/assert.h"
	14	#include "common/macros.h"
	15	#include <babeltrace2-ctf-writer/stream.h>
	16	#include "ctfser/ctfser.h"
	17	#include <stdint.h>
	18
	19	#include "assert-pre.h"
	20	#include "object.h"
	21	#include "stream.h"
	22	#include "utils.h"
	23
	24	struct bt_ctf_stream_common;
	25
	26	struct bt_ctf_stream_common {
	27	struct bt_ctf_object base;
	28	int64_t id;
	29	struct bt_ctf_stream_class_common *stream_class;
	30	GString *name;
	31	};
	32
	33	int bt_ctf_stream_common_initialize(
	34	struct bt_ctf_stream_common *stream,
	35	struct bt_ctf_stream_class_common stream_class, const char name,
	36	uint64_t id, bt_ctf_object_release_func release_func);
	37
	38	void bt_ctf_stream_common_finalize(struct bt_ctf_stream_common *stream);
	39
	40	static inline
	41	struct bt_ctf_stream_class_common *bt_ctf_stream_common_borrow_class(
	42	struct bt_ctf_stream_common *stream)
	43	{
	44	BT_ASSERT_DBG(stream);
	45	return stream->stream_class;
	46	}
	47
	48	static inline
	49	const char bt_ctf_stream_common_get_name(struct bt_ctf_stream_common stream)
	50	{
	51	BT_CTF_ASSERT_PRE_NON_NULL(stream, "Stream");
	52	return stream->name ? stream->name->str : NULL;
	53	}
	54
	55	static inline
	56	int64_t bt_ctf_stream_common_get_id(struct bt_ctf_stream_common *stream)
	57	{
	58	int64_t ret;
	59
	60	BT_CTF_ASSERT_PRE_NON_NULL(stream, "Stream");
	61	ret = stream->id;
	62	if (ret < 0) {
	63	BT_LOGT("Stream's ID is not set: addr=%p, name=\"%s\"",
	64	stream, bt_ctf_stream_common_get_name(stream));
	65	}
	66
	67	return ret;
	68	}
	69
	70	struct bt_ctf_stream {
	71	struct bt_ctf_stream_common common;
	72	struct bt_ctf_field *packet_header;
	73	struct bt_ctf_field *packet_context;
	74
	75	/* Array of pointers to bt_ctf_event for the current packet */
	76	GPtrArray *events;
	77	struct bt_ctfser ctfser;
	78	unsigned int flushed_packet_count;
	79	uint64_t discarded_events;
	80	uint64_t last_ts_end;
	81	};
	82
	83	struct bt_ctf_stream *bt_ctf_stream_create_with_id(
	84	struct bt_ctf_stream_class *stream_class,
	85	const char *name, uint64_t id);
	86
	87	#endif /* BABELTRACE_CTF_WRITER_STREAM_INTERNAL_H */