/*
 * Copyright (C) 2017 INRIA
 *
 * This file is subject to the terms and conditions of the GNU Lesser
 * General Public License v2.1. See the file LICENSE in the top level
 * directory for more details.
 */

/**
 * @ingroup     net_gnrc_gomach
 * @{
 *
 * @file
 * @brief       Implementation of GoMacH's timeout module.
 *
 * @author      Shuguo Zhuo  <shuguo.zhuo@inria.fr>
 * @}
 */

#include <assert.h>

#include "xtimer.h"
#include "net/gnrc/gomach/gomach.h"
#include "net/gnrc/gomach/timeout.h"
#include "net/gnrc/gomach/types.h"

#define ENABLE_DEBUG 0
#include "debug.h"

/* Return index >= 0 if found, -ENONENT if not found. */
static int _gomach_find_timeout(gnrc_gomach_t *gomach, gnrc_gomach_timeout_type_t type)
{
    assert(gomach);

    for (unsigned i = 0; i < GNRC_GOMACH_TIMEOUT_COUNT; i++) {
        if (gomach->timeouts[i].type == type) {
            return i;
        }
    }
    return -ENOENT;
}

inline bool gnrc_gomach_timeout_is_running(gnrc_netif_t *netif,
                                           gnrc_gomach_timeout_type_t type)
{
    assert(netif);
    return (_gomach_find_timeout(&netif->mac.prot.gomach, type) >= 0);
}

bool gnrc_gomach_timeout_is_expired(gnrc_netif_t *netif, gnrc_gomach_timeout_type_t type)
{
    assert(netif);

    int index = _gomach_find_timeout(&netif->mac.prot.gomach, type);
    if (index >= 0) {
        if (netif->mac.prot.gomach.timeouts[index].expired) {
            xtimer_remove(&(netif->mac.prot.gomach.timeouts[index].timer));
            netif->mac.prot.gomach.timeouts[index].type = GNRC_GOMACH_TIMEOUT_DISABLED;
        }
        return netif->mac.prot.gomach.timeouts[index].expired;
    }
    return false;
}

gnrc_gomach_timeout_t *_gomach_acquire_timeout(gnrc_netif_t *netif,
                                               gnrc_gomach_timeout_type_t type)
{
    assert(netif);

    if (gnrc_gomach_timeout_is_running(netif, type)) {
        return NULL;
    }

    for (unsigned i = 0; i < GNRC_GOMACH_TIMEOUT_COUNT; i++) {
        if (netif->mac.prot.gomach.timeouts[i].type == GNRC_GOMACH_TIMEOUT_DISABLED) {
            netif->mac.prot.gomach.timeouts[i].type = type;
            return &netif->mac.prot.gomach.timeouts[i];
        }
    }
    return NULL;
}

void gnrc_gomach_clear_timeout(gnrc_netif_t *netif, gnrc_gomach_timeout_type_t type)
{
    assert(netif);

    int index = _gomach_find_timeout(&netif->mac.prot.gomach, type);
    if (index >= 0) {
        xtimer_remove(&(netif->mac.prot.gomach.timeouts[index].timer));
        netif->mac.prot.gomach.timeouts[index].type = GNRC_GOMACH_TIMEOUT_DISABLED;
        netif->mac.prot.gomach.timeouts[index].expired = false;
    }
}

void gnrc_gomach_set_timeout(gnrc_netif_t *netif,
                             gnrc_gomach_timeout_type_t type,
                             uint32_t offset)
{
    assert(netif);

    gnrc_gomach_timeout_t *timeout;
    if ((timeout = _gomach_acquire_timeout(netif, type))) {
        timeout->expired = false;
        timeout->msg.type = GNRC_GOMACH_EVENT_TIMEOUT_TYPE;
        timeout->msg.content.ptr = (void *) timeout;
        xtimer_set_msg(&(timeout->timer), offset,
                       &(timeout->msg), netif->pid);
    }
    else {
        DEBUG("[GoMacH]: Cannot set timeout, too many concurrent timeouts\n");
    }
}

void gnrc_gomach_reset_timeouts(gnrc_netif_t *netif)
{
    assert(netif);

    for (unsigned i = 0; i < GNRC_GOMACH_TIMEOUT_COUNT; i++) {
        if (netif->mac.prot.gomach.timeouts[i].type != GNRC_GOMACH_TIMEOUT_DISABLED) {
            xtimer_remove(&(netif->mac.prot.gomach.timeouts[i].timer));
            netif->mac.prot.gomach.timeouts[i].type = GNRC_GOMACH_TIMEOUT_DISABLED;
        }
    }
}