[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;
};

BT_HIDDEN
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);

BT_HIDDEN
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;
};

BT_HIDDEN
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	BT_HIDDEN
	34	int bt_ctf_stream_common_initialize(
	35	struct bt_ctf_stream_common *stream,
	36	struct bt_ctf_stream_class_common stream_class, const char name,
	37	uint64_t id, bt_ctf_object_release_func release_func);
	38
	39	BT_HIDDEN
	40	void bt_ctf_stream_common_finalize(struct bt_ctf_stream_common *stream);
	41
	42	static inline
	43	struct bt_ctf_stream_class_common *bt_ctf_stream_common_borrow_class(
	44	struct bt_ctf_stream_common *stream)
	45	{
	46	BT_ASSERT_DBG(stream);
	47	return stream->stream_class;
	48	}
	49
	50	static inline
	51	const char bt_ctf_stream_common_get_name(struct bt_ctf_stream_common stream)
	52	{
	53	BT_CTF_ASSERT_PRE_NON_NULL(stream, "Stream");
	54	return stream->name ? stream->name->str : NULL;
	55	}
	56
	57	static inline
	58	int64_t bt_ctf_stream_common_get_id(struct bt_ctf_stream_common *stream)
	59	{
	60	int64_t ret;
	61
	62	BT_CTF_ASSERT_PRE_NON_NULL(stream, "Stream");
	63	ret = stream->id;
	64	if (ret < 0) {
	65	BT_LOGT("Stream's ID is not set: addr=%p, name=\"%s\"",
	66	stream, bt_ctf_stream_common_get_name(stream));
	67	}
	68
	69	return ret;
	70	}
	71
	72	struct bt_ctf_stream {
	73	struct bt_ctf_stream_common common;
	74	struct bt_ctf_field *packet_header;
	75	struct bt_ctf_field *packet_context;
	76
	77	/* Array of pointers to bt_ctf_event for the current packet */
	78	GPtrArray *events;
	79	struct bt_ctfser ctfser;
	80	unsigned int flushed_packet_count;
	81	uint64_t discarded_events;
	82	uint64_t last_ts_end;
	83	};
	84
	85	BT_HIDDEN
	86	struct bt_ctf_stream *bt_ctf_stream_create_with_id(
	87	struct bt_ctf_stream_class *stream_class,
	88	const char *name, uint64_t id);
	89
	90	#endif /* BABELTRACE_CTF_WRITER_STREAM_INTERNAL_H */