src/data_transport/transport.c

#include "transport.h"
#include <rawrtcdc/config.h>
#include <rawrtcdc/data_transport.h>
#include <rawrtcc/code.h>
#include <re.h>

#define DEBUG_MODULE "data-transport"
//#define RAWRTC_DEBUG_MODULE_LEVEL 7 // Note: Uncomment this to debug this module only
#include <rawrtcc/debug.h>

/*
 * Destructor for an existing data transport.
 */
static void rawrtc_data_transport_destroy(void* arg) {
    struct rawrtc_data_transport* const transport = arg;

    // Un-reference
    mem_deref(transport->transport);
}

/*
 * Create a data transport instance.
 */
enum rawrtc_code rawrtc_data_transport_create(
    struct rawrtc_data_transport** const transportp,  // de-referenced
    enum rawrtc_data_transport_type const type,
    void* const internal_transport,  // referenced
    rawrtc_data_transport_channel_create_handler const channel_create_handler,
    rawrtc_data_transport_channel_close_handler const channel_close_handler,
    rawrtc_data_transport_channel_send_handler const channel_send_handler,
    rawrtc_data_transport_channel_set_streaming_handler const channel_set_streaming_handler) {
    struct rawrtc_data_transport* transport;

    // Check arguments
    if (!transportp || !internal_transport || !channel_create_handler) {
        return RAWRTC_CODE_INVALID_ARGUMENT;
    }

    // Allocate
    transport = mem_zalloc(sizeof(*transport), rawrtc_data_transport_destroy);
    if (!transport) {
        return RAWRTC_CODE_NO_MEMORY;
    }

    // Set fields
    transport->type = type;
    transport->transport = mem_ref(internal_transport);
    transport->channel_create = channel_create_handler;
    transport->channel_close = channel_close_handler;
    transport->channel_send = channel_send_handler;
    transport->channel_set_streaming = channel_set_streaming_handler;

    // Set pointer & done
    DEBUG_PRINTF("Created data transport of type %s\n", rawrtc_data_transport_type_to_str(type));
    *transportp = transport;
    return RAWRTC_CODE_SUCCESS;
}