summaryrefslogtreecommitdiffstats
path: root/include/Server.hpp
diff options
context:
space:
mode:
authorDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-15 18:20:54 +0000
committerDaniel Baumann <daniel.baumann@progress-linux.org>2024-04-15 18:20:54 +0000
commit7c720bec5600a9e607c875c670ca30ed351fa4ba (patch)
treec38c9bedf07616180feee6b91a1dbea038500b54 /include/Server.hpp
parentInitial commit. (diff)
downloadiperf-7c720bec5600a9e607c875c670ca30ed351fa4ba.tar.xz
iperf-7c720bec5600a9e607c875c670ca30ed351fa4ba.zip
Adding upstream version 2.1.9+dfsg.upstream/2.1.9+dfsg
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'include/Server.hpp')
-rw-r--r--include/Server.hpp127
1 files changed, 127 insertions, 0 deletions
diff --git a/include/Server.hpp b/include/Server.hpp
new file mode 100644
index 0000000..cca386a
--- /dev/null
+++ b/include/Server.hpp
@@ -0,0 +1,127 @@
+/*---------------------------------------------------------------
+ * Copyright (c) 1999,2000,2001,2002,2003
+ * The Board of Trustees of the University of Illinois
+ * All Rights Reserved.
+ *---------------------------------------------------------------
+ * Permission is hereby granted, free of charge, to any person
+ * obtaining a copy of this software (Iperf) and associated
+ * documentation files (the "Software"), to deal in the Software
+ * without restriction, including without limitation the
+ * rights to use, copy, modify, merge, publish, distribute,
+ * sublicense, and/or sell copies of the Software, and to permit
+ * persons to whom the Software is furnished to do
+ * so, subject to the following conditions:
+ *
+ *
+ * Redistributions of source code must retain the above
+ * copyright notice, this list of conditions and
+ * the following disclaimers.
+ *
+ *
+ * Redistributions in binary form must reproduce the above
+ * copyright notice, this list of conditions and the following
+ * disclaimers in the documentation and/or other materials
+ * provided with the distribution.
+ *
+ *
+ * Neither the names of the University of Illinois, NCSA,
+ * nor the names of its contributors may be used to endorse
+ * or promote products derived from this Software without
+ * specific prior written permission.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
+ * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES
+ * OF MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
+ * NONINFRINGEMENT. IN NO EVENT SHALL THE CONTIBUTORS OR COPYRIGHT
+ * HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY,
+ * WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE,
+ * ARISING FROM, OUT OF OR IN CONNECTION WITH THE
+ * SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ * ________________________________________________________________
+ * National Laboratory for Applied Network Research
+ * National Center for Supercomputing Applications
+ * University of Illinois at Urbana-Champaign
+ * http://www.ncsa.uiuc.edu
+ * ________________________________________________________________
+ *
+ * Server.hpp
+ * by Mark Gates <mgates@nlanr.net>
+ * -------------------------------------------------------------------
+ * A server thread is initiated for each connection accept() returns.
+ * Handles sending and receiving data, and then closes socket.
+ * ------------------------------------------------------------------- */
+
+#ifndef SERVER_H
+#define SERVER_H
+
+
+#include "Settings.hpp"
+#include "util.h"
+#include "Timestamp.hpp"
+
+/* ------------------------------------------------------------------- */
+class Server {
+public:
+ // stores server socket, port and TCP/UDP mode
+ Server(thread_Settings *inSettings);
+
+ // destroy the server object
+ ~Server();
+
+ // accepts connection and receives data
+ void RunUDP(void);
+ void RunTCP(void);
+ void RunBounceBackTCP(void);
+ static void Sig_Int(int inSigno);
+
+private:
+ thread_Settings *mSettings;
+ Timestamp mEndTime;
+ Timestamp now;
+ ReportStruct scratchpad;
+ ReportStruct *reportstruct;
+
+ void InitKernelTimeStamping(void);
+ bool InitTrafficLoop(void);
+ inline void SetFullDuplexReportStartTime(void);
+ inline void SetReportStartTime();
+ bool ReadBBWithRXTimestamp ();
+ int ReadWithRxTimestamp(void);
+ bool ReadPacketID(int);
+ void L2_processing(void);
+ int L2_quintuple_filter(void);
+ void udp_isoch_processing(int);
+ bool InProgress(void);
+ int SkipFirstPayload(void);
+ void ClientReverseFirstRead(void);
+ void PostNullEvent(void);
+ Timestamp connect_done;
+ bool peerclose;
+ bool isburst;
+#if WIN32
+ SOCKET mySocket;
+ SOCKET myDropSocket;
+#else
+ int mySocket;
+ int myDropSocket;
+#endif
+ struct ReportHeader *myJob;
+ struct ReporterData *myReport;
+
+#if HAVE_DECL_SO_TIMESTAMP
+ // Structures needed for recvmsg
+ // Use to get kernel timestamps of packets
+ struct sockaddr_storage srcaddr;
+ struct iovec iov[1];
+ struct msghdr message;
+ char ctrl[CMSG_SPACE(sizeof(struct timeval))];
+ struct cmsghdr *cmsg;
+#endif
+#if defined(HAVE_LINUX_FILTER_H) && defined(HAVE_AF_PACKET)
+ struct ether_header *eth_hdr;
+ struct iphdr *ip_hdr;
+ struct udphdr *udp_hdr;
+#endif
+}; // end class Server
+
+#endif // SERVER_H