source: source/ariba/utility/visual/ServerVis.cpp@ 12766

// [License]
// The Ariba-Underlay Copyright
//
// Copyright (c) 2008-2009, Institute of Telematics, UniversitÀt Karlsruhe (TH)
//
// Institute of Telematics
// UniversitÀt Karlsruhe (TH)
// Zirkel 2, 76128 Karlsruhe
// Germany
//
// Redistribution and use in source and binary forms, with or without
// modification, are permitted provided that the following conditions are
// met:
//
// 1. Redistributions of source code must retain the above copyright
// notice, this list of conditions and the following disclaimer.
// 2. Redistributions in binary form must reproduce the above copyright
// notice, this list of conditions and the following disclaimer in the
// documentation and/or other materials provided with the distribution.
//
// THIS SOFTWARE IS PROVIDED BY THE INSTITUTE OF TELEMATICS ``AS IS'' AND
// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
// IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
// PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE ARIBA PROJECT OR
// CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
// EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
// PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
// PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
// LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
// NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
//
// The views and conclusions contained in the software and documentation
// are those of the authors and should not be interpreted as representing
// official policies, either expressed or implied, of the Institute of
// Telematics.
// [License]

#include "ServerVis.h"

namespace ariba {
namespace utility {

use_logging_cpp(ServerVis);
unsigned int ServerVis::nodecolor = 0;

typedef enum _NETWORK_ID {
        NETWORK_ID_BASE_COMMUNICATION   = 1,
                        NETWORK_ID_BASE_OVERLAY                 = 2,
                        NETWORK_ID_EONSON                               = 3,
                        NETWORK_ID_MCPO                                 = 4,
                        NETWORK_ID_CLIO                                 = 5,
                        NETWORK_ID_VIDEOSTREAM                  = 6,
                        NETWORK_ID_GAME                                 = 7,
                        NETWORK_ID_SECURITY                     = 8,
} NETWORK_ID;

string ServerVis::getNetworkName(NETWORK_ID network) const {
        switch(network){
                case NETWORK_ID_BASE_COMMUNICATION      : return "BaseCommunication";
                case NETWORK_ID_BASE_OVERLAY            : return "BaseOverlay";
                case NETWORK_ID_EONSON                          : return "Eonson";
                case NETWORK_ID_MCPO                            : return "MCPO";
                case NETWORK_ID_CLIO                            : return "CLIO";
                case NETWORK_ID_VIDEOSTREAM             : return "Video";
                case NETWORK_ID_GAME                            : return "Game";
                case NETWORK_ID_SECURITY                        : return "Security";
                default                                                         : return "<undefined>";
        }
}

void ServerVis::configure(string ip, unsigned int port, unsigned int _color){
        nodecolor = _color;
        if( ip.length() == 0 ) return;

        ostringstream sport;
        sport << port;
        logging_debug( "connecting to visualization server " << ip << " on " << sport.str());

        tcp::resolver resolver(io_service);
        tcp::resolver::query query(
                        ip, sport.str(),
                        tcp::resolver::query::passive |
                        tcp::resolver::query::address_configured |
                        tcp::resolver::query::numeric_service);

        tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);
        tcp::resolver::iterator end;

        boost::system::error_code error = boost::asio::error::host_not_found;
        while (error && endpoint_iterator != end){
                socket.close();
                socket.connect(*endpoint_iterator++, error);
        }

        if (error){
                logging_warn( "visualization could not connect to visualization server" );
        } else {
                logging_info( "connected to visualization server on " << ip << ":" << port );
                socketOpened = true;
        }
}

ServerVis::ServerVis() : socket(io_service), socketOpened(false) {
}

ServerVis::~ServerVis(){
        socket.close();
}

void ServerVis::sendSocket(const string& msg){
        if( socket.is_open()==false || socketOpened==false ) return;
        logging_debug("sending visual command: " << msg);

        try{
                socket.send( boost::asio::buffer(msg) );
        }catch( std::exception& e ){
                logging_warn("visual connection failed");
                socket.close();
                socketOpened = false;
        }
}

}} // namespace ariba, common