#ifndef _PL_QUEUE_H_
#define _PL_QUEUE_H_

#include "PipeLine.h"
#include "MaterialBuffer.h"

typedef bool (*plq_cache_pm_func_t)(const PipeMaterial& inPm, PipeMaterial& outPm, std::vector<MB_Frame>& outMbf, uint8_t* cacheData, size_t& cacheMaxSize);

struct PL_Queue_Config
{
	size_t maxBlockCount;
	size_t maxBlockSize;
	bool cacheEmptyBlock;//#todo not implement
	
	bool syncQueueFull;
	bool syncQueueEmpty;
	bool queueFullDropFrontBlock;
	bool copyData; //#todo not implement (copy ptr)
	bool dropBlockOnlyNextPayOK;

	plq_cache_pm_func_t cacheFrameListFunc;
	
	PL_Queue_Config() : 
		maxBlockCount(32), maxBlockSize(1920*1080*2), cacheEmptyBlock(false),
		syncQueueFull(true), syncQueueEmpty(true), queueFullDropFrontBlock(false), copyData(true), dropBlockOnlyNextPayOK(true),
		cacheFrameListFunc(nullptr)
	{
	}
};

class PL_Queue : public PipeLineElem
{
public:
	PL_Queue();
	virtual ~PL_Queue();

	virtual bool init(void* args);
	virtual void finit();

	virtual bool pay(const PipeMaterial& pm);
	virtual bool gain(PipeMaterial& pm);
	
private:
	static void pm_deleter_qb(PipeMaterial* pm, bool lastRet);

	void* internal;
};

PipeLineElem* create_PL_Queue();

#endif