#include "PL_RTSPServer.h"

struct PL_RTSPServer_Internal
{
	uint8_t buffer[1920*1080*4];
	size_t buffSize;
	size_t buffSizeMax;

	bool payError;
	
	PL_RTSPServer_Internal() : 
		buffSize(0), buffSizeMax(sizeof(buffer)), 
		payError(true)
	{
	}
	
	~PL_RTSPServer_Internal()
	{
	}
	
	void reset()
	{
		buffSize = 0;
		payError = true;
	}
};

PipeLineElem* create_PL_RTSPServer()
{
	return new PL_RTSPServer;
}

PL_RTSPServer::PL_RTSPServer() : internal(new PL_RTSPServer_Internal)
{
}

PL_RTSPServer::~PL_RTSPServer()
{
	delete (PL_RTSPServer_Internal*)internal;
	internal= nullptr;
}

bool PL_RTSPServer::init(void* args)
{
	PL_RTSPServer_Internal* in = (PL_RTSPServer_Internal*)internal;
	in->reset();

	return true;
}

void PL_RTSPServer::finit()
{
	PL_RTSPServer_Internal* in = (PL_RTSPServer_Internal*)internal;
	
}

bool PL_RTSPServer::pay(const PipeMaterial& pm)
{
	PL_RTSPServer_Internal* in = (PL_RTSPServer_Internal*)internal;
	
	//in->buffer readly

	//static size_t f=0;
	//char fname[50];
	//sprintf(fname, "%u.bgra", ++f);
	//FILE * pFile = fopen (fname,"wb");
	//fwrite (in->buffer , sizeof(char), in->buffSize, pFile);
	//fclose(pFile);

	return true;
}

bool PL_RTSPServer::gain(PipeMaterial& pm)
{
	PL_RTSPServer_Internal* in = (PL_RTSPServer_Internal*)internal;

	pm.buffer = in->buffer;
	pm.buffSize = in->buffSize;
	pm.former = this;
	return true;
}