/*
 * PndMQDataDistributor.h
 *
 *  Created on: 23.11.2016
 *      Author: Stockmanns
 */

#ifndef MVD_MVDOFFLINETBANALYSIS_TOPIX4_MQ_PNDMQDATADISTRIBUTOR_H_
#define MVD_MVDOFFLINETBANALYSIS_TOPIX4_MQ_PNDMQDATADISTRIBUTOR_H_

#include <FairMQDevice.h>

#include <boost/serialization/access.hpp>
#include <boost/serialization/vector.hpp>
#include <boost/serialization/deque.hpp>

#include "PndSdsHit.h"
#include "PndMQStatus.h"

class PndMQDataDistributor: public FairMQDevice {
public:
	PndMQDataDistributor();
	virtual ~PndMQDataDistributor();

	template <class Archive>
	void serialize(Archive& ar, const unsigned int version)
	{
		ar& fInputData;
		ar& fNextData;
		ar& fOutputData;
	}
protected:
	bool HandleData(FairMQParts&, int);
	void InitTask();
	void SendData(std::deque<std::deque<PndSdsHit> >& data);


private:
	#ifndef __CINT__ // for BOOST serialization
		friend class boost::serialization::access;
	#endif // for BOOST serialization

	std::deque<std::deque<PndSdsHit> > fInputData;
	std::deque<std::deque<PndSdsHit> > fOutputData;
	std::deque<std::deque<PndSdsHit> > fNextData;

	double fThreshold;
	double fCurrentThreshold;
	int fNOutputChannels;
	int fCurrentOutput;
};

#endif /* MVD_MVDOFFLINETBANALYSIS_TOPIX4_MQ_PNDMQDATADISTRIBUTOR_H_ */