msg_zerocopy.c 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821
  1. /* Evaluate MSG_ZEROCOPY
  2. *
  3. * Send traffic between two processes over one of the supported
  4. * protocols and modes:
  5. *
  6. * PF_INET/PF_INET6
  7. * - SOCK_STREAM
  8. * - SOCK_DGRAM
  9. * - SOCK_DGRAM with UDP_CORK
  10. * - SOCK_RAW
  11. * - SOCK_RAW with IP_HDRINCL
  12. *
  13. * PF_PACKET
  14. * - SOCK_DGRAM
  15. * - SOCK_RAW
  16. *
  17. * PF_RDS
  18. * - SOCK_SEQPACKET
  19. *
  20. * Start this program on two connected hosts, one in send mode and
  21. * the other with option '-r' to put it in receiver mode.
  22. *
  23. * If zerocopy mode ('-z') is enabled, the sender will verify that
  24. * the kernel queues completions on the error queue for all zerocopy
  25. * transfers.
  26. */
  27. #define _GNU_SOURCE
  28. #include <arpa/inet.h>
  29. #include <error.h>
  30. #include <errno.h>
  31. #include <limits.h>
  32. #include <linux/errqueue.h>
  33. #include <linux/if_packet.h>
  34. #include <linux/ipv6.h>
  35. #include <linux/socket.h>
  36. #include <linux/sockios.h>
  37. #include <net/ethernet.h>
  38. #include <net/if.h>
  39. #include <netinet/ip.h>
  40. #include <netinet/ip6.h>
  41. #include <netinet/tcp.h>
  42. #include <netinet/udp.h>
  43. #include <poll.h>
  44. #include <sched.h>
  45. #include <stdbool.h>
  46. #include <stdio.h>
  47. #include <stdint.h>
  48. #include <stdlib.h>
  49. #include <string.h>
  50. #include <sys/ioctl.h>
  51. #include <sys/socket.h>
  52. #include <sys/stat.h>
  53. #include <sys/time.h>
  54. #include <sys/types.h>
  55. #include <sys/wait.h>
  56. #include <unistd.h>
  57. #include <linux/rds.h>
  58. #ifndef SO_EE_ORIGIN_ZEROCOPY
  59. #define SO_EE_ORIGIN_ZEROCOPY 5
  60. #endif
  61. #ifndef SO_ZEROCOPY
  62. #define SO_ZEROCOPY 60
  63. #endif
  64. #ifndef SO_EE_CODE_ZEROCOPY_COPIED
  65. #define SO_EE_CODE_ZEROCOPY_COPIED 1
  66. #endif
  67. #ifndef MSG_ZEROCOPY
  68. #define MSG_ZEROCOPY 0x4000000
  69. #endif
  70. static int cfg_cork;
  71. static bool cfg_cork_mixed;
  72. static int cfg_cpu = -1; /* default: pin to last cpu */
  73. static int cfg_family = PF_UNSPEC;
  74. static int cfg_ifindex = 1;
  75. static int cfg_payload_len;
  76. static int cfg_port = 8000;
  77. static bool cfg_rx;
  78. static int cfg_runtime_ms = 4200;
  79. static int cfg_verbose;
  80. static int cfg_waittime_ms = 500;
  81. static int cfg_notification_limit = 32;
  82. static bool cfg_zerocopy;
  83. static socklen_t cfg_alen;
  84. static struct sockaddr_storage cfg_dst_addr;
  85. static struct sockaddr_storage cfg_src_addr;
  86. static char payload[IP_MAXPACKET];
  87. static long packets, bytes, completions, expected_completions;
  88. static int zerocopied = -1;
  89. static uint32_t next_completion;
  90. static uint32_t sends_since_notify;
  91. static unsigned long gettimeofday_ms(void)
  92. {
  93. struct timeval tv;
  94. gettimeofday(&tv, NULL);
  95. return (tv.tv_sec * 1000) + (tv.tv_usec / 1000);
  96. }
  97. static uint16_t get_ip_csum(const uint16_t *start, int num_words)
  98. {
  99. unsigned long sum = 0;
  100. int i;
  101. for (i = 0; i < num_words; i++)
  102. sum += start[i];
  103. while (sum >> 16)
  104. sum = (sum & 0xFFFF) + (sum >> 16);
  105. return ~sum;
  106. }
  107. static int do_setcpu(int cpu)
  108. {
  109. cpu_set_t mask;
  110. CPU_ZERO(&mask);
  111. CPU_SET(cpu, &mask);
  112. if (sched_setaffinity(0, sizeof(mask), &mask))
  113. fprintf(stderr, "cpu: unable to pin, may increase variance.\n");
  114. else if (cfg_verbose)
  115. fprintf(stderr, "cpu: %u\n", cpu);
  116. return 0;
  117. }
  118. static void do_setsockopt(int fd, int level, int optname, int val)
  119. {
  120. if (setsockopt(fd, level, optname, &val, sizeof(val)))
  121. error(1, errno, "setsockopt %d.%d: %d", level, optname, val);
  122. }
  123. static int do_poll(int fd, int events)
  124. {
  125. struct pollfd pfd;
  126. int ret;
  127. pfd.events = events;
  128. pfd.revents = 0;
  129. pfd.fd = fd;
  130. ret = poll(&pfd, 1, cfg_waittime_ms);
  131. if (ret == -1)
  132. error(1, errno, "poll");
  133. return ret && (pfd.revents & events);
  134. }
  135. static int do_accept(int fd)
  136. {
  137. int fda = fd;
  138. fd = accept(fda, NULL, NULL);
  139. if (fd == -1)
  140. error(1, errno, "accept");
  141. if (close(fda))
  142. error(1, errno, "close listen sock");
  143. return fd;
  144. }
  145. static void add_zcopy_cookie(struct msghdr *msg, uint32_t cookie)
  146. {
  147. struct cmsghdr *cm;
  148. if (!msg->msg_control)
  149. error(1, errno, "NULL cookie");
  150. cm = (void *)msg->msg_control;
  151. cm->cmsg_len = CMSG_LEN(sizeof(cookie));
  152. cm->cmsg_level = SOL_RDS;
  153. cm->cmsg_type = RDS_CMSG_ZCOPY_COOKIE;
  154. memcpy(CMSG_DATA(cm), &cookie, sizeof(cookie));
  155. }
  156. static bool do_sendmsg(int fd, struct msghdr *msg, bool do_zerocopy, int domain)
  157. {
  158. int ret, len, i, flags;
  159. static uint32_t cookie;
  160. char ckbuf[CMSG_SPACE(sizeof(cookie))];
  161. len = 0;
  162. for (i = 0; i < msg->msg_iovlen; i++)
  163. len += msg->msg_iov[i].iov_len;
  164. flags = MSG_DONTWAIT;
  165. if (do_zerocopy) {
  166. flags |= MSG_ZEROCOPY;
  167. if (domain == PF_RDS) {
  168. memset(&msg->msg_control, 0, sizeof(msg->msg_control));
  169. msg->msg_controllen = CMSG_SPACE(sizeof(cookie));
  170. msg->msg_control = (struct cmsghdr *)ckbuf;
  171. add_zcopy_cookie(msg, ++cookie);
  172. }
  173. }
  174. ret = sendmsg(fd, msg, flags);
  175. if (ret == -1 && errno == EAGAIN)
  176. return false;
  177. if (ret == -1)
  178. error(1, errno, "send");
  179. if (cfg_verbose && ret != len)
  180. fprintf(stderr, "send: ret=%u != %u\n", ret, len);
  181. sends_since_notify++;
  182. if (len) {
  183. packets++;
  184. bytes += ret;
  185. if (do_zerocopy && ret)
  186. expected_completions++;
  187. }
  188. if (do_zerocopy && domain == PF_RDS) {
  189. msg->msg_control = NULL;
  190. msg->msg_controllen = 0;
  191. }
  192. return true;
  193. }
  194. static void do_sendmsg_corked(int fd, struct msghdr *msg)
  195. {
  196. bool do_zerocopy = cfg_zerocopy;
  197. int i, payload_len, extra_len;
  198. /* split up the packet. for non-multiple, make first buffer longer */
  199. payload_len = cfg_payload_len / cfg_cork;
  200. extra_len = cfg_payload_len - (cfg_cork * payload_len);
  201. do_setsockopt(fd, IPPROTO_UDP, UDP_CORK, 1);
  202. for (i = 0; i < cfg_cork; i++) {
  203. /* in mixed-frags mode, alternate zerocopy and copy frags
  204. * start with non-zerocopy, to ensure attach later works
  205. */
  206. if (cfg_cork_mixed)
  207. do_zerocopy = (i & 1);
  208. msg->msg_iov[0].iov_len = payload_len + extra_len;
  209. extra_len = 0;
  210. do_sendmsg(fd, msg, do_zerocopy,
  211. (cfg_dst_addr.ss_family == AF_INET ?
  212. PF_INET : PF_INET6));
  213. }
  214. do_setsockopt(fd, IPPROTO_UDP, UDP_CORK, 0);
  215. }
  216. static int setup_iph(struct iphdr *iph, uint16_t payload_len)
  217. {
  218. struct sockaddr_in *daddr = (void *) &cfg_dst_addr;
  219. struct sockaddr_in *saddr = (void *) &cfg_src_addr;
  220. memset(iph, 0, sizeof(*iph));
  221. iph->version = 4;
  222. iph->tos = 0;
  223. iph->ihl = 5;
  224. iph->ttl = 2;
  225. iph->saddr = saddr->sin_addr.s_addr;
  226. iph->daddr = daddr->sin_addr.s_addr;
  227. iph->protocol = IPPROTO_EGP;
  228. iph->tot_len = htons(sizeof(*iph) + payload_len);
  229. iph->check = get_ip_csum((void *) iph, iph->ihl << 1);
  230. return sizeof(*iph);
  231. }
  232. static int setup_ip6h(struct ipv6hdr *ip6h, uint16_t payload_len)
  233. {
  234. struct sockaddr_in6 *daddr = (void *) &cfg_dst_addr;
  235. struct sockaddr_in6 *saddr = (void *) &cfg_src_addr;
  236. memset(ip6h, 0, sizeof(*ip6h));
  237. ip6h->version = 6;
  238. ip6h->payload_len = htons(payload_len);
  239. ip6h->nexthdr = IPPROTO_EGP;
  240. ip6h->hop_limit = 2;
  241. ip6h->saddr = saddr->sin6_addr;
  242. ip6h->daddr = daddr->sin6_addr;
  243. return sizeof(*ip6h);
  244. }
  245. static void setup_sockaddr(int domain, const char *str_addr,
  246. struct sockaddr_storage *sockaddr)
  247. {
  248. struct sockaddr_in6 *addr6 = (void *) sockaddr;
  249. struct sockaddr_in *addr4 = (void *) sockaddr;
  250. switch (domain) {
  251. case PF_INET:
  252. memset(addr4, 0, sizeof(*addr4));
  253. addr4->sin_family = AF_INET;
  254. addr4->sin_port = htons(cfg_port);
  255. if (str_addr &&
  256. inet_pton(AF_INET, str_addr, &(addr4->sin_addr)) != 1)
  257. error(1, 0, "ipv4 parse error: %s", str_addr);
  258. break;
  259. case PF_INET6:
  260. memset(addr6, 0, sizeof(*addr6));
  261. addr6->sin6_family = AF_INET6;
  262. addr6->sin6_port = htons(cfg_port);
  263. if (str_addr &&
  264. inet_pton(AF_INET6, str_addr, &(addr6->sin6_addr)) != 1)
  265. error(1, 0, "ipv6 parse error: %s", str_addr);
  266. break;
  267. default:
  268. error(1, 0, "illegal domain");
  269. }
  270. }
  271. static int do_setup_tx(int domain, int type, int protocol)
  272. {
  273. int fd;
  274. fd = socket(domain, type, protocol);
  275. if (fd == -1)
  276. error(1, errno, "socket t");
  277. do_setsockopt(fd, SOL_SOCKET, SO_SNDBUF, 1 << 21);
  278. if (cfg_zerocopy)
  279. do_setsockopt(fd, SOL_SOCKET, SO_ZEROCOPY, 1);
  280. if (domain != PF_PACKET && domain != PF_RDS)
  281. if (connect(fd, (void *) &cfg_dst_addr, cfg_alen))
  282. error(1, errno, "connect");
  283. if (domain == PF_RDS) {
  284. if (bind(fd, (void *) &cfg_src_addr, cfg_alen))
  285. error(1, errno, "bind");
  286. }
  287. return fd;
  288. }
  289. static uint32_t do_process_zerocopy_cookies(struct rds_zcopy_cookies *ck)
  290. {
  291. int i;
  292. if (ck->num > RDS_MAX_ZCOOKIES)
  293. error(1, 0, "Returned %d cookies, max expected %d\n",
  294. ck->num, RDS_MAX_ZCOOKIES);
  295. for (i = 0; i < ck->num; i++)
  296. if (cfg_verbose >= 2)
  297. fprintf(stderr, "%d\n", ck->cookies[i]);
  298. return ck->num;
  299. }
  300. static bool do_recvmsg_completion(int fd)
  301. {
  302. char cmsgbuf[CMSG_SPACE(sizeof(struct rds_zcopy_cookies))];
  303. struct rds_zcopy_cookies *ck;
  304. struct cmsghdr *cmsg;
  305. struct msghdr msg;
  306. bool ret = false;
  307. memset(&msg, 0, sizeof(msg));
  308. msg.msg_control = cmsgbuf;
  309. msg.msg_controllen = sizeof(cmsgbuf);
  310. if (recvmsg(fd, &msg, MSG_DONTWAIT))
  311. return ret;
  312. if (msg.msg_flags & MSG_CTRUNC)
  313. error(1, errno, "recvmsg notification: truncated");
  314. for (cmsg = CMSG_FIRSTHDR(&msg); cmsg; cmsg = CMSG_NXTHDR(&msg, cmsg)) {
  315. if (cmsg->cmsg_level == SOL_RDS &&
  316. cmsg->cmsg_type == RDS_CMSG_ZCOPY_COMPLETION) {
  317. ck = (struct rds_zcopy_cookies *)CMSG_DATA(cmsg);
  318. completions += do_process_zerocopy_cookies(ck);
  319. ret = true;
  320. break;
  321. }
  322. error(0, 0, "ignoring cmsg at level %d type %d\n",
  323. cmsg->cmsg_level, cmsg->cmsg_type);
  324. }
  325. return ret;
  326. }
  327. static bool do_recv_completion(int fd, int domain)
  328. {
  329. struct sock_extended_err *serr;
  330. struct msghdr msg = {};
  331. struct cmsghdr *cm;
  332. uint32_t hi, lo, range;
  333. int ret, zerocopy;
  334. char control[100];
  335. if (domain == PF_RDS)
  336. return do_recvmsg_completion(fd);
  337. msg.msg_control = control;
  338. msg.msg_controllen = sizeof(control);
  339. ret = recvmsg(fd, &msg, MSG_ERRQUEUE);
  340. if (ret == -1 && errno == EAGAIN)
  341. return false;
  342. if (ret == -1)
  343. error(1, errno, "recvmsg notification");
  344. if (msg.msg_flags & MSG_CTRUNC)
  345. error(1, errno, "recvmsg notification: truncated");
  346. cm = CMSG_FIRSTHDR(&msg);
  347. if (!cm)
  348. error(1, 0, "cmsg: no cmsg");
  349. if (!((cm->cmsg_level == SOL_IP && cm->cmsg_type == IP_RECVERR) ||
  350. (cm->cmsg_level == SOL_IPV6 && cm->cmsg_type == IPV6_RECVERR) ||
  351. (cm->cmsg_level == SOL_PACKET && cm->cmsg_type == PACKET_TX_TIMESTAMP)))
  352. error(1, 0, "serr: wrong type: %d.%d",
  353. cm->cmsg_level, cm->cmsg_type);
  354. serr = (void *) CMSG_DATA(cm);
  355. if (serr->ee_origin != SO_EE_ORIGIN_ZEROCOPY)
  356. error(1, 0, "serr: wrong origin: %u", serr->ee_origin);
  357. if (serr->ee_errno != 0)
  358. error(1, 0, "serr: wrong error code: %u", serr->ee_errno);
  359. hi = serr->ee_data;
  360. lo = serr->ee_info;
  361. range = hi - lo + 1;
  362. /* Detect notification gaps. These should not happen often, if at all.
  363. * Gaps can occur due to drops, reordering and retransmissions.
  364. */
  365. if (cfg_verbose && lo != next_completion)
  366. fprintf(stderr, "gap: %u..%u does not append to %u\n",
  367. lo, hi, next_completion);
  368. next_completion = hi + 1;
  369. zerocopy = !(serr->ee_code & SO_EE_CODE_ZEROCOPY_COPIED);
  370. if (zerocopied == -1)
  371. zerocopied = zerocopy;
  372. else if (zerocopied != zerocopy) {
  373. fprintf(stderr, "serr: inconsistent\n");
  374. zerocopied = zerocopy;
  375. }
  376. if (cfg_verbose >= 2)
  377. fprintf(stderr, "completed: %u (h=%u l=%u)\n",
  378. range, hi, lo);
  379. completions += range;
  380. return true;
  381. }
  382. /* Read all outstanding messages on the errqueue */
  383. static void do_recv_completions(int fd, int domain)
  384. {
  385. while (do_recv_completion(fd, domain)) {}
  386. sends_since_notify = 0;
  387. }
  388. /* Wait for all remaining completions on the errqueue */
  389. static void do_recv_remaining_completions(int fd, int domain)
  390. {
  391. int64_t tstop = gettimeofday_ms() + cfg_waittime_ms;
  392. while (completions < expected_completions &&
  393. gettimeofday_ms() < tstop) {
  394. if (do_poll(fd, domain == PF_RDS ? POLLIN : POLLERR))
  395. do_recv_completions(fd, domain);
  396. }
  397. if (completions < expected_completions)
  398. fprintf(stderr, "missing notifications: %lu < %lu\n",
  399. completions, expected_completions);
  400. }
  401. static void do_tx(int domain, int type, int protocol)
  402. {
  403. struct iovec iov[3] = { {0} };
  404. struct sockaddr_ll laddr;
  405. struct msghdr msg = {0};
  406. struct ethhdr eth;
  407. union {
  408. struct ipv6hdr ip6h;
  409. struct iphdr iph;
  410. } nh;
  411. uint64_t tstop;
  412. int fd;
  413. fd = do_setup_tx(domain, type, protocol);
  414. if (domain == PF_PACKET) {
  415. uint16_t proto = cfg_family == PF_INET ? ETH_P_IP : ETH_P_IPV6;
  416. /* sock_raw passes ll header as data */
  417. if (type == SOCK_RAW) {
  418. memset(eth.h_dest, 0x06, ETH_ALEN);
  419. memset(eth.h_source, 0x02, ETH_ALEN);
  420. eth.h_proto = htons(proto);
  421. iov[0].iov_base = &eth;
  422. iov[0].iov_len = sizeof(eth);
  423. msg.msg_iovlen++;
  424. }
  425. /* both sock_raw and sock_dgram expect name */
  426. memset(&laddr, 0, sizeof(laddr));
  427. laddr.sll_family = AF_PACKET;
  428. laddr.sll_ifindex = cfg_ifindex;
  429. laddr.sll_protocol = htons(proto);
  430. laddr.sll_halen = ETH_ALEN;
  431. memset(laddr.sll_addr, 0x06, ETH_ALEN);
  432. msg.msg_name = &laddr;
  433. msg.msg_namelen = sizeof(laddr);
  434. }
  435. /* packet and raw sockets with hdrincl must pass network header */
  436. if (domain == PF_PACKET || protocol == IPPROTO_RAW) {
  437. if (cfg_family == PF_INET)
  438. iov[1].iov_len = setup_iph(&nh.iph, cfg_payload_len);
  439. else
  440. iov[1].iov_len = setup_ip6h(&nh.ip6h, cfg_payload_len);
  441. iov[1].iov_base = (void *) &nh;
  442. msg.msg_iovlen++;
  443. }
  444. if (domain == PF_RDS) {
  445. msg.msg_name = &cfg_dst_addr;
  446. msg.msg_namelen = (cfg_dst_addr.ss_family == AF_INET ?
  447. sizeof(struct sockaddr_in) :
  448. sizeof(struct sockaddr_in6));
  449. }
  450. iov[2].iov_base = payload;
  451. iov[2].iov_len = cfg_payload_len;
  452. msg.msg_iovlen++;
  453. msg.msg_iov = &iov[3 - msg.msg_iovlen];
  454. tstop = gettimeofday_ms() + cfg_runtime_ms;
  455. do {
  456. if (cfg_cork)
  457. do_sendmsg_corked(fd, &msg);
  458. else
  459. do_sendmsg(fd, &msg, cfg_zerocopy, domain);
  460. if (cfg_zerocopy && sends_since_notify >= cfg_notification_limit)
  461. do_recv_completions(fd, domain);
  462. while (!do_poll(fd, POLLOUT)) {
  463. if (cfg_zerocopy)
  464. do_recv_completions(fd, domain);
  465. }
  466. } while (gettimeofday_ms() < tstop);
  467. if (cfg_zerocopy)
  468. do_recv_remaining_completions(fd, domain);
  469. if (close(fd))
  470. error(1, errno, "close");
  471. fprintf(stderr, "tx=%lu (%lu MB) txc=%lu zc=%c\n",
  472. packets, bytes >> 20, completions,
  473. zerocopied == 1 ? 'y' : 'n');
  474. }
  475. static int do_setup_rx(int domain, int type, int protocol)
  476. {
  477. int fd;
  478. /* If tx over PF_PACKET, rx over PF_INET(6)/SOCK_RAW,
  479. * to recv the only copy of the packet, not a clone
  480. */
  481. if (domain == PF_PACKET)
  482. error(1, 0, "Use PF_INET/SOCK_RAW to read");
  483. if (type == SOCK_RAW && protocol == IPPROTO_RAW)
  484. error(1, 0, "IPPROTO_RAW: not supported on Rx");
  485. fd = socket(domain, type, protocol);
  486. if (fd == -1)
  487. error(1, errno, "socket r");
  488. do_setsockopt(fd, SOL_SOCKET, SO_RCVBUF, 1 << 21);
  489. do_setsockopt(fd, SOL_SOCKET, SO_RCVLOWAT, 1 << 16);
  490. do_setsockopt(fd, SOL_SOCKET, SO_REUSEPORT, 1);
  491. if (bind(fd, (void *) &cfg_dst_addr, cfg_alen))
  492. error(1, errno, "bind");
  493. if (type == SOCK_STREAM) {
  494. if (listen(fd, 1))
  495. error(1, errno, "listen");
  496. fd = do_accept(fd);
  497. }
  498. return fd;
  499. }
  500. /* Flush all outstanding bytes for the tcp receive queue */
  501. static void do_flush_tcp(int fd)
  502. {
  503. int ret;
  504. /* MSG_TRUNC flushes up to len bytes */
  505. ret = recv(fd, NULL, 1 << 21, MSG_TRUNC | MSG_DONTWAIT);
  506. if (ret == -1 && errno == EAGAIN)
  507. return;
  508. if (ret == -1)
  509. error(1, errno, "flush");
  510. if (!ret)
  511. return;
  512. packets++;
  513. bytes += ret;
  514. }
  515. /* Flush all outstanding datagrams. Verify first few bytes of each. */
  516. static void do_flush_datagram(int fd, int type)
  517. {
  518. int ret, off = 0;
  519. char buf[64];
  520. /* MSG_TRUNC will return full datagram length */
  521. ret = recv(fd, buf, sizeof(buf), MSG_DONTWAIT | MSG_TRUNC);
  522. if (ret == -1 && errno == EAGAIN)
  523. return;
  524. /* raw ipv4 return with header, raw ipv6 without */
  525. if (cfg_family == PF_INET && type == SOCK_RAW) {
  526. off += sizeof(struct iphdr);
  527. ret -= sizeof(struct iphdr);
  528. }
  529. if (ret == -1)
  530. error(1, errno, "recv");
  531. if (ret != cfg_payload_len)
  532. error(1, 0, "recv: ret=%u != %u", ret, cfg_payload_len);
  533. if (ret > sizeof(buf) - off)
  534. ret = sizeof(buf) - off;
  535. if (memcmp(buf + off, payload, ret))
  536. error(1, 0, "recv: data mismatch");
  537. packets++;
  538. bytes += cfg_payload_len;
  539. }
  540. static void do_rx(int domain, int type, int protocol)
  541. {
  542. const int cfg_receiver_wait_ms = 400;
  543. uint64_t tstop;
  544. int fd;
  545. fd = do_setup_rx(domain, type, protocol);
  546. tstop = gettimeofday_ms() + cfg_runtime_ms + cfg_receiver_wait_ms;
  547. do {
  548. if (type == SOCK_STREAM)
  549. do_flush_tcp(fd);
  550. else
  551. do_flush_datagram(fd, type);
  552. do_poll(fd, POLLIN);
  553. } while (gettimeofday_ms() < tstop);
  554. if (close(fd))
  555. error(1, errno, "close");
  556. fprintf(stderr, "rx=%lu (%lu MB)\n", packets, bytes >> 20);
  557. }
  558. static void do_test(int domain, int type, int protocol)
  559. {
  560. int i;
  561. if (cfg_cork && (domain == PF_PACKET || type != SOCK_DGRAM))
  562. error(1, 0, "can only cork udp sockets");
  563. do_setcpu(cfg_cpu);
  564. for (i = 0; i < IP_MAXPACKET; i++)
  565. payload[i] = 'a' + (i % 26);
  566. if (cfg_rx)
  567. do_rx(domain, type, protocol);
  568. else
  569. do_tx(domain, type, protocol);
  570. }
  571. static void usage(const char *filepath)
  572. {
  573. error(1, 0, "Usage: %s [options] <test>", filepath);
  574. }
  575. static void parse_opts(int argc, char **argv)
  576. {
  577. const int max_payload_len = sizeof(payload) -
  578. sizeof(struct ipv6hdr) -
  579. sizeof(struct tcphdr) -
  580. 40 /* max tcp options */;
  581. int c;
  582. char *daddr = NULL, *saddr = NULL;
  583. char *cfg_test;
  584. cfg_payload_len = max_payload_len;
  585. while ((c = getopt(argc, argv, "46c:C:D:i:l:mp:rs:S:t:vz")) != -1) {
  586. switch (c) {
  587. case '4':
  588. if (cfg_family != PF_UNSPEC)
  589. error(1, 0, "Pass one of -4 or -6");
  590. cfg_family = PF_INET;
  591. cfg_alen = sizeof(struct sockaddr_in);
  592. break;
  593. case '6':
  594. if (cfg_family != PF_UNSPEC)
  595. error(1, 0, "Pass one of -4 or -6");
  596. cfg_family = PF_INET6;
  597. cfg_alen = sizeof(struct sockaddr_in6);
  598. break;
  599. case 'c':
  600. cfg_cork = strtol(optarg, NULL, 0);
  601. break;
  602. case 'C':
  603. cfg_cpu = strtol(optarg, NULL, 0);
  604. break;
  605. case 'D':
  606. daddr = optarg;
  607. break;
  608. case 'i':
  609. cfg_ifindex = if_nametoindex(optarg);
  610. if (cfg_ifindex == 0)
  611. error(1, errno, "invalid iface: %s", optarg);
  612. break;
  613. case 'l':
  614. cfg_notification_limit = strtoul(optarg, NULL, 0);
  615. break;
  616. case 'm':
  617. cfg_cork_mixed = true;
  618. break;
  619. case 'p':
  620. cfg_port = strtoul(optarg, NULL, 0);
  621. break;
  622. case 'r':
  623. cfg_rx = true;
  624. break;
  625. case 's':
  626. cfg_payload_len = strtoul(optarg, NULL, 0);
  627. break;
  628. case 'S':
  629. saddr = optarg;
  630. break;
  631. case 't':
  632. cfg_runtime_ms = 200 + strtoul(optarg, NULL, 10) * 1000;
  633. break;
  634. case 'v':
  635. cfg_verbose++;
  636. break;
  637. case 'z':
  638. cfg_zerocopy = true;
  639. break;
  640. }
  641. }
  642. cfg_test = argv[argc - 1];
  643. if (strcmp(cfg_test, "rds") == 0) {
  644. if (!daddr)
  645. error(1, 0, "-D <server addr> required for PF_RDS\n");
  646. if (!cfg_rx && !saddr)
  647. error(1, 0, "-S <client addr> required for PF_RDS\n");
  648. }
  649. setup_sockaddr(cfg_family, daddr, &cfg_dst_addr);
  650. setup_sockaddr(cfg_family, saddr, &cfg_src_addr);
  651. if (cfg_payload_len > max_payload_len)
  652. error(1, 0, "-s: payload exceeds max (%d)", max_payload_len);
  653. if (cfg_cork_mixed && (!cfg_zerocopy || !cfg_cork))
  654. error(1, 0, "-m: cork_mixed requires corking and zerocopy");
  655. if (optind != argc - 1)
  656. usage(argv[0]);
  657. }
  658. int main(int argc, char **argv)
  659. {
  660. const char *cfg_test;
  661. parse_opts(argc, argv);
  662. cfg_test = argv[argc - 1];
  663. if (!strcmp(cfg_test, "packet"))
  664. do_test(PF_PACKET, SOCK_RAW, 0);
  665. else if (!strcmp(cfg_test, "packet_dgram"))
  666. do_test(PF_PACKET, SOCK_DGRAM, 0);
  667. else if (!strcmp(cfg_test, "raw"))
  668. do_test(cfg_family, SOCK_RAW, IPPROTO_EGP);
  669. else if (!strcmp(cfg_test, "raw_hdrincl"))
  670. do_test(cfg_family, SOCK_RAW, IPPROTO_RAW);
  671. else if (!strcmp(cfg_test, "tcp"))
  672. do_test(cfg_family, SOCK_STREAM, 0);
  673. else if (!strcmp(cfg_test, "udp"))
  674. do_test(cfg_family, SOCK_DGRAM, 0);
  675. else if (!strcmp(cfg_test, "rds"))
  676. do_test(PF_RDS, SOCK_SEQPACKET, 0);
  677. else
  678. error(1, 0, "unknown cfg_test %s", cfg_test);
  679. return 0;
  680. }