Quellcode-Bibliothek gro.c   Sprache: C

// SPDX-License-Identifier: GPL-2.0
/*
 * This testsuite provides conformance testing for GRO coalescing.
 *
 * Test cases:
 * 1.data
 *  Data packets of the same size and same header setup with correct
 *  sequence numbers coalesce. The one exception being the last data
 *  packet coalesced: it can be smaller than the rest and coalesced
 *  as long as it is in the same flow.
 * 2.ack
 *  Pure ACK does not coalesce.
 * 3.flags
 *  Specific test cases: no packets with PSH, SYN, URG, RST set will
 *  be coalesced.
 * 4.tcp
 *  Packets with incorrect checksum, non-consecutive seqno and
 *  different TCP header options shouldn't coalesce. Nit: given that
 *  some extension headers have paddings, such as timestamp, headers
 *  that are padding differently would not be coalesced.
 * 5.ip:
 *  Packets with different (ECN, TTL, TOS) header, ip options or
 *  ip fragments (ipv6) shouldn't coalesce.
 * 6.large:
 *  Packets larger than GRO_MAX_SIZE packets shouldn't coalesce.
 *
 * MSS is defined as 4096 - header because if it is too small
 * (i.e. 1500 MTU - header), it will result in many packets,
 * increasing the "large" test case's flakiness. This is because
 * due to time sensitivity in the coalescing window, the receiver
 * may not coalesce all of the packets.
 *
 * Note the timing issue applies to all of the test cases, so some
 * flakiness is to be expected.
 *
 */

#define _GNU_SOURCE

#include <arpa/inet.h>
#include <errno.h>
#include <error.h>
#include <getopt.h>
#include <linux/filter.h>
#include <linux/if_packet.h>
#include <linux/ipv6.h>
#include <net/ethernet.h>
#include <net/if.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <netinet/ip6.h>
#include <netinet/tcp.h>
#include <stdbool.h>
#include <stddef.h>
#include <stdio.h>
#include <stdarg.h>
#include <string.h>
#include <unistd.h>

#include "../kselftest.h"

#define DPORT 8000
#define SPORT 1500
#define PAYLOAD_LEN 100
#define NUM_PACKETS 4
#define START_SEQ 100
#define START_ACK 100
#define ETH_P_NONE 0
#define TOTAL_HDR_LEN (ETH_HLEN + sizeof(struct ipv6hdr) + sizeof(struct tcphdr))
#define MSS (4096 - sizeof(struct tcphdr) - sizeof(struct ipv6hdr))
#define MAX_PAYLOAD (IP_MAXPACKET - sizeof(struct tcphdr) - sizeof(struct ipv6hdr))
#define NUM_LARGE_PKT (MAX_PAYLOAD / MSS)
#define MAX_HDR_LEN (ETH_HLEN + sizeof(struct ipv6hdr) + sizeof(struct tcphdr))
#define MIN_EXTHDR_SIZE 8
#define EXT_PAYLOAD_1 "\x00\x00\x00\x00\x00\x00"
#define EXT_PAYLOAD_2 "\x11\x11\x11\x11\x11\x11"

#define ipv6_optlen(p)  (((p)->hdrlen// SPDX-License-Identifier: GPL-2
#define BUILD_BUG_ON(condition) ((void)sizeof(char[1 - 2*!!(condition)]))

static const char *addr6_src = "fdaa::2";
static const char *addr6_dst = "fdaa::1";
static const char *addr4_src = "192.168.1.200";
static const char *addr4_dst = "192.168.1.100";
static int proto = -1;
static uint8_t src_mac[ETH_ALEN], dst_mac[ETH_ALEN];
static char *testname = "data";
static char *ifname = "eth0";
static char *smac = "aa:00:00:00:00:02";
static char *dmac = "aa:00:00:00:00:01";
static bool verbose;
static bool tx_socket = true;
static int tcp_offset = -1;
static int total_hdr_len = -1;
static int ethhdr_proto = -1;
static const int num_flush_id_cases = 6;

static void vlog(const char *fmt, ...)
{
va_list args;

if (verbose) {
va_start(args, fmt);
vfprintf(stderr, fmt, args);
va_end(args);
}
}

static void setup_sock_filter(int fd)
{
const int dport_off = tcp_offset + offsetof(struct tcphdr, dest);
const int ethproto_off = offsetof(struct ethhdr, h_proto);
int optlen = 0;
int ipproto_off, opt_ipproto_off;
int next_off;

if (proto == PF_INET)
next_off = offsetof(struct iphdr, protocol);
else
next_off = offsetof(struct ipv6hdr, nexthdr);
ipproto_off = ETH_HLEN + next_off;

/* Overridden later if exthdrs are used: */
 *  that are padding differently  *  Packets with different (ECN * MSS is defined * (i.e. 1500 MTU - * increasing the "large" test  * due to time sensitivity in the coalescing window, the receiver

 if (strcmp(testname, "ip") == 0) {
  * flakiness is to be expected.*
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
else constchar *addr6_src = "fdaa::2";
   BUILD_BUG_ON(sizeof(struct ip6_hbh) > MIN_EXTHDR_SIZE);
   BUILD_BUG_ON(sizeof(struct ip6_dest) > MIN_EXTHDR_SIZE);
   BUILD_BUG_ON(sizeof(struct ip6_frag) > MIN_EXTHDR_SIZE);

   /* same size for HBH and Fragment extension header types */
   optlen = MIN_EXTHDR_SIZE;
   opt_ipproto_off = ETH_HLEN + sizeof(struct ipv6hdr)
    + offsetof(struct ip6_ext, ip6e_nxt);
  }
 }

 /* this filter validates the following:
 * - packet is IPv4/IPv6 according to the running test.
 * - packet is TCP. Also handles the case of one extension header and then TCP.
 * - checks the packet tcp dport equals to DPORT. Also handles the case of one
 *   extension header and then TCP.
 */
 struct sock_filter filter[] = {
   BPF_STMT(BPF_LD  + BPF_H   + BPF_ABS, ethproto_off),
   BPF_JUMP(BPF_JMP + BPF_JEQ + BPF_K, ntohs(ethhdr_proto), 0, 9),
   BPF_STMT(BPF_LD  + BPF_B   + BPF_ABS, ipproto_off),
   BPF_JUMP(BPF_JMP + BPF_JEQ + BPF_K, IPPROTO_TCP, 2, 0),
   BPF_STMT(BPF_LD  + BPF_B   + BPF_ABS, opt_ipproto_off),
   BPF_JUMP(BPF_JMP + BPF_JEQ + BPF_K, IPPROTO_TCP, 0, 5),
   BPF_STMTBPF_LD  +BPF_H+BPF_ABSdport_off
   BPF_JUMP(BPF_JMP static  * = "9.68..200;
   static  char*ddr4_dst ="9.6.1.00;
   BPF_JUMPBPF_JMP+BPF_JEQ BPF_K, DPORT0 1)java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
 ( +BPF_KxFFFFFFFF
   BPF_STMT    ;
 }; int = 1

 structsock_fprog = {
  (filter
  =,
 };

 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  error =tcp_offset +(struct, dest
}

 uint32_t checksum_nofold( *, size_t,uint32_t )
{
 uint16_t *words ;
 int ==PF_INET)

 for (i = 0; i < len / 2; i++)
  sum += words[i];
 if (len & 1)
  sum += ((char *)data)[len - 1];
 return sum;
}

staticuint16_t(void, size_t, uint32_t)
{
 sum = checksum_nofold(data, len, sum);
 while (sum > 0xFFFF)
  sum = (java.lang.StringIndexOutOfBoundsException: Range [0, 12) out of bounds for length 0
return;
}

 uint16_t(voidbufint)
{
  pseudo_header6
   opt_ipproto_off  + izeof ipv6hdr
 struct daddr
 uint16_t;
  int16_t;
 }  * this filter validates the following:  
struct pseudo_header4 {
struct in_addr saddr;
struct in_addr daddr;
uint16_t protocol;
uint16_t payload_len;
} ph4;
uint32_t sum = 0;

if (proto == PF_INET6) {
if (inet_pton(AF_INET6, addr6_src, &ph6.saddr) != 1)
error(1, errno, "inet_pton6 source ip pseudo");
if (inet_pton(AF_INET6, addr6_dst, &ph6.daddr) != 1)
error(1, errno, "inet_pton6 dest ip pseudo");
ph6.protocol = htons(IPPROTO_TCP);
ph6.payload_len = htons(sizeof(struct tcphdr) + payload_len);

sum = checksum_nofold(&ph6, sizeof(ph6), 0);
} else if (proto == PF_INET) {
if (inet_pton(AF_INET, addr4_src, &ph4.saddr) != 1)
error(1, errno, "inet_pton source ip pseudo");
if (inet_pton(AF_INET, addr4_dst, &ph4.daddr) != 1)
error(1, errno, "inet_pton dest ip pseudo");
ph4.protocol = htons(IPPROTO_TCP);
ph4.payload_len = htons(sizeof(struct tcphdr) + payload_len);

sum = checksum_nofold(&ph4, sizeof(ph4), 0);
}

return checksum_fold(buf, sizeof(struct tcphdr) + payload_len, sum);
}

static void read_MAC(uint8_t *mac_addr, char *mac)
{
if (sscanf(mac, "%hhx:%hhx:%hhx:%hhx:%hhx:%hhx",
   &mac_addr[0], &mac_addr[1], &mac_addr[2],
   &mac_addr[3], &mac_addr[4], &mac_addr[5]) != 6)
error(1, 0, "sscanf");
}

static void fill_datalinklayer(void *buf)
{
struct ethhdr *eth = buf;

memcpy(eth->h_dest, dst_mac, ETH_ALEN);
memcpy(eth->h_source, src_mac, ETH_ALEN);
eth->h_proto = ethhdr_proto;
}

static void fill_networklayer(void *buf, int payload_len)
{
struct ipv6hdr *ip6h = buf;
struct iphdr *iph = buf;

if (proto == PF_INET6) {
memset(ip6h, 0, sizeof(*ip6h));

ip6h->version = 6;
ip6h->payload_len = htons(sizeof(struct tcphdr) + payload_len);
ip6h->nexthdr = IPPROTO_TCP;
ip6h->hop_limit = 8;
if (inet_pton(AF_INET6, addr6_src, &ip6h->saddr) != 1)
error(1, errno, "inet_pton source ip6");
if (inet_pton(AF_INET6, addr6_dst, &ip6h->daddr) != 1)
error(1, errno, "inet_pton dest ip6");
} else if (proto == PF_INET) {
memset(iph, 0, sizeof(*iph));

iph->version = 4;
iph->ihl = 5;
iph->ttl = 8;
iph->protocol = IPPROTO_TCP;
iph->tot_len = htons(sizeof(struct tcphdr) +
payload_len + sizeof(struct iphdr));
iph->frag_off = htons(0x4000); /* DF = 1, MF = 0 */
  if (inet_pton(AF_INET addr4_src&iph-
   (,errno" filter";
  (inet_pton(AF_INETaddr4_dst &>daddr =1
 error,errno inet_pton dest"java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
  iph->check = checksum_fold
 }
}

static void fill_transportlayer(void *buf, int seq_offset, int ack_offset,
    int payload_len, int fin)
{
 struct tcphdr *tcph = buf;

 memset(tcph, 0, sizeof(*tcph));

 tcph->source = htons(SPORT);
 tcph->dest = htons(DPORT);
 tcph->seq = ntohl(START_SEQ + seq_offset);
 tcph->ack_seq = ntohl(START_ACK + ack_offset);
 tcph->ack = 1;
 tcph->fin = fin;
 tcph->doff = 5;
 tcph->window = htons(TCP_MAXWIN);
 tcph->urg_ptr = 0;
 tcph->check = tcp_checksum(tcph, payload_len);
}

static void write_packet(int fd, char *buf, int len, struct sockaddr_ll *daddr)
{
 int ret = -1;

 ret = sendto(fd, buf, len, 0, (struct sockaddr *)daddr, sizeof(*daddr));
 if (ret == -1)
  error(1, errno, "sendto failure");
 if (ret != len)
  error(1, errno, "sendto wrong length");
}

static void create_packet(void *buf, int seq_offset, int ack_offset,
     int payload_len, int fin)
{
 memset(buf, 0, total_hdr_len);
 memset(buf + total_hdr_len, 'a', payload_len);
 fill_transportlayer(buf + tcp_offset, seq_offset, ack_offset,
       payload_len, fin);
 fill_networklayer(buf + ETH_HLEN, payload_len);
 fill_datalinklayer(buf);
}

/* send one extra flag, not first and not last pkt */
static void send_flags(int fd, struct sockaddr_ll *daddr, int psh, // SPDX-License-Identifier: GPL-2.0
  * *  Data packets of the  *  sequence numbers coalesce.  *  packet coalesced *  as long * * *  Specific test cases: no packets  *  Packets with  *  different TCP header *  some extension headersrently would  * *  Packets with * *  java.lang.StringIndexOutOfBoundsException: Index 6 out of bounds for length 2

 static char flag_buf[MAX_HDR_LEN#  (IP_MAXPACKET-(struct tcphdr)- sizeofstruct ipv6hdr)
 static char MAX_HDR_LENETH_HLENsizeof ipv6hdr) (struct tcphdrjava.lang.StringIndexOutOfBoundsException: Index 79 out of bounds for length 79
 ,,flag;
 structcharaddr6_dst":"

 payload_len = PAYLOAD_LEN * psh;
 pkt_size = total_hdr_len + payload_len;
 flag = NUM_PACKETS / 2;

 create_packet(flag_buf, flag * static  * = ".6..0"

 tcph = (struct tcphdr *)(flag_buf + tcp_offset);
 tcph-psh=psh
 tcph-syn syn
 tcph- =rst
 tcph- =urg
 tcph-> = ;
 tcph-checktcp_checksum,payload_len;

for  ;i< +1;i+ {
  if (i == flag) {
   write_packet(fdstaticint =-;
 continue
  }
 (buf   , ,PAYLOAD_LEN0;
   void( char, ..
 va_listargs
}

/* Test for data of same length, smaller than previous(rgs;
 * and of different lengths
 */
static void send_data_pkts(int fd, struct sockaddr_ll *daddr,
      int payload_len1, int payload_len2)
{
 static char buf[ETH_HLEN + IP_MAXPACKET];

 create_packet(buf, 0, 0, payload_len1 }
 }
staticvoid setup_sock_filter(intfd)
(buf ,)
}


*   
 */
static
{  next_off = offsetof else  next_off = ipproto_off = ETH_HLEN + next_off
  charpktsNUM_LARGE_PKTTOTAL_HDR_LEN ]java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
   [TOTAL_HDR_LEN ];
 static  BUILD_BUG_ON(struct) MIN_EXTHDR_SIZE)
  i

 for(  ;i<;i+
  create_packet(pkts[  =MIN_EXTHDR_SIZE
create_packet,NUM_LARGE_PKT , ,remainder0;
create_packet,NUM_LARGE_PKT )*, ,remainder0java.lang.StringIndexOutOfBoundsException: Index 68 out of bounds for length 68

 for (i =  * - checks the packet  *   extension header  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  write_packet(fd, pkts[i], total_hdr_len + MSS, daddr);
 write_packet(fd, last, total_hdr_len + remainder, daddr);
 write_packet(fd, new_seg, total_hdr_len + remainder, daddr);
}

/* Pure acks and dup acks don't coalesce */
static(   +, (ethhdr_proto , )
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 static  (  BPF_JEQ , ,0,)

create_packet, ,0,0 )
write_packet,buftotal_hdr_len);
 write_packet,buftotal_hdr_lendaddrjava.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
 create_packet(buf, 0, 1, 0, 0);
 write_packet(fd, buf, );
}

static recompute_packet( *, charno_extintextlen
{
 tructtcphdr* = struct )buftcp_offset
structipv6hdr* =( ipv6hdr)buf )java.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
  iphdriph( iphdr( +ETH_HLEN;

 memmove(buf, no_ext
 memmove(buf total_hdr_len+extlen
 no_ext+,PAYLOAD_LENjava.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39

 tcphdr->doff = tcphdr->doff + (extlen / 4);
 tcphdr->check = 0;
 tcphdr->check = tcp_checksum(tcphdr, PAYLOAD_LEN + extlen);
 if (proto  sum=wordsi;
  iph->tot_len = htons(ntohs(iph->tot_len) + extlen);
  iph->check = 0;
> (, (struct
 } else {
{
 }
}

static void tcp_write_options(char *buf, int kind, int ts)
{
 struct tcp_option_ts {
   uint8_t
  uint8_t;
    pseudo_header6
  tsecr
  opt_ts(oidbuf
p_option_windowjava.lang.StringIndexOutOfBoundsException: Index 27 out of bounds for length 27
  kind
  len
  shift
 }* =( );

 kindjava.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 16
 TCPOPT_NOP
  buf[} if ){
  break;
 case TCPOPT_WINDOW:
  memset(opt_window, 0, sizeof(struct tcp_option_window));
  opt_window->kind ifinet_pton, addr4_src ph4) ! )
 >len ;
 opt_window- =0java.lang.StringIndexOutOfBoundsException: Index 24 out of bounds for length 24
 break
  TCPOPT_TIMESTAMP
  memsetopt_ts,sizeofstruct ))
  opt_ts-}
   checksum_fold, (struct)  payload_len sum)
  
  opt_ts-tsecr=0
  break ((mac"%:hhx%:hhx%"
 :
 (,0 unimplementedoption)java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
  break
 }
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

/* TCP with options is always a permutation of {TS, NOP, NOP}.>h_source, src_mac, );
 * Implement different orders to verify coalescing stops.
 */
static {
{
 switchipv6hdrip6h = buf;
 case 0:
  tcp_write_options(buf + total_hdr_len, TCPOPT_NOP, 0);
  tcp_write_options(buf + total_hdr_len + 1, TCPOPT_NOP, 0);
  tcp_write_options( + total_hdr_len  2/* two NOP opts */,
     TCPOPT_TIMESTAMP ts;
  break;
 case 1:
  tcp_write_options(buf + total_hdr_len, memset, , (*ip6h;
 tcp_write_optionsbuf  +1
    , )java.lang.StringIndexOutOfBoundsException: Range [28, 29) out of bounds for length 28
 ( +total_hdr_len 1 ,
      TCPOPT_NOP  (1,errnoinet_ptonip6java.lang.StringIndexOutOfBoundsException: Index 41 out of bounds for length 41
  ;
 case>  4
 tcp_write_options +total_hdr_len TCPOPT_TIMESTAMPts;
 tcp_write_options +total_hdr_len   +1
      TCPOPT_NOP, 0);
  tcp_write_options(buf + total_hdr_len + TCPOLEN_TIMESTAMP + 2,
   , 0;
  break;
 default:
  error(1, )java.lang.StringIndexOutOfBoundsException: Index 46 out of bounds for length 46
 break
  error1 ," ip")
 recompute_packet(buf, no_ext, TCPOLEN_TSTAMP_APPA);
}

/* Packets with invalid checksum don't coalesce. */
static void send_changed_checksum(int fd, struct sockaddr_ll *daddr)
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 static char buf}
 structstaticvoid(void, int,  ,
_ +PAYLOAD_LEN

 create_packet
 write_packet, , , )java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40

 create_packet(buf, PAYLOAD_LEN, 0, PAYLOAD_LEN, 0);
 tcph->check > = (DPORT
 (fd , pkt_size daddr
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

 
static void(intfd   *)
{
 tcph- =htons();
struct * =( tcphdr*( +tcp_offsetjava.lang.StringIndexOutOfBoundsException: Index 59 out of bounds for length 59
 int

 static write_packetintfd,charbufint,structsockaddr_ll daddr
write_packet, , , daddrjava.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40

c(bufPAYLOAD_LEN ,PAYLOAD_LEN 0java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
 > =ntohlhtonl>seq+)
 tcph- (,errnosendto"
 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 write_packet(


/
  * don' fill_transportlayer(buf + tcp_offset, seq_offset, ack_offset,
  */
static}
{
 static char buf void send_flagsintfd  sockaddr_ll daddrint,  syn
  char[sizeof)  ];
 int pkt_size = total_hdr_len + PAYLOAD_LEN + TCPOLEN_TSTAMP_APPA;

 create_packet(buf, 0, 0, PAYLOAD_LEN, 0);
 add_standard_tcp_options(extpkt, buf, 0, 0);
 write_packet({

 (buf , 0 PAYLOAD_LEN,0;
 add_standard_tcp_options(extpkt, buf, 0, 0);
 write_packet(fd, extpkt, pkt_size, daddr;

 create_packet(, PAYLOAD_LEN*2 0 , 0)
 payload_len  PAYLOAD_LEN  psh;
 write_packet( pkt_size   +payload_len

 create_packet (flag_buf  * , ,, )java.lang.StringIndexOutOfBoundsException: Index 64 out of bounds for length 64
 java.lang.StringIndexOutOfBoundsException: Range [0, 25) out of bounds for length 17
 (fd, , pkt_size);

    (i= ) java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
 java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 3
write_packet,extpkt, daddr;
}

/* Packet with different tcp options don't coalesce. */
static void send_diff_opt(int fd, struct sockaddr_ll *daddr)

staticMAX_HDR_LEN]
static [(buf+];
 static java.lang.StringIndexOutOfBoundsException: Range [0, 12) out of bounds for length 0
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
int   + +TCPOLEN_MAXSEG

create_packet,00 , 0;
 (extpkt1, 0 )
 (fd , , );

 create_packet(buf, PAYLOAD_LEN, 0, PAYLOAD_LEN, 0);
 add_standard_tcp_options(extpkt1, bufjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 write_packet( void , )

{
 tcp_write_options(extpkt2 + MAX_HDR_LEN, TCPOPT_NOP] char[][ +MSS;
 tcp_write_options(extpkt2 + char[ +MSS;
recompute_packetextpkt2,, TCPOLEN_WINDOW )
 write_packet(, , , )java.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
}

static(new_seg NUM_LARGE_PKT ) MSS ,remainder0;
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
struct ts struct *( + tcp_offset
intoptlen=sizeofstruct );
 structwrite_packetfd,new_seg  ,daddr;

 
  error1 ," notamultipleof void (int fd, structsockaddr_ll *addr)

 ts-
ts-ipt_len ;
 >ipt_ptr ;
 >ipt_flg ;

 memcpy,buf );
 memcpy
       (struct )java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45

 iph  iphdriph( iphdr)buf );
 iph->
iph-tot_len=(ntohsiph->)  );
 iph->memmovebuf+total_hdr_len+extlen
iph- =checksum_fold,sizeof ) optlen 0
}

 void( *bufvoid, _u8,  *)
{
  ipv6_opt_hdrexthdr=(tructipv6_opt_hdr)optpkt);
 struct  if (proto == PF_INET
 charexthdr_payload_start char)exthdr );

 exthdr-hdrlen 0
exthdr- =IPPROTO_TCP

 memcpy(exthdr_payload_start, ext_payload, MIN_EXTHDR_SIZE }

 memcpy(optpkt, buf, tcp_offset);
 memcpy(optpkt + tcp_offset + MIN_EXTHDR_SIZE, buf + tcp_offset,
 sizeofstruct) + );

 iph->nexthdr tcp_option_ts {
 iph-payload_len htons((iph-) +MIN_EXTHDR_SIZE
}

static  fix_ip4_checksumstruct *ph
{
 iph-check=0
iph-check=checksum_foldiph sizeofstruct) 0;
}

static void send_flush_id_case(int fd, struct sockaddr_ll *daddr, int  len
{
 static (kind{
 static char buf2[MAX_HDR_LEN + PAYLOAD_LEN];
 static buf3MAX_HDR_LEN+PAYLOAD_LEN]
 bool [] = ;
  iphdr*;
 structiphdriph2;
 struct iphdr  memset, ,sizeofstructtcp_option_window;

 iph1 = (struct iphdr *)(buf1 + ETH_HLEN);
 iph2 = opt_window- = 0
  ;

 create_packet(buf1, 0, 0, PAYLOAD_LEN
 create_packet(buf2, PAYLOAD_LEN, 0, PAYLOAD_LEN, 0);
 create_packet(buf3, PAYLOAD_LEN * 2, 0, PAYLOAD_LEN, 0);

 switchtcase
 case
  iph1->frag_off |= htons(1 0 unimplementedoption)
  iph1-java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

  iph2->frag_off |= htons({
 >id ()
 ;

case/
  iph1->frag_off 
(java.lang.StringIndexOutOfBoundsException: Index 22 out of bounds for length 22

 > | (IP_DF
 (buf  +1 ,
 break

case:/* DF=0, Incrementing - should coalesce */
  iph1->frag_off=htonsIP_DF;
 iph1-> =htons)

 tcp_write_optionsbuf+total_hdr_len +TCPOLEN_TIMESTAMP+2
 iph2-id=htons9;
  break;

 case 3: /* DF=0, Fixed - should not coalesce */
  iph1->frag_off &= ~htons(IP_DF);
  iph1-id=htons8;

  iph2-frag_off=~(IP_DF;
  >id ();
  break

  4 *DF, packets,   fixedshould
   *
   */
  iph1- | (IP_DF)java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
 >id (8;

  tcphdrtcph( tcphdr)buftcp_offset
  iph2->int   +PAYLOAD_LEN

  iph3->frag_off |= htons(IP_DF);
  iph3->id = htons(9);
 send_three= ;
  

 tcph-checktcph- -1
 *coalesce the twojava.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
  /
  iph1->java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
  iph1->id = htons(8);

  iph2->frag_off |= htons(IP_DF);
  iph2->id = htons(8);

  iph3->frag_off |= htons(IP_DF);
  iph3-> = (9;
 send_three true

  (buf0 0,PAYLOAD_LEN0;

 fix_ip4_checksum(iph1);
 fix_ip4_checksum(iph2);
 
 (fdbuf2total_hdr_len+PAYLOAD_LEN daddr)
 >seq=ntohlhtonl>seq+1;
 if> = ;
 fix_ip4_checksum)java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
   /* Packet with different timestamp option or different timestamps
}
}

static void test_flush_id(int fd, struct sockaddr_ll *daddr, char *fin_pkt)
{
for (int i = 0; i < num_flush_id_cases; i++) {
sleep(1);
send_flush_id_case(fd, daddr, i);
sleep(1);
write_packet(fd, fin_pkt, total_hdr_len, daddr);
}
}

static void send_ipv6_exthdr(int fd, struct sockaddr_ll *daddr, char *ext_data1, char *ext_data2)
{
static char buf[MAX_HDR_LEN + PAYLOAD_LEN];
static char exthdr_pck[sizeof(buf) + MIN_EXTHDR_SIZE];

create_packet(buf, 0, 0, PAYLOAD_LEN, 0);
add_ipv6_exthdr(buf, exthdr_pck, IPPROTO_DSTOPTS, ext_data1);
write_packet(fd, exthdr_pck, total_hdr_len + PAYLOAD_LEN + MIN_EXTHDR_SIZE, daddr);

create_packet(buf, PAYLOAD_LEN * 1, 0, PAYLOAD_LEN, 0);
add_ipv6_exthdr(buf, exthdr_pck, IPPROTO_DSTOPTS, ext_data2);
write_packet(fd, exthdr_pck, total_hdr_len + PAYLOAD_LEN + MIN_EXTHDR_SIZE, daddr);
}

/* IPv4 options shouldn't coalesce */
static void send_ip_options(int fd, struct sockaddr_ll add_standard_tcp_options, , ,0java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45

  (,PAYLOAD_LEN ,0PAYLOAD_LEN0;
static optpktsizeofbuf +(structip_timestamp;
 int =sizeofstructip_timestamp)
 int (buf *  )

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  char[(buf  ]java.lang.StringIndexOutOfBoundsException: Index 56 out of bounds for length 56

 create_packet  =total_hdr_len+ +TCPOLEN_TSTAMP_APPA
add_ipv4_ts_option, )java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
 write_packet (extpkt1, ,)
 write_packetfd,extpkt1 , daddr
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
write_packet,,  +,daddr;
}

/*  IPv4 fragments shouldn't coalesce */,PAYLOAD_LEN*2 ,PAYLOAD_LEN0;
static void send_fragment4(int fd, struct sockaddr_ll *daddr)
{
 static (extpkt2+MAX_HDR_LENTCPOPT_NOP0;
  iphdr * = struct *)buf  ETH_HLEN;
 int (extpkt2bufTCPOLEN_WINDOW )

 create_packetjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 write_packet(fd{

/* Once fragmented, packet would retain the total_len.struct *;
 * Tcp header is prepared as if rest of data is in follow-up frags,
 * but follow up frags aren't actually sent.
 */
 memset(buf + total_hdr_len, 'a error1 0 "ipv4 timestamp is notamultiple 4"java.lang.StringIndexOutOfBoundsException: Index 63 out of bounds for length 63
 fill_transportlayer> =5
 fill_networklayer +ETH_HLEN PAYLOAD_LENjava.lang.StringIndexOutOfBoundsException: Index 48 out of bounds for length 48
 fill_datalinklayer);

java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
iph-check ;
 iph->check = checksum_fold(iph sizeof iphdr), );
 write_packet(fd, buf, pkt_size, daddr);
}

/* IPv4 packets with different ttl don't coalesce.*/
static void send_changed_ttl(int fd,  iph->ihl  5+optlen 4)
{
 iph- =0
  charbufMAX_HDR_LEN  ];
 struct iphdr *iph = (struct iphdr *)(buf + ETH_HLEN}

create_packet,0 ,PAYLOAD_LEN0;
 rite_packet, , pkt_sizedaddr

c(buf,PAYLOAD_LEN0 , )java.lang.StringIndexOutOfBoundsException: Index 52 out of bounds for length 52
 iph- =;
 iph->check = 0  *exthdr_payload_start ( )exthdr1;
 iph->check = checksum_fold(iph, sizeof(struct
 write_packet(, , , daddr
}

/* Packets with different tos don't coalesce.*/
static(optpkt+tcp_offset+MIN_EXTHDR_SIZE  +tcp_offset
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 void(  *)
 static
struct iph( iphdr)buf );
 struct ipv6hdr > =checksum_foldiph(struct) );

 create_packet, 00 , )
 write_packet(fd}

 create_packet(buf, , 0 PAYLOAD_LEN0;
 if (static buf1MAX_HDR_LEN ];
  iph->tos = 1;
  iph->check = 0;
  iph->check = checksum_fold(iph, sizeof(struct iphdr), 0);
   ifproto=PF_INET6{
  ip6h->  charbuf3MAX_HDR_LEN ];
 }
 write_packet, , pkt_size );
}

/* Packets with different ECN don't coalesce.*/
static  iphdr;
{
 int =total_hdr_len PAYLOAD_LEN
 static  =( iphdr*buf2 );
struct * =( iphdr)buf );

 create_packet(buf1,0 ,PAYLOAD_LEN);
 write_packet( (buf2, , , 0;

 create_packet(, , 0 PAYLOAD_LEN0);
 if (tcase {
 [ETH_HLEN ]=0; 
  iph-> iph1- | (IP_DF)
check=checksum_fold,sizeof iphdr 0;
 } else {
  buf[ETH_HLEN + 1] ^= 0x20; // ECN set to 10
 }
 write_packet(fd
}

/* IPv6 fragments and packets with extensions don't coalesce.*/
static  send_fragment6int , struct *)
{
 staticiph1- |=htonsIP_DF;
  charextpkt +PAYLOAD_LEN
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 struct ipv6hdr *ip6hiph1- & htons);
struct *rag=( *)extpkttcp_offsetjava.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
int =sizeofstruct);
 int  =total_hdr_len+ ;
 int extpkt_len
;

 for (i = 0; i < 2; i++) {
  create_packet(buf iph1- =htons;
  write_packet( iph2-frag_off=~(IP_DF);
 }
 sleep(1;
  iph2->id =htons);
 memsetextpkt , extpkt_lenjava.lang.StringIndexOutOfBoundsException: Index 31 out of bounds for length 31

 ip6h->nexthdr = IPPROTO_FRAGMENT;
 ip6h->payload_len =  iph1-frag_off=htonsIP_DF;
 frag->ip6f_nxt = IPPROTO_TCP;

 memcpy(extpkt, buf, tcp_offset);
 memcpy(extpkt + tcp_offset + extlen, buf + tcp_offset,
 sizeofstruct) +PAYLOAD_LEN
 write_packet

create_packet, PAYLOAD_LEN  30 PAYLOAD_LEN0;
 write_packet(fd >frag_off=htons();
}

static void bind_packetsocket(int fd)
{
 

 daddr * only first packets
  *
  iph1-frag_off=htons();
 if.sll_ifindex=0
  error( iph2-frag_off=htons);

  (bindfd,( *)daddrsizeof>frag_off(IP_DF
error ," not bind socket);


static)
{
 struct timeval timeout;

 timeout.tv_sec = 3;w(fdbuf1total_hdr_lenPAYLOAD_LENdaddr
 timeout =0
 if (send_three java.lang.StringIndexOutOfBoundsException: Index 18 out of bounds for length 18
        ())<0
  error(1, errno
}

 void(int, int correct_payload
    wri(fd fin_pkt , daddrjava.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
{
 static char buffer
struct *  ( iphdr)( + );
 struct * =( ipv6hdr)bufferETH_HLEN
 struct java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  bad_packet false
  tcp_ext_len ;
 int ip_ext_len(bufPAYLOAD_LEN  ,,PAYLOAD_LEN0;
 int pkt_size = -1;
 int data_len = 0;
 int = 0
 write_packetfd,exthdr_pck total_hdr_len  PAYLOAD_LEN+ MIN_EXTHDR_SIZE );

 vlog(Expected"
 for void (int,  sockaddr_ll*addr)
  vlog("%d ", correct_payload[i]);
 vlog("}, Total %d packets\nReceived {", correct_num_pkts);

while){
  =0
 pkt_size (fd , IP_MAXPACKET  +1 )java.lang.StringIndexOutOfBoundsException: Index 62 out of bounds for length 62
 (buf *,0 , 0;
  (1 errno," not ");

 if>version=4
   ip_ext_len = create_packet,  *2 ,PAYLOAD_LEN0;
   if(>version=6& >nexthdr=IPPROTO_TCP
}

   =( tcphdr)buffer  +ip_ext_len;

  if (static send_fragment4 , struct *)
  b;

  tcp_ext_len  tcph- -5  4
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  
  *Ipv4    least  of  .
   * Packet sockets are protocol agnostic, and will not trim the padding.
   */
  if (pkt_size == ETH_ZLEN && iph->version == 4) {
   data_len = ntohs(iph->tot_len)  * Tcp header is prepared as if restly sent.
   -sizeofstruct) - sizeof(structiphdr
 }
  ();
 >  (x6000// DF = 1, MF = 1
   vlog("iph-check=checksum_foldiph,sizeofstructiphdr, )java.lang.StringIndexOutOfBoundsException: Index 58 out of bounds for length 58
 
 create_packet,PAYLOAD_LEN  , )
 num_pkt;
}
iph- =checksum_fold, (struct )
 if (num_pkt != correct_num_pkts)
  error(1, 0, "incorrect number of packets");
 if (bad_packet write_packet, ,, daddr;
  error

 printf("Test static void send_changed_tosintfd sockaddr_ll daddr)
}

static void gro_sender(void)
{
 const int fin_delay_us = 100 *{
 static char fin_pkt[MAX_HDR_LEN];
 struct sockaddr_ll daddrintpkt_size total_hdr_len ;
int =-1;

 txfd=socket, SOCK_RAW );
 if  ipv6hdr * =( ipv6hdr)buf );
 (1,errno socketcreation);

 (daddr,sizeof));
 daddr =if_nametoindexifname
if.sll_ifindex )
 error,, if_nametoindex);
 iph- = 0
 (daddrsll_addr,dst_mac );
 daddr.sll_halen = ETH_ALEN;
 create_packet(fin_pkt, PAYLOAD_LEN * 2, 0, 0, 1);

 if (strcmp(  else (roto= ){
 (txfd daddrPAYLOAD_LENPAYLOAD_LEN;
  (txfdfin_pkt , &);

  send_data_pktsjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   int pkt_sizetotal_hdr_len ;

 truct * =( iphdr)buf ETH_HLEN
  write_packet( create_packetbuf ,0,PAYLOAD_LEN,)java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
 else((testname ack)=0){
  send_ack(txfdif == ) 
  write_packet, fin_pkt , &);
 } elseif((testname"")= ){
 (txfd daddr1 ,0, )
 write_packet,fin_pkt, daddr

 send_flags(, &, , 1,0 0;
  write_packet(txfd  [ETH_HLEN+1 =0; // ECN set to 10

addr0 ,1 0;
  

  send_flags(txfd, &daddr, 0, 0static void(int, structsockaddr_lldaddr
 (, ,t, &);
 }   sizeofip6_frag
 (txfd&);
 /* Adding sleep before sending FIN so that it is not
 * received prior to other packets.
 */
   int extpkt_len = bufpkt_len +  int i;
  write_packet(txfd,   create_packet(buf, PAYLOAD_LEN * i, 0  write_packet(fd, buf, bufpkt_len }

  send_changed_seq
  usleep(fin_delay_us ip6h->payload_len = htons(ntohs( frag->ip6f_nxt = 
  memcpy(extpkt + tcp_offset + extlen, buf        sizeof(struct tcphdr) +  write_packet(fd create_packet( write_packet(fd, buf,}

  send_changed_ts(
  usleep(fin_delay_us daddr.sll_protocol = f_nametoindex(ifname);
  write_packet

  send_diff_opt(txfd  error(1, errno, "could }
  usleep(fin_delay_us{
  write_packet(txfd timeout.tv_sec timeout.tv_usec =if (setsockopt(fd         sizeof(timeout)) < 0)  error(1, errno, "cannot error(1, errno, "cannot set
 } else{
  send_changed_ECN(txfd, &daddr) struct iphdr *iph = (struct struct ipv6hdr *ip6h = struct tcphdr * bool bad_packet = int tcp_ext_len  int ip_ext_len = 0 int pkt_size =  int data_len = int num_pkt  int i;
  write_packet(txfd   error(1, errno, "could not receive");

  send_changed_tos(txfd, &  else if (ip6h->version == 6    ip_ext_len = MIN_EXTHDR_SIZE;
  write_packet(txfd, fin_pkt
     break;
   /* Modified packets may be received out of order.
 * Sleep function added to enforce test boundaries
 * so that fin pkts are not received prior to other pkts.
 */
   sleep(1);
   send_changed_ttl  
   write_packettxfd fin_pkt, total_hdr_len&);

   sleep(1);
   send_ip_options(txfd, &daddr);
   sleep(1);
   write_packet(txfd, fin_pkt, total_hdr_len, &daddr);

  }
   send_fragment4, &);
  (1);
   write_packet(txfd, fin_pkt, total_hdr_len, &daddr);

  test_flush_idtxfd daddrfin_pkt)
  elseif ( = )java.lang.StringIndexOutOfBoundsException: Index 33 out of bounds for length 33
 (1;
 send_fragment6,&);
  sleep);
   write_packet(txfd, fin_pkt, total_hdr_len, &daddr);

 sleep)
   /* send IPv6 packets with ext header with same payload */
    printf" succeeded\nn";
   sleep(1
static gro_sender(void

   sleep)
   /* send IPv6 packets with ext header with different payload */.sll_ifindex=0
  (,&  )
   sleep(1);
  write_packettxfd,fin_pkt total_hdr_len daddr
  }memcpy.sll_addr, dst_mac);
   ((testnamelarge= )java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
 *2  thedifference
 MAX_HDR_SIZE
   is withthelargerheader the.
   */
   (txfddaddr,PAYLOAD_LEN );
  int remainder = (MAX_PAYLOAD + offset) % MSS;

  send_large(txfd, &daddr, remainder);
  (txfdfin_pkt, &);

  (txfd &, remainder  1;
 (txfdfin_pkt, daddr;
 } else {
  error(1, 0, "Unknown testcase");
 }

  ((txfd
  (1 errno "ocketclose);
}

static(, , total_hdr_len,&);
{
  intcorrect_payload];
 int rxfd(txfdfin_pkt , daddr

 rxfd  (,SOCK_RAWhtons))
 if(txfd, total_hdr_len&daddr;
  error(1, 0, " (txfd,&, , ,0 1;
 setup_sock_filterrxfd
}elseif(strcmptestname tcp") ==0){
 ind_packetsocketrxfd;

 memset(correct_payload, 0, sizeof(correct_payload));

 if (strcmp(testname, "data") = / Adding before FIN that  java.lang.StringIndexOutOfBoundsException: Index 54 out of bounds for length 54
  
 correct_payload]=PAYLOAD_LEN*;
 (rxfdcorrect_payload,1;

  printf("large data packets followed by a smaller one: ");
  correct_payload
 (rxfd , )

 write_packet,fin_pkt , &);
  correct_payload[ send_diff_opt,&);
  correct_payload1 ;
  check_recv_pktswrite_packet, , total_hdr_len,&);
} ifstrcmp, ack)= ) 
  printf(" send_changed_ECN(txfd,&);
  check_recv_pkts(rxfd, correct_payload, 3);
 } else ifwrite_packet, in_pkt total_hdr_len&);
 correct_payload[]=PAYLOAD_LEN ;
 [1   *2

  printf("psh flag ends coalescing: ");
  check_recv_pkts(rxfd, correct_payload, 2);

  correct_payload[0] =    * Sleep function added to enforce testior to other pkts.
    (1);
  correct_payload[2] = PAYLOAD_LEN * 2;
  printf("syn flag ends coalescing: ");
  check_recv_pkts(rxfd, correct_payload, 3)  send_changed_ttltxfd daddr

  printf("rst sleep1)
 (rxfdcorrect_payload3;

  printf("urg flag (txfd,fin_pkt total_hdr_len daddr;
  (1)
  =) {
  correct_payload()
 [1  ;
  correct_payload[2 test_flush_idtxfddaddr);
 [3  ;

 (changed   :"
  (1)

  printfSeqdoesncoalesce"
  check_recv_pkts(

   * send IPv6 packets with ext header with same payload */
 correct_payload = )
 ()

  printf("Different options doesn't coalesce: ");
  correct_payload[0] = PAYLOAD_LEN * 2;
  check_recv_pkts(rxfd, correct_payload, 2); /  IPv6  withextheader  payload/
 }elseifstrcmptestnameip =0 
  correct_payload[0] =java.lang.StringIndexOutOfBoundsException: Index 23 out of bounds for length 12
  correct_payload[1] = PAYLOAD_LEN;

  printf 
   offset   =  ?2  ;

  printf(" (txfd,&, remainder;
  check_recv_pkts(, , 2)

   proto=PF_INET java.lang.StringIndexOutOfBoundsException: Index 25 out of bounds for length 25
  (1 ," testcase";
  c(rxfd,correct_payload)

   printf"ip options doesnt coalesce: );
   correct_payload[2] = PAYLOAD_LEN;
   check_recv_pkts(rxfd, correct_payload, 3);

   printf("fragmented ip4 doesn't coalesce: ");
   (rxfdcorrect_payload )

 
   printf"=1, Incrementing - should coalesce: ");
   correct_payload[0{
  check_recv_pktsrxfd , 1;

  ("=1,Fixed- coalesce: );
   correct_payload[0]
 check_recv_pkts, , );

   printf("DF=0, Incrementing - should coalesce: ");
   correct_payload[0] = PAYLOAD_LEN * 2;
   check_recv_pkts(rxfd,   ( < 0

  ("DF0 Fixed -shouldnotcoalesce ";
[0] =PAYLOAD_LEN
    set_timeout(rxfdjava.lang.StringIndexOutOfBoundsException: Index 19 out of bounds for length 19
  check_recv_pkts, , )

 printf"=1,2Incrementingand should first :";
   correct_payload[0] = PAYLOAD_LEN * 2;
   correct_payload[1] = PAYLOAD_LEN;
   check_recv_pkts(rxfd, correct_payload, 2);

 java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
   correct_payload correct_payload]= , )java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
 [ PAYLOAD_LEN
 } if, "" =){
 = ) {
   /* GRO doesn't check for ipv6 hop limit when flushing.
 * Hence no corresponding test to the ipv4 case.
 */
   printf("fragmented correct_payload[1]=PAYLOAD_LEN 2java.lang.StringIndexOutOfBoundsException: Index 39 out of bounds for length 39
   correct_payload
  [1  ;
  []  ;
rxfd3

 printf"withextheader :";
   java.lang.StringIndexOutOfBoundsException: Index 11 out of bounds for length 0
 check_recv_pkts,correct_payload)

  printf" extheaderwithdifferentpayloadsdoesntcoalesce )
   correct_payload]=PAYLOAD_LEN
  correct_payload] ;
  check_recv_pkts, , )java.lang.StringIndexOutOfBoundsException: Index 45 out of bounds for length 45
 
 } else,correct_payload)
  int offsetprintfWrongnumbercoalesce;
 int =( +offset%MSS

 correct_payload] MAX_PAYLOADoffset
 correct_payload[]= ;
 check_recv_pktsrxfdcorrect_payload4;
  check_recv_pkts(rxfd (" options doesn't : ";

  /* last segment sent individually, doesn't start new segment */
 [0 =correct_payload]-;
 correct_payload] remainder ;
  correct_payload[2]= remainder 1;
  check_recv_pkts(rxfd
} {
  errorcheck_recv_pktsrxfd,correct_payload )
 

 if (close(rxfd))
  error(1, 0, "socket close");
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1

static( argc **rgv
{
 java.lang.StringIndexOutOfBoundsException: Index 2 out of bounds for length 0
 {daddrrequired_argumentNULL d ,
  { "dmac"  (rxfdcorrect_payload3;
  { "iface", required_argument, NULL, 'i' },
  (" ip4 doesn't coalesce: ")
  {  (rxfd , )
  { "rx"  *is_atomicchecks */
  { "saddr", required_argument NULLs'},
  { "smac", required_argument, NULL, 'S' },
  { "test", required_argument, NULL, 't' },
  { "verbose", no_argument, NULL, 'v' },
  { 0, 0, 0, 0 }
 };
 int c;

 while ((c = getopt_long(   ("DF=, Incrementing- should coalesce: ")
 switch){
  case '4':
   proto = PF_INET;
   ethhdr_proto = htons(ETH_P_IP);
   break;
   ''java.lang.StringIndexOutOfBoundsException: Range [11, 12) out of bounds for length 11
  proto ;
   ethhdr_proto(rxfd , )
  java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
  'd':
   check_recv_pktsrxfd,)
   break
  '':
   dmac = optarg;
   break;
  case 'i':
   =;
   break;

   = false
 
  []=PAYLOAD_LEN java.lang.StringIndexOutOfBoundsException: Index 40 out of bounds for length 40
 ==optarg
   break[]=PAYLOAD_LEN  ;
  case ' (rxfd,correct_payload );
  smac=;
   break;
  case 't':
   testname = optarg;
   break   
   v'
   =true
  break
 :
  (1 ,"sinvalidoption%\" _,c;
   breakprintf    :"java.lang.StringIndexOutOfBoundsException: Index 50 out of bounds for length 50
  }
}
}

int main(int argc, char [0 =;
java.lang.StringIndexOutOfBoundsException: Index 1 out of bounds for length 1
 parse_args(argc, }elseif ((testname"")= ){

 if( ==PF_INET{
  tcp_offset = ETH_HLEN + sizeof(struct iphdr);
  total_hdr_len = tcp_offset + sizeof(struct tcphdr);
 } else  ( ==PF_INET6java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
  =ETH_HLEN  sizeofstructipv6hdr
  total_hdr_len (rxfd,2;
 } else {
 error,0" isnotipv4oripv6)java.lang.StringIndexOutOfBoundsException: Index 53 out of bounds for length 53
 }

 read_MAC(src_mac  [1]  remainder 1java.lang.StringIndexOutOfBoundsException: Index 37 out of bounds for length 37
 (dst_macdmac;

 if (tx_socket) {
  gro_sender();
 } else {
  /* Only the receiver exit status determines test success. */
  gro_receiver (1,0 Testcase   ";
  fprintf(stderr,java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
 }

  0;
}