gem5
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Groups Pages
tcp_iface.hh
Go to the documentation of this file.
1 /*
2  * Copyright (c) 2015 ARM Limited
3  * All rights reserved
4  *
5  * The license below extends only to copyright in the software and shall
6  * not be construed as granting a license to any other intellectual
7  * property including but not limited to intellectual property relating
8  * to a hardware implementation of the functionality of the software
9  * licensed hereunder. You may use the software subject to the license
10  * terms below provided that you ensure that this notice is replicated
11  * unmodified and in its entirety in all distributions of the software,
12  * modified or unmodified, in source code or in binary form.
13  *
14  * Redistribution and use in source and binary forms, with or without
15  * modification, are permitted provided that the following conditions are
16  * met: redistributions of source code must retain the above copyright
17  * notice, this list of conditions and the following disclaimer;
18  * redistributions in binary form must reproduce the above copyright
19  * notice, this list of conditions and the following disclaimer in the
20  * documentation and/or other materials provided with the distribution;
21  * neither the name of the copyright holders nor the names of its
22  * contributors may be used to endorse or promote products derived from
23  * this software without specific prior written permission.
24  *
25  * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
26  * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
27  * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
28  * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
29  * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
30  * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
31  * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
32  * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
33  * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
34  * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
35  * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
36  *
37  * Authors: Gabor Dozsa
38  * Mohammad Alian
39  */
40 
41 /* @file
42  * TCP stream socket based interface class for dist-gem5 runs.
43  *
44  * For a high level description about dist-gem5 see comments in
45  * header file dist_iface.hh.
46  *
47  * Each gem5 process connects to the server (another gem5 process which
48  * simulates a switch box) via a stream socket. The server process
49  * transfers messages and co-ordinates the synchronisation among the gem5
50  * peers.
51  */
52 #ifndef __DEV_NET_TCP_IFACE_HH__
53 #define __DEV_NET_TCP_IFACE_HH__
54 
55 
56 #include <string>
57 
58 #include "dev/net/dist_iface.hh"
59 
60 class EventManager;
61 
62 class TCPIface : public DistIface
63 {
64  private:
68  int sock;
69 
70  std::string serverName;
72 
73  bool isSwitch;
74 
75  bool listening;
76  static bool anyListening;
77  static int fdStatic;
78 
83  struct NodeInfo
84  {
85  unsigned rank;
86  unsigned distIfaceId;
87  unsigned distIfaceNum;
88  };
94 
95  private:
96 
104  void
105  sendTCP(int sock, const void *buf, unsigned length);
106 
114  bool recvTCP(int sock, void *buf, unsigned length);
115  bool listen(int port);
116  void accept();
117  void connect();
118  int getfdStatic() const { return fdStatic; }
119  bool islistening() const { return listening; }
120  bool anyislistening() const { return anyListening; }
121  void establishConnection();
122 
123  protected:
124 
125  void sendPacket(const Header &header,
126  const EthPacketPtr &packet) override;
127 
128  void sendCmd(const Header &header) override;
129 
130  bool recvHeader(Header &header) override;
131 
132  void recvPacket(const Header &header, EthPacketPtr &packet) override;
133 
134  void initTransport() override;
135 
136  public:
148  TCPIface(std::string server_name, unsigned server_port,
149  unsigned dist_rank, unsigned dist_size,
150  Tick sync_start, Tick sync_repeat, EventManager *em,
151  bool use_pseudo_op, bool is_switch, int num_nodes);
152 
153  ~TCPIface() override;
154 };
155 
156 #endif // __DEV_NET_TCP_IFACE_HH__
std::string serverName
Definition: tcp_iface.hh:70
bool isSwitch
Definition: tcp_iface.hh:73
Bitfield< 2 > em
Definition: misc.hh:603
void initTransport() override
Init hook for the underlaying transport.
Definition: tcp_iface.cc:338
void sendCmd(const Header &header) override
Send out a control command to the remote end.
Definition: tcp_iface.cc:307
static bool anyListening
Definition: tcp_iface.hh:76
STL vector class.
Definition: stl.hh:40
bool listening
Definition: tcp_iface.hh:75
~TCPIface() override
Definition: tcp_iface.cc:255
TCPIface(std::string server_name, unsigned server_port, unsigned dist_rank, unsigned dist_size, Tick sync_start, Tick sync_repeat, EventManager *em, bool use_pseudo_op, bool is_switch, int num_nodes)
The ctor creates and connects the stream socket to the server.
Definition: tcp_iface.cc:82
uint64_t Tick
Tick count type.
Definition: types.hh:63
static int fdStatic
Definition: tcp_iface.hh:77
std::shared_ptr< EthPacketData > EthPacketPtr
Definition: etherpkt.hh:90
bool islistening() const
Definition: tcp_iface.hh:119
void recvPacket(const Header &header, EthPacketPtr &packet) override
Receive a packet from the remote end.
Definition: tcp_iface.cc:328
void sendTCP(int sock, const void *buf, unsigned length)
Send out a message through a TCP stream socket.
Definition: tcp_iface.cc:264
void connect()
Definition: tcp_iface.cc:222
static std::vector< int > sockRegistry
Storage for all opened sockets.
Definition: tcp_iface.hh:93
bool listen(int port)
Definition: tcp_iface.cc:115
void establishConnection()
Definition: tcp_iface.cc:152
bool recvTCP(int sock, void *buf, unsigned length)
Receive the next incoming message through a TCP stream socket.
Definition: tcp_iface.cc:281
bool recvHeader(Header &header) override
Receive a header (i.e.
Definition: tcp_iface.cc:319
bool anyislistening() const
Definition: tcp_iface.hh:120
DistHeaderPkt::Header Header
Definition: dist_iface.hh:104
void accept()
Definition: tcp_iface.cc:208
Compute node info and storage for the very first connection from each node (used by the switch) ...
Definition: tcp_iface.hh:83
unsigned distIfaceId
Definition: tcp_iface.hh:86
int sock
The stream socket to connect to the server.
Definition: tcp_iface.hh:68
static std::vector< std::pair< NodeInfo, int > > nodes
Definition: tcp_iface.hh:89
unsigned distIfaceNum
Definition: tcp_iface.hh:87
uint8_t length
Definition: inet.hh:334
The interface class to talk to peer gem5 processes.
Definition: dist_iface.hh:101
int getfdStatic() const
Definition: tcp_iface.hh:118
void sendPacket(const Header &header, const EthPacketPtr &packet) override
Send out a data packet to the remote end.
Definition: tcp_iface.cc:300
int serverPort
Definition: tcp_iface.hh:71

Generated on Fri Jun 9 2017 13:03:46 for gem5 by doxygen 1.8.6