Changeset 59


Ignore:
Timestamp:
May 30, 2010, 7:50:59 PM (14 years ago)
Author:
Torben Dannhauer
Message:

updated cluster functionality to allow build with any cluster module selected.

Location:
osgVisual
Files:
8 edited

Legend:

Unmodified
Added
Removed

  • osgVisual/include/cluster/dataIO_cluster.h

    r32 r59  
    3838public:
    3939        /**
     40         * This enum defines the three modi of the cluster engine.
     41         */
     42        enum clustermode {MASTER, SLAVE, STANDALONE};
     43
     44        /**
    4045         * \brief Empty constructor.
    4146         *
    … …  
    5459         *
    5560         */
    56         virtual void init( osg::ArgumentParser& arguments_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ ) = 0;
     61        virtual void init( osg::ArgumentParser& arguments_, clustermode clusterMode_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ ) = 0;
    5762
    5863
    … …  
    109114        virtual bool sendSwapCommand() = 0;
    110115
    111         /**
    112          * This enum defines the three modi of the cluster engine.
    113          */
    114         enum clustermode {MASTER, SLAVE, STANDALONE};
    115 
    116116
    117117

  • osgVisual/include/cluster/dataIO_clusterAsioTcpIostream.h

    r58 r59  
    2727        virtual ~dataIO_clusterAsioTcpIostream(void);
    2828
    29         virtual void init( osg::ArgumentParser& arguments_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ );
     29        virtual void init( osg::ArgumentParser& arguments_, clustermode clusterMode_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ );
    3030        virtual void shutdown();
    3131        virtual bool sendTO_OBJvaluesToSlaves() ;

  • osgVisual/include/cluster/dataIO_clusterDummy.h

    r32 r59  
    3838        virtual ~dataIO_clusterDummy(void);
    3939
    40         void init( osg::ArgumentParser& arguments_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ );
     40        void init( osg::ArgumentParser& arguments_, clustermode clusterMode_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ );
    4141        void shutdown();
    4242

  • osgVisual/include/cluster/dataIO_clusterUDP.h

    r57 r59  
    4848        virtual ~dataIO_clusterUDP(void);
    4949
    50         void init( osg::ArgumentParser& arguments_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ );
     50        void init( osg::ArgumentParser& arguments_, clustermode clusterMode_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ );
    5151        void shutdown();
    5252

  • osgVisual/src/cluster/dataIO_clusterAsioTcpIostream.cpp

    r58 r59  
    2121dataIO_clusterAsioTcpIostream::dataIO_clusterAsioTcpIostream()
    2222{
     23        OSG_NOTIFY( osg::ALWAYS ) << "clusterAsioTcpIostream constructed" << std::endl;
    2324}
    2425
    2526dataIO_clusterAsioTcpIostream::~dataIO_clusterAsioTcpIostream(void)
    2627{
     28        OSG_NOTIFY( osg::ALWAYS ) << "clusterAsioTcpIostream destructed" << std::endl;
    2729}
    2830
    29 void dataIO_clusterAsioTcpIostream::init( osg::ArgumentParser& arguments_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ )
     31void dataIO_clusterAsioTcpIostream::init( osg::ArgumentParser& arguments_, clustermode clusterMode_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ )
    3032{
    31 
     33        OSG_NOTIFY( osg::ALWAYS ) << "clusterAsioTcpIostream init()" << std::endl;
    3234}
    3335
    3436void dataIO_clusterAsioTcpIostream::shutdown()
    3537{
    36 
     38        OSG_NOTIFY( osg::ALWAYS ) << "clusterAsioTcpIostream shutdown()" << std::endl;
    3739}
    3840
    3941bool dataIO_clusterAsioTcpIostream::sendTO_OBJvaluesToSlaves()
    4042{
    41 
     43        OSG_NOTIFY( osg::INFO ) << "clusterAsioTcpIostream sendTO_OBJvaluesToSlaves()" << std::endl;
    4244        return true;
    4345}
    … …  
    4547bool dataIO_clusterAsioTcpIostream::readTO_OBJvaluesFromMaster()
    4648{
     49        OSG_NOTIFY( osg::INFO ) << "clusterAsioTcpIostream readTO_OBJvaluesFromMaster()" << std::endl;
    4750
    4851        return true;
    … …  
    5154void dataIO_clusterAsioTcpIostream::reportAsReadyToSwap()
    5255{
    53 
     56        OSG_NOTIFY( osg::INFO ) << "clusterAsioTcpIostream reportAsReadyToSwap()" << std::endl;
    5457}
    5558
    5659bool dataIO_clusterAsioTcpIostream::waitForSwap()
    5760{
    58 
     61        OSG_NOTIFY( osg::INFO ) << "clusterAsioTcpIostream waitForSwap()" << std::endl;
    5962        return true;
    6063}
    … …  
    6265bool dataIO_clusterAsioTcpIostream::waitForAllReadyToSwap()
    6366{
    64 
     67        OSG_NOTIFY( osg::INFO ) << "clusterAsioTcpIostream waitForAllReadyToSwap()" << std::endl;
    6568        return true;
    6669}
    … …  
    6871bool dataIO_clusterAsioTcpIostream::sendSwapCommand()
    6972{
    70 
     73        OSG_NOTIFY( osg::INFO ) << "clusterAsioTcpIostream sendSwapCommand()" << std::endl;
    7174        return true;
    7275}

  • osgVisual/src/cluster/dataIO_clusterDummy.cpp

    r31 r59  
    1717#include "dataIO_clusterDummy.h"
    1818
    19 #include "memoryLeakDetection.h"
     19using namespace osgVisual;
    2020
    2121dataIO_clusterDummy::dataIO_clusterDummy()
    … …  
    2929}
    3030
    31 void dataIO_clusterDummy::init( osg::ArgumentParser& arguments_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ )
     31void dataIO_clusterDummy::init( osg::ArgumentParser& arguments_, clustermode clusterMode_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ )
    3232{
    3333        sendContainer = sendContainer_;

  • osgVisual/src/cluster/dataIO_clusterUDP.cpp

    r31 r59  
    3434}
    3535
    36 void dataIO_clusterUDP::init( osg::ArgumentParser& arguments_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ )
     36void dataIO_clusterUDP::init( osg::ArgumentParser& arguments_, osgVisual::dataIO_cluster::clustermode clusterMode_, osgVisual::dataIO_transportContainer* sendContainer_, bool compressionEnabled_, bool asAscii_ )
    3737{
    3838        // set Variables

  • osgVisual/src/dataIO/visual_dataIO.cpp

    r58 r59  
    7777                cluster = new dataIO_clusterUDP();
    7878        #endif
    79         cluster->init(arguments_, slotContainer, true, false);
     79        cluster->init(arguments_, clusterMode, slotContainer, true, false);
    8080
    8181        // Create extLink.
Note: See TracChangeset for help on using the changeset viewer.