#include "PL_Fork1.h"
|
#include "MaterialBuffer.h"
|
#include "logger.h"
|
|
struct PL_Fork1_Internal
|
{
|
//uint8_t buffer[1920*1080*4];
|
//size_t buffSize;
|
//size_t buffSizeMax;
|
|
PipeMaterial lastPm;
|
|
MB_Frame lastFrame;
|
|
PL_Fork1_Config config;
|
|
bool payError;
|
|
PL_Fork1_Internal() :
|
//buffSize(0), buffSizeMax(sizeof(buffer)),
|
lastPm(), lastFrame(), config(), payError(true)
|
{
|
}
|
|
~PL_Fork1_Internal()
|
{
|
}
|
|
void reset()
|
{
|
//buffSize = 0;
|
payError = true;
|
|
PipeMaterial _lastPm;
|
lastPm = _lastPm;
|
|
MB_Frame _lastFrame;
|
lastFrame = _lastFrame;
|
|
PL_Fork1_Config _config;
|
config = _config;
|
}
|
};
|
|
PipeLineElem* create_PL_Fork1()
|
{
|
return new PL_Fork1;
|
}
|
|
PL_Fork1::PL_Fork1() : internal(new PL_Fork1_Internal), pl(nullptr)
|
{
|
}
|
|
PL_Fork1::~PL_Fork1()
|
{
|
delete (PL_Fork1_Internal*)internal;
|
internal= nullptr;
|
}
|
|
bool PL_Fork1::init(void* args)
|
{
|
PL_Fork1_Internal* in = (PL_Fork1_Internal*)internal;
|
in->reset();
|
|
if (args == nullptr)
|
{
|
LOG_ERROR << "Config should give" << std::endl;
|
return false;
|
}
|
|
PL_Fork1_Config* config = (PL_Fork1_Config*)args;
|
in->config = *config;
|
|
return true;
|
}
|
|
void PL_Fork1::finit()
|
{
|
PL_Fork1_Internal* in = (PL_Fork1_Internal*)internal;
|
|
}
|
|
bool PL_Fork1::pay(const PipeMaterial& pm)
|
{
|
PL_Fork1_Internal* in = (PL_Fork1_Internal*)internal;
|
PL_Fork1_Config& config(in->config);
|
|
in->lastPm = pm;
|
|
return false;
|
}
|
|
bool PL_Fork1::gain(PipeMaterial& pm)
|
{
|
PL_Fork1_Internal* in = (PL_Fork1_Internal*)internal;
|
|
return false;
|
}
|
|
void PL_Fork1::attach_pipe_line(PipeLine* pl)
|
{
|
PL_Fork1_Internal* in = (PL_Fork1_Internal*)internal;
|
|
if (this->pl != nullptr)
|
{
|
LOG_ERROR << "Has areadly attached pipe line" << std::endl;
|
return;
|
}
|
|
if (pl == nullptr)
|
{
|
LOG_NOTICE << "Detach pipe line" << std::endl;
|
this->pl->remove_elem(this);
|
this->pl = nullptr;
|
return;
|
}
|
|
this->pl = pl;
|
PipeLine* mainPipeLineManager = this->manager;
|
pl->push_front_elem(this);
|
this->manager = mainPipeLineManager;
|
}
|
