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

Last change on this file since 6900 was 6894, checked in by Christoph Mayer, 15 years ago

-visual stuff

File size: 4.0 KB
Line 
1// [License]
2// The Ariba-Underlay Copyright
3//
4// Copyright (c) 2008-2009, Institute of Telematics, UniversitÀt Karlsruhe (TH)
5//
6// Institute of Telematics
7// UniversitÀt Karlsruhe (TH)
8// Zirkel 2, 76128 Karlsruhe
9// Germany
10//
11// Redistribution and use in source and binary forms, with or without
12// modification, are permitted provided that the following conditions are
13// met:
14//
15// 1. Redistributions of source code must retain the above copyright
16// notice, this list of conditions and the following disclaimer.
17// 2. Redistributions in binary form must reproduce the above copyright
18// notice, this list of conditions and the following disclaimer in the
19// documentation and/or other materials provided with the distribution.
20//
21// THIS SOFTWARE IS PROVIDED BY THE INSTITUTE OF TELEMATICS ``AS IS'' AND
22// ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
23// IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
24// PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE ARIBA PROJECT OR
25// CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
26// EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
27// PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
28// PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
29// LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
30// NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
31// SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
32//
33// The views and conclusions contained in the software and documentation
34// are those of the authors and should not be interpreted as representing
35// official policies, either expressed or implied, of the Institute of
36// Telematics.
37// [License]
38
39#include "ServerVis.h"
40
41namespace ariba {
42namespace utility {
43
44use_logging_cpp(ServerVis);
45
46typedef enum _NETWORK_ID {
47 NETWORK_ID_BASE_COMMUNICATION = 1,
48 NETWORK_ID_BASE_OVERLAY = 2,
49 NETWORK_ID_EONSON = 3,
50 NETWORK_ID_MCPO = 4,
51 NETWORK_ID_CLIO = 5,
52 NETWORK_ID_VIDEOSTREAM = 6,
53 NETWORK_ID_GAME = 7,
54 NETWORK_ID_SECURITY = 8,
55} NETWORK_ID;
56
57string ServerVis::getNetworkName(NETWORK_ID network) const {
58 switch(network){
59 case NETWORK_ID_BASE_COMMUNICATION : return "BaseCommunication";
60 case NETWORK_ID_BASE_OVERLAY : return "BaseOverlay";
61 case NETWORK_ID_EONSON : return "Eonson";
62 case NETWORK_ID_MCPO : return "MCPO";
63 case NETWORK_ID_CLIO : return "CLIO";
64 case NETWORK_ID_VIDEOSTREAM : return "Video";
65 case NETWORK_ID_GAME : return "Game";
66 case NETWORK_ID_SECURITY : return "Security";
67 default : return "<undefined>";
68 }
69}
70
71void ServerVis::configure(string ip, unsigned int port){
72 if( ip.length() == 0 ) return;
73
74 ostringstream sport;
75 sport << port;
76 logging_debug( "connecting to visualization server " << ip << " on " << sport.str());
77
78 tcp::resolver resolver(io_service);
79 tcp::resolver::query query(
80 ip, sport.str(),
81 tcp::resolver::query::passive |
82 tcp::resolver::query::address_configured |
83 tcp::resolver::query::numeric_service);
84
85 tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);
86 tcp::resolver::iterator end;
87
88 boost::system::error_code error = boost::asio::error::host_not_found;
89 while (error && endpoint_iterator != end){
90 socket.close();
91 socket.connect(*endpoint_iterator++, error);
92 }
93
94 if (error){
95 logging_warn( "visualization could not connect to visualization server" );
96 } else {
97 logging_info( "connected to visualization server on " << ip << ":" << port );
98 socketOpened = true;
99 }
100}
101
102ServerVis::ServerVis() : socket(io_service), socketOpened(false) {
103}
104
105ServerVis::~ServerVis(){
106 socket.close();
107}
108
109void ServerVis::sendSocket(const string& msg){
110 if( socket.is_open()==false || socketOpened==false ) return;
111 logging_debug("sending visual command: " << msg);
112
113 try{
114 socket.send( boost::asio::buffer(msg) );
115 }catch( std::exception& e ){
116 logging_warn("visual connection failed");
117 socket.close();
118 socketOpened = false;
119 }
120}
121
122}} // namespace ariba, common
Note: See TracBrowser for help on using the repository browser.