bsd/netinet/tcp_lro.c

128 tcp_lro_matching_tuple(struct ip* ip_hdr, struct tcphdr *tcp_hdr, int *hash,
137 		tcp_hdr->th_sport, tcp_hdr->th_dport, (TCP_LRO_FLOW_MAP - 1));
144 	seqnum = tcp_hdr->th_seq;
145 	off = tcp_hdr->th_off << 2;
152 			(flow->lr_fport == tcp_hdr->th_sport) &&
153 			(flow->lr_lport == tcp_hdr->th_dport)) {
181 		if (SEQ_GT(tcp_hdr->th_ack, flow->lr_tcphdr->th_ack)) {
184 					__func__, tcp_hdr->th_ack,
203 tcp_lro_init_flow(int flow_id, struct ip* ip_hdr, struct tcphdr *tcp_hdr,
213 	flow->lr_fport = tcp_hdr->th_sport;
214 	flow->lr_lport = tcp_hdr->th_dport;
217 	flow->lr_seq = ntohl(tcp_hdr->th_seq) + payload_len;
342 			struct tcphdr *tcp_hdr, int payload_len,
396 	tcp_lro_init_flow(candidate_flow, ip_hdr, tcp_hdr, hash,
398 	tcp_lro_coalesce(candidate_flow, lro_mb, tcp_hdr, payload_len,
405 				struct tcphdr *tcp_hdr, int drop_hdrlen)
436 	if ((lro_mb = lro_tcp_xsum_validate(lro_mb, ip_hdr, tcp_hdr)) == NULL) {
449 	off = tcp_hdr->th_off << 2;
452 	optp = (u_char *)(tcp_hdr + 1);
464 			(tcp_hdr->th_flags & TH_SYN) == 0) {
481 	thflags = tcp_hdr->th_flags;
509 	retval = tcp_lro_matching_tuple(ip_hdr, tcp_hdr, &hash, &flow_id);
520 			tcp_lro_coalesce(flow_id, lro_mb, tcp_hdr, payload_len,
530 					ntohl(tcp_hdr->th_seq));
539 			lro_flow_list[flow_id].lr_seq = ntohl(tcp_hdr->th_seq) +
673 	struct tcphdr * tcp_hdr = NULL;
714 	tcp_hdr = (struct tcphdr *)((caddr_t)ip_hdr + hlen);
719 	off = tcp_hdr->th_off << 2;
728 	return (tcp_lro_process_pkt(m, ip_hdr, tcp_hdr, hlen + off));
767 tcp_start_coalescing(struct ip *ip_hdr, struct tcphdr *tcp_hdr, int tlen)
775 		tcp_hdr->th_sport, tcp_hdr->th_dport,
785 		    (lf->lr_fport == tcp_hdr->th_sport) &&
786 		    (lf->lr_lport == tcp_hdr->th_dport)) {
788 		    		(lf->lr_seq != (tcp_hdr->th_seq + tlen))) {
789 				lf->lr_seq = tcp_hdr->th_seq + tlen;
797 	HTONL(tcp_hdr->th_seq);
798 	HTONL(tcp_hdr->th_ack);
800 		tcp_lro_insert_flow(NULL, ip_hdr, tcp_hdr, tlen, 0, hash,
805 	NTOHL(tcp_hdr->th_seq);
806 	NTOHL(tcp_hdr->th_ack);
810 			tcp_hdr->th_sport, tcp_hdr->th_dport, tcp_hdr->th_seq);