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

#ifndef MVD_MVDOFFLINETBANALYSIS_TOPIX4_MQ_PndMQDataMerger_H_
#define MVD_MVDOFFLINETBANALYSIS_TOPIX4_MQ_PndMQDataMerger_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 PndMQDataMerger: public FairMQDevice {
public:
	PndMQDataMerger();
	virtual ~PndMQDataMerger();

	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;

	int fNInputChannels;
	int fCurrentInput;
};

#endif /* MVD_MVDOFFLINETBANALYSIS_TOPIX4_MQ_PndMQDataMerger_H_ */