redundancy_basic.c

Go to the documentation of this file.

/**
 * \addtogroup redundancy
 * @{
 */

/**
 * \defgroup redundancy_basic basic redundancy check module
 *
 * @{
 */

/**
 * \file
 * \brief implementation of basic redundancy check module
 * \author Georg von Zengen <vonzeng@ibr.cs.tu-bs.de>
 * \author Wolf-Bastian Poettner <poettner@ibr.cs.tu-bs.de>
 */

#include <stdlib.h>
#include <stdio.h>
#include <string.h> // memset

#include "lib/list.h"
#include "lib/memb.h"
#include "contiki.h"
#include "sys/ctimer.h"
#include "logging.h"

#include "sdnv.h"
#include "redundancy.h"
#include "bundle.h"
#include "agent.h"

uint32_t redundance_bundle_list[REDUNDANCE_MAX];
uint8_t redundance_bundle_active[REDUNDANCE_MAX];
uint8_t redundance_bundle_list_pointer;

/**
 * \brief checks if bundle was delivered before
 * \param bundlemem pointer to bundle
 * \return 1 if bundle was delivered before, 0 otherwise
 */
uint8_t redundancy_basic_check(uint32_t bundle_number)
{
        int i;

        LOG(LOGD_DTN, LOG_AGENT, LOGL_DBG, "REDUNDANCE: Checking bundle %lu for redundancy", bundle_number);

        for(i=0; i<REDUNDANCE_MAX; i++) {
                if( redundance_bundle_active[i] == 0 ) {
                        continue;
                }

                if( redundance_bundle_list[i] == bundle_number) {
                        LOG(LOGD_DTN, LOG_AGENT, LOGL_DBG, "REDUNDANCE: bundle %lu is redundant", bundle_number);
                        return 1;
                }
        }

        return 0;
}

/**
 * \brief saves the bundle in a list of delivered bundles
 * \param bundlemem pointer to bundle
 * \return 1 on successor 0 on error
 */
uint8_t redundancy_basic_set(uint32_t bundle_number)
{
        redundance_bundle_list[redundance_bundle_list_pointer] = bundle_number;
        redundance_bundle_active[redundance_bundle_list_pointer] = 1;
        redundance_bundle_list_pointer = (redundance_bundle_list_pointer + 1) % REDUNDANCE_MAX;

        return 1;
}
                
/**
 * \brief called by agent at startup
 */
void redundancy_basic_init(void)
{
        LOG(LOGD_DTN, LOG_AGENT, LOGL_DBG, "REDUNDANCE: starting");

        // Initialize our bundle list
        memset(redundance_bundle_list, 0, sizeof(uint32_t) * REDUNDANCE_MAX);
        memset(redundance_bundle_active, 0, REDUNDANCE_MAX);

        // And initialize our ring-buffer pointer
        redundance_bundle_list_pointer = 0;
}

const struct redundance_check redundancy_basic ={
        "B_REDUNDANCE",
        redundancy_basic_init,
        redundancy_basic_check,
        redundancy_basic_set,
};
/** @} */
/** @} */