Changeset 430 for experimental/Threading/Threading/IGConnector.cpp

Timestamp:

Oct 25, 2012, 9:49:08 AM (12 years ago)

Author:

Torben Dannhauer

Message:

 

File:

• experimental/Threading/Threading/IGConnector.cpp (modified) (2 diffs)

experimental/Threading/Threading/IGConnector.cpp

@@ -5 +5 @@
 
 
-IGConnector::IGConnector()
+IGConnector::IGConnector(int numberOfchannels, OpenThreads::Barrier& frameBarrier)
+: _numberOfchannels(numberOfchannels), _frameBarrier(frameBarrier)
 {
         OSG_ALWAYS<<"IGConnector instantiated."<<std::endl;
@@ -16 +17 @@
 void IGConnector::operator()(ThreadedWorker* threadObject)
 {
-        OSG_ALWAYS<<"IGConnector running: ID "<<threadObject->getThreadId()<<std::endl;
+        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