channelStateInformation.c

#include <stdlib.h>
#include "../defines.h"
#include "../util/common.h"
#include "../util/dbg.h"
#include "channelStateInformation.h"
#include "clock.h"

PrrtChannelStateInformation * PrrtChannelStateInformation_create()
{
    PrrtChannelStateInformation *csi = calloc(1, sizeof(PrrtChannelStateInformation));
    check_mem(csi);

    check(pthread_mutex_init(&csi->lock, NULL) == 0, "Mutex init failed.");

    csi->rtprop = TIMESTAMP_SPACE;
    csi->rtprop_filter_length_us = 2 * 1000 * 1000; // 2 seconds
    return csi;

    error:
    PERROR("Should not happen.%s","");
    return NULL;
}

void PrrtChannelStateInformation_update_rtprop(PrrtChannelStateInformation *csi, prrtTimedelta_t rtprop)
{
    pthread_mutex_lock(&csi->lock);
    prrtTimestamp_t now = PrrtClock_get_current_time_us();
    csi->rtprop_expired = now > (csi->rtprop_stamp + csi->rtprop_filter_length_us);
    if (rtprop >= 0 && (rtprop <= csi->rtprop || csi->rtprop_expired)) {
        csi->rtprop = rtprop;
        csi->rtprop_stamp = now;
    }
    pthread_mutex_unlock(&csi->lock);
}

void PrrtChannelStateInformation_update_plr(PrrtChannelStateInformation *csi, prrtSequenceNumber_t erasures,
                                                   prrtSequenceNumber_t packets) {
    pthread_mutex_lock(&csi->lock);
    csi->plr = ((float) erasures) / packets;
    pthread_mutex_unlock(&csi->lock);
}


prrtTimedelta_t PrrtChannelStateInformation_get_rtprop(PrrtChannelStateInformation *csi)
{
    pthread_mutex_lock(&csi->lock);
    prrtTimedelta_t res = csi->rtprop;
    pthread_mutex_unlock(&csi->lock);
    return res;
}

bool PrrtChannelStateInformation_destroy(PrrtChannelStateInformation *csi)
{
    check(pthread_mutex_destroy(&csi->lock) == EXIT_SUCCESS, "Destroy mutex failed.");
    free(csi);
    return true;
    error:
        return false;
}

prrtPacketLossRate_t PrrtChannelStateInformation_get_plr(PrrtChannelStateInformation *csi) {
    return csi->plr;
}