Changeset 62 for osgVisual/include/cluster

Timestamp:

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

Author:

Torben Dannhauer

Message:

 

File:

• osgVisual/include/cluster/dataIO_clusterAsioTcpIostream.h (modified) (1 diff)

osgVisual/include/cluster/dataIO_clusterAsioTcpIostream.h

@@ -18 +18 @@
 #include "dataIO_cluster.h"
 
+#include <osg/notify>
+#include <osg/ArgumentParser>
+
+#include <iostream>
+#include <string>
+#include <vector>
+#include <boost/asio.hpp>
+#include <boost/date_time/posix_time/posix_time.hpp>
+
+
 namespace osgVisual
 {
 
-class dataIO_clusterAsioTcpIostream : public dataIO_cluster
+/**
+ * \brief This is a Boost ASIO iostream implementation of dataIO_cluster..
+ * 
+ * This class uses Boost ASIO and it iostream privider to fullfil the functions of dataIO_cluster.
+ * It sends the clusterdata into the network to any connected client.
+ * 
+ * 
+ * \todo Add getHorizonColor to transport it to slave for consistent fog.
+ * @author Torben Dannhauer
+ * @date  May 2010
+ */ 
+class dataIO_clusterAsioTcpIostream :   public dataIO_cluster
 {
+
 public:
+
         dataIO_clusterAsioTcpIostream();
-        virtual ~dataIO_clusterAsioTcpIostream(void);
+        virtual ~dataIO_clusterAsioTcpIostream();
 
-        virtual void init( osg::ArgumentParser& arguments_, clustermode clusterMode_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ );
-        virtual void shutdown();
-        virtual bool sendTO_OBJvaluesToSlaves() ;
-        virtual bool readTO_OBJvaluesFromMaster();
-        virtual void reportAsReadyToSwap();
-        virtual bool waitForSwap();
-        virtual bool waitForAllReadyToSwap();
-        virtual bool sendSwapCommand();
+        void init( osg::ArgumentParser& arguments_, clustermode clusterMode_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ );
+        void shutdown();
+        bool sendTO_OBJvaluesToSlaves();
+        bool readTO_OBJvaluesFromMaster();
+        void reportAsReadyToSwap();
+        bool waitForSwap();
+        bool waitForAllReadyToSwap();
+        bool sendSwapCommand();
+
+private:
+        osgVisual::dataIO_cluster::clustermode clusterMode;
+        bool initialized;
+        int port;       // Defaults to 5678 
+        
+        /**
+         * This list contains the connections to communicate with in each frame. 
+         * 
+         * As slave, contains only one entry: connection to master.
+         * As Master,contains the connection to all slaves which use this connection.
+         */ 
+        std::vector<boost::asio::ip::tcp::iostream> clientlists;
+
+        boost::asio::io_service io_service;
 };
 
-}       // END Namespace
+}       // END NAMESPACE