rtp_queue.h

Go to the documentation of this file.

/*******************************************************************************
 * Copyright © 2020 The DTVKit Open Software Foundation Ltd (www.dtvkit.org)
 * Copyright © 2020 Ocean Blue Software Ltd
 *
 * This file is part of a DTVKit Software Component
 * You are permitted to copy, modify or distribute this file subject to the terms
 * of the DTVKit 1.0 Licence which can be found in licence.txt or at www.dtvkit.org
 *
 * THIS CODE AND INFORMATION ARE PROVIDED "AS IS" WITHOUT WARRANTY OF ANY KIND,
 * EITHER EXPRESSED OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE IMPLIED WARRANTIES
 * OF MERCHANTABILITY AND/OR FITNESS FOR A PARTICULAR PURPOSE.
 *
 * If you or your organisation is not a member of DTVKit then you have access
 * to this source code outside of the terms of the licence agreement
 * and you are expected to delete this and any associated files immediately.
 * Further information on DTVKit, membership and terms can be found at www.dtvkit.org
 *******************************************************************************/

#ifndef __RTP_QUEUE_H
#define __RTP_QUEUE_H

/*---includes for this file--------------------------------------------------*/

#include "techtype.h"


/*---Constant and macro definitions for public use---------------------------*/

/*---Enumerations for public use---------------------------------------------*/

/*---Global type defs for public use-----------------------------------------*/

typedef struct s_item_info
{
   U8BIT *buffer;
   U32BIT send_clock;
   U32BIT rcvd_clock;
   U16BIT buff_size;
} S_ITEM_INFO;

/*---Global variable declarations for public use-----------------------------*/

/*---Global Function prototypes for public use-------------------------------*/

void *RTPCreateSequencingArray(U32BIT fec_layer);

void RTPDestroySequencingArray(void *handle);

void* RTPCreatePlayoutQueue(U32BIT low_threshold, U32BIT high_threshold);

void RTPDeletePlayoutQueue(void *handle);

void RTPConnectSeqArrayToPlayoutQueue(void *seq_array_hdl, void *queue_hdl);

void* RTPAllocateMedia(U8BIT **buffer, U16BIT data_size);

void* RTPAllocateFEC(U8BIT **buffer, U16BIT buff_size);

void RTPFreePkt(void *handle);

BOOLEAN RTPInsertMedia(void *seq_array_hdl, void *rtp_packet_hdl, U16BIT buffer_bytes);

void RTPParseCntl(void *seq_array_hdl, U8BIT *buffer, U16BIT buffer_bytes);

BOOLEAN RTPInsertFec(void *seq_array_hdl, void *fec_packet_hdl, U16BIT buffer_len, BOOLEAN second_stream);

void* RTPRemoveQueueItem(void *queue_handle, S_ITEM_INFO *info);

void RTPUnpauseQueue(void *queue_handle);

#endif /* __RTP_QUEUE_H */