#include "hframe.h"

int HFrameBuf::push(HFrame* pFrame){
    if (pFrame->isNull())
        return -10;

    frame_stats.push_cnt++;

    std::lock_guard<std::mutex> locker(mutex);

    if (frames.size() >= cache_num){
        if (policy == HFrameBuf::DISCARD){
            return -20; // note: cache full, discard frame
        }

        // note: cache full, remove front, push newer frame
        HFrame& frame = frames.front();
        frames.pop_front();
        free(frame.buf.len);
    }

    int ret = 0;
    if (isNull()){
        init(pFrame->buf.len * cache_num);
        ret = 1; // note: first push

        frame_info.w = pFrame->w;
        frame_info.h = pFrame->h;
        frame_info.type = pFrame->type;
        frame_info.bpp  = pFrame->bpp;
    }

    HFrame frame;
    frame.buf.base = alloc(pFrame->buf.len);
    frame.buf.len  = pFrame->buf.len;
    frame.copy(*pFrame);
    frames.push_back(frame);
    frame_stats.push_ok_cnt++;

    return ret;
}

int HFrameBuf::pop(HFrame* pFrame){
    frame_stats.pop_cnt++;

    std::lock_guard<std::mutex> locker(mutex);

    if (isNull())
        return -10;

    if (frames.size() == 0)
        return -20;

    HFrame& frame = frames.front();
    frames.pop_front();
    free(frame.buf.len);

    if (frame.isNull())
        return -30;

    pFrame->copy(frame);
    frame_stats.pop_ok_cnt++;

    return 0;
}