Eclipse SUMO - Simulation of Urban MObility
OutputDevice_Network.cpp
Go to the documentation of this file.
1 /****************************************************************************/
2 // Eclipse SUMO, Simulation of Urban MObility; see https://eclipse.org/sumo
3 // Copyright (C) 2006-2020 German Aerospace Center (DLR) and others.
4 // This program and the accompanying materials are made available under the
5 // terms of the Eclipse Public License 2.0 which is available at
6 // https://www.eclipse.org/legal/epl-2.0/
7 // This Source Code may also be made available under the following Secondary
8 // Licenses when the conditions for such availability set forth in the Eclipse
9 // Public License 2.0 are satisfied: GNU General Public License, version 2
10 // or later which is available at
11 // https://www.gnu.org/licenses/old-licenses/gpl-2.0-standalone.html
12 // SPDX-License-Identifier: EPL-2.0 OR GPL-2.0-or-later
13 /****************************************************************************/
20 // An output device for TCP/IP Network connections
21 /****************************************************************************/
22 
23 
24 // ==========================================================================
25 // included modules
26 // ==========================================================================
27 #include <config.h>
28 
29 #include <thread>
30 #include <chrono>
31 #include <vector>
32 #include "OutputDevice_Network.h"
33 #include "foreign/tcpip/socket.h"
34 #include "utils/common/ToString.h"
35 
36 
37 // ==========================================================================
38 // method definitions
39 // ==========================================================================
41  const int port) {
42  mySocket = new tcpip::Socket(host, port);
43 #ifdef _MSC_VER
44 #pragma warning(push)
45 #pragma warning(disable: 4127) // do not warn about constant conditional expression
46 #endif
47  for (int wait = 1000; true; wait += 1000) {
48 #ifdef _MSC_VER
49 #pragma warning(pop)
50 #endif
51  try {
52  mySocket->connect();
53  break;
54  } catch (tcpip::SocketException& e) {
55  if (wait == 9000) {
56  throw IOError(toString(e.what()) + " (host: " + host + ", port: " + toString(port) + ")");
57  }
58  std::this_thread::sleep_for(std::chrono::milliseconds(wait));
59  }
60  }
61  myFilename = host + ":" + toString(port);
62 }
63 
64 
66  mySocket->close();
67  delete mySocket;
68 }
69 
70 
71 std::ostream&
73  return myMessage;
74 }
75 
76 
77 void
79  std::string toSend = myMessage.str();
80  std::vector<unsigned char> msg;
81  msg.insert(msg.end(), toSend.begin(), toSend.end());
82  try {
83  mySocket->send(msg);
84  } catch (tcpip::SocketException& e) {
85  throw IOError(toString(e.what()));
86  }
87  myMessage.str("");
88 }
89 
90 
91 /****************************************************************************/
std::string toString(const T &t, std::streamsize accuracy=gPrecision)
Definition: ToString.h:44
OutputDevice_Network(const std::string &host, const int port)
Constructor.
tcpip::Socket * mySocket
the socket to transfer the data
std::ostringstream myMessage
packet buffer
std::ostream & getOStream()
Returns the associated ostream.
virtual void postWriteHook()
Sends the data which was written to the string stream over the socket.
std::string myFilename
Definition: OutputDevice.h:333
void connect()
Connects to host_:port_.
Definition: socket.cpp:358
void send(const std::vector< unsigned char > &buffer)
Definition: socket.cpp:400
void close()
Definition: socket.cpp:382