2 * Copyright (c) 2017 Cisco and/or its affiliates.
3 * Licensed under the Apache License, Version 2.0 (the "License");
4 * you may not use this file except in compliance with the License.
5 * You may obtain a copy of the License at:
7 * http://www.apache.org/licenses/LICENSE-2.0
9 * Unless required by applicable law or agreed to in writing, software
10 * distributed under the License is distributed on an "AS IS" BASIS,
11 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
12 * See the License for the specific language governing permissions and
13 * limitations under the License.
17 #include <sys/types.h>
18 #include <sys/socket.h>
19 #include <netinet/in.h>
21 #include <vppinfra/format.h>
25 main (int argc, char *argv[])
27 int sockfd, portno, n;
28 struct sockaddr_in serv_addr;
29 struct hostent *server;
30 u8 *rx_buffer = 0, *tx_buffer = 0, no_echo = 0, test_bytes = 0;
32 long bytes = 1 << 20, to_send;
34 struct timeval start, end;
39 portno = atoi (argv[2]);
40 server = gethostbyname (argv[1]);
43 clib_unix_warning ("gethostbyname");
52 bytes = ((long) atoi (argv[0])) << 20;
58 no_echo = atoi (argv[0]);
64 test_bytes = atoi (argv[0]);
71 portno = 1234; // atoi(argv[2]);
72 server = gethostbyname ("6.0.1.1" /* argv[1] */ );
75 clib_unix_warning ("gethostbyname");
81 sockfd = socket (AF_INET, SOCK_STREAM, 0);
84 clib_unix_error ("socket");
88 bzero ((char *) &serv_addr, sizeof (serv_addr));
89 serv_addr.sin_family = AF_INET;
90 bcopy ((char *) server->h_addr,
91 (char *) &serv_addr.sin_addr.s_addr, server->h_length);
92 serv_addr.sin_port = htons (portno);
93 if (connect (sockfd, (const void *) &serv_addr, sizeof (serv_addr)) < 0)
95 clib_unix_warning ("connect");
99 vec_validate (rx_buffer, 128 << 10);
100 vec_validate (tx_buffer, 128 << 10);
102 for (i = 0; i < vec_len (tx_buffer); i++)
103 tx_buffer[i] = (i + 1) % 0xff;
106 * Send one packet to warm up the RX pipeline
108 n = send (sockfd, tx_buffer, vec_len (tx_buffer), 0 /* flags */ );
109 if (n != vec_len (tx_buffer))
111 clib_unix_warning ("write");
115 gettimeofday (&start, NULL);
121 n = send (sockfd, tx_buffer, vec_len (tx_buffer), 0 /* flags */ );
122 if (n != vec_len (tx_buffer))
124 clib_unix_warning ("write");
139 n = recv (sockfd, rx_buffer + offset,
140 vec_len (rx_buffer) - offset, 0 /* flags */ );
143 clib_unix_warning ("read");
148 while (offset < vec_len (rx_buffer));
152 for (i = 0; i < vec_len (rx_buffer); i++)
154 if (rx_buffer[i] != tx_buffer[i])
156 clib_warning ("[%d] read 0x%x not 0x%x", rx_buffer[i],
164 gettimeofday (&end, NULL);
166 deltat = (end.tv_sec - start.tv_sec);
167 deltat += (end.tv_usec - start.tv_usec) / 1000000.0; // us to ms
168 clib_warning ("Finished in %.6f", deltat);
169 clib_warning ("%.4f Gbit/second %s", (((f64) to_send * 8.0) / deltat / 1e9),
170 no_echo ? "half" : "full");
176 * fd.io coding-style-patch-verification: ON
179 * eval: (c-set-style "gnu")