/* * Copyright (c) 2017 Cisco and/or its affiliates. * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at: * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ #include #include #include #include #include #include #include int main (int argc, char *argv[]) { int sockfd, portno, n; struct sockaddr_in serv_addr; struct hostent *server; u8 *rx_buffer = 0, *tx_buffer = 0, no_echo = 0, test_bytes = 0; u32 offset; long bytes = 1 << 20, to_send; int i; struct timeval start, end; double deltat; if (argc >= 3) { portno = atoi (argv[2]); server = gethostbyname (argv[1]); if (server == NULL) { clib_unix_warning ("gethostbyname"); exit (1); } argc -= 3; argv += 3; if (argc) { bytes = ((long) atoi (argv[0])) << 20; argc--; argv++; } if (argc) { no_echo = atoi (argv[0]); argc--; argv++; } if (argc) { test_bytes = atoi (argv[0]); argc--; argv++; } } else { portno = 1234; // atoi(argv[2]); server = gethostbyname ("6.0.1.1" /* argv[1] */ ); if (server == NULL) { clib_unix_warning ("gethostbyname"); exit (1); } } to_send = bytes; sockfd = socket (AF_INET, SOCK_STREAM, 0); if (sockfd < 0) { clib_unix_error ("socket"); exit (1); } bzero ((char *) &serv_addr, sizeof (serv_addr)); serv_addr.sin_family = AF_INET; bcopy ((char *) server->h_addr, (char *) &serv_addr.sin_addr.s_addr, server->h_length); serv_addr.sin_port = htons (portno); if (connect (sockfd, (const void *) &serv_addr, sizeof (serv_addr)) < 0) { clib_unix_warning ("connect"); exit (1); } vec_validate (rx_buffer, 128 << 10); vec_validate (tx_buffer, 128 << 10); for (i = 0; i < vec_len (tx_buffer); i++) tx_buffer[i] = (i + 1) % 0xff; /* * Send one packet to warm up the RX pipeline */ n = send (sockfd, tx_buffer, vec_len (tx_buffer), 0 /* flags */ ); if (n != vec_len (tx_buffer)) { clib_unix_warning ("write"); exit (0); } gettimeofday (&start, NULL); while (bytes > 0) { /* * TX */ n = send (sockfd, tx_buffer, vec_len (tx_buffer), 0 /* flags */ ); if (n != vec_len (tx_buffer)) { clib_unix_warning ("write"); exit (0); } bytes -= n; if (no_echo) continue; /* * RX */ offset = 0; do { n = recv (sockfd, rx_buffer + offset, vec_len (rx_buffer) - offset, 0 /* flags */ ); if (n < 0) { clib_unix_warning ("read"); exit (0); } offset += n; } while (offset < vec_len (rx_buffer)); if (test_bytes) { for (i = 0; i < vec_len (rx_buffer); i++) { if (rx_buffer[i] != tx_buffer[i]) { clib_warning ("[%d] read 0x%x not 0x%x", rx_buffer[i], tx_buffer[i]); exit (1); } } } } close (sockfd); gettimeofday (&end, NULL); deltat = (end.tv_sec - start.tv_sec); deltat += (end.tv_usec - start.tv_usec) / 1000000.0; // us to ms clib_warning ("Finished in %.6f", deltat); clib_warning ("%.4f Gbit/second %s", (((f64) to_send * 8.0) / deltat / 1e9), no_echo ? "half" : "full"); return 0; } /* * fd.io coding-style-patch-verification: ON * * Local Variables: * eval: (c-set-style "gnu") * End: */