source: experimental/Threading/Threading/IGConnector.cpp @ 430

#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<<"";

}