From bab4885f1e923a252209db8b6011cf8a2fcb30c5 Mon Sep 17 00:00:00 2001
From: Joshua Colp <jcolp@digium.com>
Date: Tue, 7 Feb 2017 12:56:41 +0000
Subject: stream: Add media stream definition and API with unit tests.

This change adds the media stream definition and API for
accessing and using it. Unit tests have also been written
which exercise aspects of the API.

ASTERISK-26773

Change-Id: I3dbe54065b55aaa51f467e1a3bafd67fb48cac87
---
 main/stream.c | 128 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 128 insertions(+)
 create mode 100644 main/stream.c

(limited to 'main')

diff --git a/main/stream.c b/main/stream.c
new file mode 100644
index 000000000..fb3dbd5ce
--- /dev/null
+++ b/main/stream.c
@@ -0,0 +1,128 @@
+/*
+ * Asterisk -- An open source telephony toolkit.
+ *
+ * Copyright (C) 2017, Digium, Inc.
+ *
+ * Joshua Colp <jcolp@digium.com>
+ *
+ * See http://www.asterisk.org for more information about
+ * the Asterisk project. Please do not directly contact
+ * any of the maintainers of this project for assistance;
+ * the project provides a web site, mailing lists and IRC
+ * channels for your use.
+ *
+ * This program is free software, distributed under the terms of
+ * the GNU General Public License Version 2. See the LICENSE file
+ * at the top of the source tree.
+ */
+
+/*! \file
+ *
+ * \brief Media Stream API
+ *
+ * \author Joshua Colp <jcolp@digium.com>
+ */
+
+/*** MODULEINFO
+	<support_level>core</support_level>
+ ***/
+
+#include "asterisk.h"
+
+#include "asterisk/logger.h"
+#include "asterisk/stream.h"
+#include "asterisk/strings.h"
+
+struct ast_stream {
+	/*!
+	 * \brief The type of media the stream is handling
+	 */
+	enum ast_media_type type;
+
+	/*!
+	 * \brief Unique number for the stream within the context of the channel it is on
+	 */
+	unsigned int num;
+
+	/*!
+	 * \brief Current formats negotiated on the stream
+	 */
+	struct ast_format_cap *formats;
+
+	/*!
+	 * \brief The current state of the stream
+	 */
+	enum ast_stream_state state;
+
+	/*!
+	 * \brief Name for the stream within the context of the channel it is on
+	 */
+	char name[0];
+};
+
+struct ast_stream *ast_stream_create(const char *name, enum ast_media_type type)
+{
+	struct ast_stream *stream;
+
+	stream = ast_calloc(1, sizeof(*stream) + strlen(S_OR(name, "")) + 1);
+	if (!stream) {
+		return NULL;
+	}
+
+	stream->type = type;
+	stream->state = AST_STREAM_STATE_INACTIVE;
+	strcpy(stream->name, S_OR(name, ""));
+
+	return stream;
+}
+
+void ast_stream_destroy(struct ast_stream *stream)
+{
+	if (!stream) {
+		return;
+	}
+
+	ao2_cleanup(stream->formats);
+	ast_free(stream);
+}
+
+const char *ast_stream_get_name(const struct ast_stream *stream)
+{
+	return stream->name;
+}
+
+enum ast_media_type ast_stream_get_type(const struct ast_stream *stream)
+{
+	return stream->type;
+}
+
+void ast_stream_set_type(struct ast_stream *stream, enum ast_media_type type)
+{
+	stream->type = type;
+}
+
+struct ast_format_cap *ast_stream_get_formats(const struct ast_stream *stream)
+{
+	return stream->formats;
+}
+
+void ast_stream_set_formats(struct ast_stream *stream, struct ast_format_cap *caps)
+{
+	ao2_cleanup(stream->formats);
+	stream->formats = ao2_bump(caps);
+}
+
+enum ast_stream_state ast_stream_get_state(const struct ast_stream *stream)
+{
+	return stream->state;
+}
+
+void ast_stream_set_state(struct ast_stream *stream, enum ast_stream_state state)
+{
+	stream->state = state;
+}
+
+unsigned int ast_stream_get_num(const struct ast_stream *stream)
+{
+	return stream->num;
+}
-- 
cgit v1.2.3