RTP pack/unpack

[rcvangemert]

Hi, Thanks for your library. I am trying to use rtp to encode/decode data. As is am not locked to a known format I am using your rtp-pack.c & rtp-unpack.c

I have the encode side working but am struggling with the decode side. I hope to feed in an async stream with the input data coming in by repeating calls to decode. The way I see it you can only call encode once. What am I missing?

Thanks,
Robert

//
// Created by rcvangemert on 5/2/23.
//
#include "rtp-payload.h"
#include "rtp-profile.h"
#include "rtp-packet.h"
#include "rtp-payload-internal.h"
#include <stdlib.h>
#include <string.h>
#include <assert.h>
#include <sys/time.h>
#include <android/log.h>

#define NDK_TAG "native_juice"
#define VERBOSE 1
#if VERBOSE
#define LOGI(...) __android_log_print(ANDROID_LOG_INFO, NDK_TAG, __VA_ARGS__)
#else
#define LOGI(...) ;
#endif

#define PAYLOAD_SIZE 1200

unsigned long int _usec(void) {
    struct timeval t;
    gettimeofday(&t, (struct timezone *) NULL);
    unsigned long int us = t.tv_sec;
    us *= 1000000u;
    us += t.tv_usec;
    return us;
}

static unsigned long int startUsec = 0;

uint32_t timeStamp() {
    if(startUsec == 0) {
        startUsec = _usec();
        return startUsec;
    }
    else
        return (_usec() - startUsec);
}

static void* rtp_alloc(void* /*param*/, int bytes)
{
    static uint8_t buffer[PAYLOAD_SIZE];
    return buffer;
}

static void rtp_free(void* /*param*/, void * /*packet*/)
{
}

static int rtp_packet(void* param, const void *packet, int bytes, uint32_t timestamp, int flags)
{
    return 0;
}

static struct rtp_payload_encode_t *encoder;
static struct rtp_payload_t handler;
static struct rtp_packer_t *packer;

void create_encoder() {
    encoder = rtp_common_encode();

    handler.alloc = rtp_alloc;
    handler.packet = rtp_packet;
    handler.free = rtp_free;

    packer = encoder->create(PAYLOAD_SIZE, RTP_PAYLOAD_DYNAMIC, 0, 0, &handler, 0 /*param*/);
}

int encode(void* data, int bytes) {
    return encoder->input(packer, data,bytes, timeStamp());
}

void delete_encoder() {
    encoder->destroy(packer);
}

void test_rtp_encoder(void) {
    char str[8192+5+1];

    LOGI("start test encoder");

    create_encoder();
    for (int i = 0; i < 10000; ++i) {
        sprintf(str, "%.8192d", i);
        encode(str, strlen(str));
    }
    delete_encoder();

    LOGI("end test encoder");
}

//
// Created by rcvangemert on 5/3/23.
//
#include "rtp-payload.h"
#include "rtp-profile.h"
#include "rtp-packet.h"
#include "rtp-payload-internal.h"
#include <stdlib.h>
#include <string.h>
#include <assert.h>
#include <sys/time.h>
#include <android/log.h>

#define NDK_TAG "native_juice"
#define VERBOSE 1
#if VERBOSE
#define LOGI(...) __android_log_print(ANDROID_LOG_INFO, NDK_TAG, __VA_ARGS__)
#else
#define LOGI(...) ;
#endif

#define PAYLOAD_SIZE 1200

static struct rtp_payload_decode_t *decoder;
static struct rtp_payload_t handler;
static struct rtp_unpacker_t *unpacker;

static void* rtp_alloc(void* /*param*/, int bytes)
{
    static uint8_t buffer[PAYLOAD_SIZE];
    return buffer;
}

static void rtp_free(void* /*param*/, void * /*packet*/)
{
}

static int rtp_packet(void* param, const void *packet, int bytes, uint32_t timestamp, int flags)
{
//incoming decoded data?
    return 0;
}

void create_decoder() {
    decoder = rtp_common_decode();

    handler.alloc = rtp_alloc;
    handler.packet = rtp_packet;
    handler.free = rtp_free;

    unpacker = decoder->create(&handler, 0 /*param*/);
}

int decode(void* data, int bytes) {
    return decoder->input(unpacker, data, bytes);
}

void delete_decoder() {
    decoder->destroy(unpacker);
}

[rcvangemert]

mabe rtp_queue_t is the answer? This way I should have fully formed RTP packets to feed decoder->input(unpacker, data, bytes)

[ireader]

rtp encode/decode has many useful api：

1. librtp/include/rtp-payload.h: rtp_payload_encode_create/rtp_payload_decode_create
2. librtp/include/rtp-demuxer.h: rtp_demuxer_create
3. librtsp/include/rtsp-muxer.h/rtsp-demuxer.h: rtsp_demuxer_create

For rtp packet decode:

1. rtp_payload_decode_create: only for rtp packet decode, output raw payload;
2. rtp_demuxer_create: rtp packet decode + rtp reorder
3. rtsp_demuxer_create: rtp packet decode + rtp reorder + sdp fmtp parse + mpeg-ps/ts decode + audio/video packet handle

so, use rtsp_demuxer_create if any.

[rcvangemert]

Thanks for the info. I am now trying rtp_demuxer_create. I think I understand the process. I chose jitter and frequency values that I have seen in your code but I do not understand. Can you give a brief explanation so I can investigate? As I am not locked to a format I chose "encoding" but rtp_payload_find fails because "encoding" is not known. Opus seems to be my best choice but your code is locked to defined formats. rtp_demuxer_create(100, 90000, RTP_PAYLOAD_DYNAMIC, "encoding", rtp_onpacket, 0);

…

On Mon, 8 May 2023 at 22:49, Chen ***@***.***> wrote: rtp encode/decode has many useful api： 1. librtp/include/rtp-payload.h: rtp_payload_encode_create/rtp_payload_decode_create 2. librtp/include/rtp-demuxer.h: rtp_demuxer_create 3. librtsp/include/rtsp-muxer.h/rtsp-demuxer.h: rtsp_demuxer_create For rtp packet decode: 1. rtp_payload_decode_create: only for rtp packet decode, output raw payload; 2. rtp_demuxer_create: rtp packet decode + rtp reorder 3. rtsp_demuxer_create: rtp packet decode + rtp reorder + sdp fmtp parse + mpeg-ps/ts decode + audio/video packet handle so, use rtsp_demuxer_create if any. — Reply to this email directly, view it on GitHub <#275 (comment)>, or unsubscribe <https://github.com/notifications/unsubscribe-auth/ABGSW3CLRSFJYXC5ARQCM2DXFDTUFANCNFSM6AAAAAAXZRPKMQ> . You are receiving this because you authored the thread.Message ID: ***@***.***>