File content as of revision 3:8662ebe83570:

/**
 * Copyright (c) 2015 Digi International Inc.,
 * All rights not expressly granted are reserved.
 *
 * This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this file,
 * You can obtain one at http://mozilla.org/MPL/2.0/.
 *
 * Digi International Inc. 11001 Bren Road East, Minnetonka, MN 55343
 * =======================================================================
 */
 
#include "FrameBuffer.h"

#if !(defined AVOID_DISABLE_IRQS)
#define disable_irq() __disable_irq()
#define enable_irq() __enable_irq()
#else
#define disable_irq()
#define enable_irq()
#endif

FrameBuffer::FrameBuffer() : _head(0), _tail_app(0), _tail_syncr(0), _dropped_frames(0)
{
    for (int i = 0; i < FRAME_BUFFER_SIZE; i++) {
        _frm_buf[i].frame = new ApiFrame(MAX_FRAME_PAYLOAD_LEN - 1);
        _frm_buf[i].status = FrameStatusFree;
    }
}

FrameBuffer::~FrameBuffer()
{
    for (int i = 0; i < FRAME_BUFFER_SIZE; i++) {
        delete _frm_buf[i].frame;
    }
}
    
ApiFrame *FrameBuffer::get_next_free_frame(void)
{
    uint8_t i = _head;
    ApiFrame *ret = NULL;
    
    do {
        if (_frm_buf[i].status == FrameStatusFree || _frm_buf[i].status == FrameStatusComplete) {
            if (_frm_buf[i].status == FrameStatusComplete)
                _dropped_frames++;
            _frm_buf[i].status = FrameStatusAssigned;
            ret = _frm_buf[i].frame;
            _head = ++i % FRAME_BUFFER_SIZE;
            break;
        }
        i++;
        i = i % FRAME_BUFFER_SIZE;
    } while (i != _head);

    return ret;    
}

bool FrameBuffer::complete_frame(ApiFrame *frame)
{
    bool ret = false;
    
    for (int i = 0; i < FRAME_BUFFER_SIZE; i++) {
        if (_frm_buf[i].frame == frame) {
            _frm_buf[i].status = FrameStatusComplete;
            ret = true;
            break;
        }
    }

    return ret;
}

ApiFrame *FrameBuffer::get_next_complete_frame(uint8_t* tail)
{
    uint8_t i = *tail;
    ApiFrame *ret = NULL;
    
    do {
        disable_irq();
        if (_frm_buf[i].status == FrameStatusComplete) {
            _frm_buf[i].status = FrameStatusAssigned;
            enable_irq();
            ret = _frm_buf[i].frame;
            *tail = ++i % FRAME_BUFFER_SIZE;
            break;
        }
        enable_irq();
        i++;
        i = i % FRAME_BUFFER_SIZE;
    } while (i != *tail);

    return ret;    
}

ApiFrame *FrameBuffer::get_next_complete_frame_syncr(void)
{
    return get_next_complete_frame(&_tail_syncr);
}

ApiFrame *FrameBuffer::get_next_complete_frame_app(void)
{
    return get_next_complete_frame(&_tail_app);
}

bool FrameBuffer::free_frame(ApiFrame *frame)
{
    bool ret = false;
    
    for (int i = 0; i < FRAME_BUFFER_SIZE; i++) {
        if (_frm_buf[i].frame == frame) {
            _frm_buf[i].status = FrameStatusFree;
            ret = true;
            break;
        }
    }

    return ret;
}

uint32_t FrameBuffer::get_dropped_frames_count(void)
{
    const uint32_t dropped_frames = _dropped_frames;

    _dropped_frames = 0;

    return dropped_frames;
}