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

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

-listener sanity checks

File size: 3.9 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
46
47typedef enum _NETWORK_ID {
48 NETWORK_ID_BASE_COMMUNICATION = 1,
49 NETWORK_ID_BASE_OVERLAY = 2,
50 NETWORK_ID_EONSON = 3,
51 NETWORK_ID_MCPO = 4,
52 NETWORK_ID_CLIO = 5,
53 NETWORK_ID_VIDEOSTREAM = 6,
54 NETWORK_ID_GAME = 7,
55 NETWORK_ID_SECURITY = 8,
56} NETWORK_ID;
57
58string ServerVis::getNetworkName(NETWORK_ID network) const {
59 switch(network){
60 case NETWORK_ID_BASE_COMMUNICATION : return "BaseCommunication";
61 case NETWORK_ID_BASE_OVERLAY : return "BaseOverlay";
62 case NETWORK_ID_EONSON : return "Eonson";
63 case NETWORK_ID_MCPO : return "Multicast/Multipeer Overlay";
64 case NETWORK_ID_CLIO : return "CLIO";
65 case NETWORK_ID_VIDEOSTREAM : return "Video";
66 case NETWORK_ID_GAME : return "Game";
67 case NETWORK_ID_SECURITY : return "Security";
68 default : return "<undefined>";
69 }
70}
71
72void ServerVis::configure(string ip, unsigned int port){
73 if( ip.length() == 0 ) return;
74
75 ostringstream sport;
76 sport << port;
77 logging_debug( "connecting to visualization server " << ip << " on " << sport.str());
78
79 tcp::resolver resolver(io_service);
80 tcp::resolver::query query(
81 ip, sport.str(),
82 tcp::resolver::query::passive |
83 tcp::resolver::query::address_configured |
84 tcp::resolver::query::numeric_service);
85
86 tcp::resolver::iterator endpoint_iterator = resolver.resolve(query);
87 tcp::resolver::iterator end;
88
89 boost::system::error_code error = boost::asio::error::host_not_found;
90 while (error && endpoint_iterator != end){
91 socket.close();
92 socket.connect(*endpoint_iterator++, error);
93 }
94
95 if (error){
96 logging_warn( "visualization could not connect to visualization server" );
97 } else {
98 logging_info( "connected to visualization server on " << ip << ":" << port );
99 socketOpened = true;
100 }
101}
102
103ServerVis::ServerVis() : socket(io_service), socketOpened(false) {
104}
105
106ServerVis::~ServerVis(){
107 socket.close();
108}
109
110void ServerVis::sendSocket(const string& msg){
111 if( socket.is_open() && socketOpened ){
112 logging_debug("sending visual command: " << msg);
113 socket.send( boost::asio::buffer(msg) );
114 }
115}
116
117}} // namespace ariba, common
Note: See TracBrowser for help on using the repository browser.