Changeset 62 for osgVisual/src/cluster/dataIO_clusterAsioTcpIostream.cpp

Timestamp:

Jun 8, 2010, 9:39:17 AM (14 years ago)

Author:

Torben Dannhauer

Message:

 

File:

• osgVisual/src/cluster/dataIO_clusterAsioTcpIostream.cpp (modified) (5 diffs)

osgVisual/src/cluster/dataIO_clusterAsioTcpIostream.cpp

@@ -15 +15 @@
 */
 
-#include "..\..\include\cluster\dataIO_clusterAsioTcpIostream.h"
+#include "dataIO_clusterAsioTcpIostream.h"
 
 using namespace osgVisual;
 
-dataIO_clusterAsioTcpIostream::dataIO_clusterAsioTcpIostream()
+using boost::asio::ip::tcp;
+
+dataIO_clusterAsioTcpIostream::dataIO_clusterAsioTcpIostream() 
 {
-        OSG_NOTIFY( osg::ALWAYS ) << "clusterAsioTcpIostream constructed" << std::endl;
+        OSG_NOTIFY(osg::ALWAYS) << "dataIO_clusterAsioTcpIostream constructed" << std::endl;
+
+        port = 5678;
+        initialized = false;
 }
 
-dataIO_clusterAsioTcpIostream::~dataIO_clusterAsioTcpIostream(void)
+dataIO_clusterAsioTcpIostream::~dataIO_clusterAsioTcpIostream()
 {
-        OSG_NOTIFY( osg::ALWAYS ) << "clusterAsioTcpIostream destructed" << std::endl;
+        OSG_NOTIFY(osg::ALWAYS) << "dataIO_clusterAsioTcpIostream destructed" << std::endl;
 }
 
 void dataIO_clusterAsioTcpIostream::init( osg::ArgumentParser& arguments_, clustermode clusterMode_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ )
 {
-        OSG_NOTIFY( osg::ALWAYS ) << "clusterAsioTcpIostream init()" << std::endl;
+        OSG_NOTIFY(osg::ALWAYS) << "dataIO_clusterAsioTcpIostream initialized" << std::endl;
+
+        clusterMode = clusterMode_;
+
+        if(clusterMode == osgVisual::dataIO_cluster::MASTER)
+        {
+                
+
+                tcp::endpoint endpoint(tcp::v4(), port);
+                tcp::acceptor acceptor(io_service, endpoint);
+
+                                                                                tcp::iostream stream;
+                                                                        
+                                                                                acceptor.accept(*stream.rdbuf());
+                                                                                tcp::no_delay option(true);
+                                                                                boost::system::error_code ec;
+                                                                                stream.rdbuf()->set_option(option, ec);
+                                                                                if (ec)
+                                                                                {
+                                                                                        OSG_NOTIFY(osg::WARN) << "Error: Unable to set TCP_NODELAY option" << ec << std::endl;
+                                                                                        // An error occurred.
+                                                                                }
+        }
+
+        if(clusterMode == osgVisual::dataIO_cluster::SLAVE)
+        {
+
+        }
+
+        initialized = true;
 }
 
 void dataIO_clusterAsioTcpIostream::shutdown()
 {
-        OSG_NOTIFY( osg::ALWAYS ) << "clusterAsioTcpIostream shutdown()" << std::endl;
+        OSG_NOTIFY(osg::ALWAYS) << "dataIO_clusterAsioTcpIostream shut down" << std::endl;
+
+        if(initialized)
+        {
+
+        }
 }
 
 bool dataIO_clusterAsioTcpIostream::sendTO_OBJvaluesToSlaves()
 {
-        OSG_NOTIFY( osg::INFO ) << "clusterAsioTcpIostream sendTO_OBJvaluesToSlaves()" << std::endl;
+        OSG_NOTIFY(osg::INFO) << "dataIO_clusterAsioTcpIostream::sendTO_OBJvaluesToSlaves()" << std::endl;
+
         return true;
 }
@@ -47 +87 @@
 bool dataIO_clusterAsioTcpIostream::readTO_OBJvaluesFromMaster()
 {
-        OSG_NOTIFY( osg::INFO ) << "clusterAsioTcpIostream readTO_OBJvaluesFromMaster()" << std::endl;
+        OSG_NOTIFY(osg::INFO) << "dataIO_clusterAsioTcpIostream::readTO_OBJvaluesFromMaster()" << std::endl;
 
         return true;
@@ -54 +94 @@
 void dataIO_clusterAsioTcpIostream::reportAsReadyToSwap()
 {
-        OSG_NOTIFY( osg::INFO ) << "clusterAsioTcpIostream reportAsReadyToSwap()" << std::endl;
+        OSG_NOTIFY(osg::INFO) << "dataIO_clusterAsioTcpIostream::reportAsReadyToSwap()" << std::endl;
 }
 
 bool dataIO_clusterAsioTcpIostream::waitForSwap()
 {
-        OSG_NOTIFY( osg::INFO ) << "clusterAsioTcpIostream waitForSwap()" << std::endl;
+        OSG_NOTIFY(osg::INFO) << "dataIO_clusterAsioTcpIostream::waitForAllReadyToSwap()" << std::endl;
+
         return true;
 }
@@ -65 +106 @@
 bool dataIO_clusterAsioTcpIostream::waitForAllReadyToSwap()
 {
-        OSG_NOTIFY( osg::INFO ) << "clusterAsioTcpIostream waitForAllReadyToSwap()" << std::endl;
+        OSG_NOTIFY(osg::INFO) << "dataIO_clusterAsioTcpIostream::waitForAllReadyToSwap()" << std::endl;
+
         return true;
 }
@@ -71 +113 @@
 bool dataIO_clusterAsioTcpIostream::sendSwapCommand()
 {
-        OSG_NOTIFY( osg::INFO ) << "clusterAsioTcpIostream sendSwapCommand()" << std::endl;
+        OSG_NOTIFY(osg::INFO) << "dataIO_clusterAsioTcpIostream::sendSwapCommand()" << std::endl;
+
         return true;
 }