#include "IGConnector.h"

#include <osg/Notify>
#include "ThreadedWorker.h"


IGConnector::IGConnector(int numberOfchannels, OpenThreads::Barrier& frameBarrier)
: _numberOfchannels(numberOfchannels), _frameBarrier(frameBarrier)
{
	OSG_ALWAYS<<"IGConnector instantiated."<<std::endl;
}

IGConnector::~IGConnector()
{
}

void IGConnector::operator()(ThreadedWorker* threadObject)
{
	OSG_ALWAYS<<"IGConnector "<<threadObject->getThreadId()<<" : Receiving SOF packet"<<std::endl;

	_frameBarrier.block(_numberOfchannels+1);  // Sync the main and all IG threads.

	OSG_ALWAYS<<"IGConnector "<<threadObject->getThreadId()<<" : Sending SOF answer packet"<<std::endl;

	// Place Holder
	for(int i=0;i<100;i++)
		OSG_ALWAYS<<"";

}