bsd/netinet/tcp_lro.c

129 			int *flow_id )
139 	*flow_id = lro_flow_map[*hash];
140 	if (*flow_id == TCP_LRO_FLOW_NOTFOUND) {
148 	flow = &lro_flow_list[*flow_id];
190 		if (ntohl(seqnum) == (ntohl(lro_flow_list[*flow_id].lr_tcphdr->th_seq) + lro_flow_list[*flow_id].lr_len)) {
203 tcp_lro_init_flow(int flow_id, struct ip* ip_hdr, struct tcphdr *tcp_hdr,
208 	flow = &lro_flow_list[flow_id];
215 	lro_flow_map[hash] = flow_id;
223 tcp_lro_coalesce(int flow_id, struct mbuf *lro_mb, struct tcphdr *tcphdr,
231 	flow =  &lro_flow_list[flow_id];
316 tcp_lro_eject_flow(int flow_id)
320 	mb = lro_flow_list[flow_id].lr_mhead;
321 	ASSERT(lro_flow_map[lro_flow_list[flow_id].lr_hash_map] == flow_id);
322 	lro_flow_map[lro_flow_list[flow_id].lr_hash_map] = TCP_LRO_FLOW_UNINIT;
323 	bzero(&lro_flow_list[flow_id], sizeof(struct lro_flow));
329 tcp_lro_eject_coalesced_pkt(int flow_id)
332 	mb = lro_flow_list[flow_id].lr_mhead;
333 	lro_flow_list[flow_id].lr_mhead =
334 		lro_flow_list[flow_id].lr_mtail = NULL;
335 	lro_flow_list[flow_id].lr_tcphdr = NULL;
406 	int flow_id = TCP_LRO_FLOW_UNINIT;
506 	retval = tcp_lro_matching_tuple(ip_hdr, tcp_hdr, &hash, &flow_id);
517 			tcp_lro_coalesce(flow_id, lro_mb, tcp_hdr, payload_len,
523 				printf("tcp_lro_process_pkt: coalesce len = %d. flow_id = %d payload_len = %d drop_hdrlen = %d optlen = %d lport = %d seqnum = %x.\n",
524 					lro_flow_list[flow_id].lr_len, flow_id,
526 					ntohs(lro_flow_list[flow_id].lr_lport),
529 			if (lro_flow_list[flow_id].lr_mhead->m_pkthdr.lro_npkts >= coalesc_sz) {
535 			mb = tcp_lro_eject_coalesced_pkt(flow_id);
536 			lro_flow_list[flow_id].lr_seq = ntohl(tcp_hdr->th_seq) +
554 		mb = tcp_lro_eject_coalesced_pkt(flow_id);
852 	int flow_id;
862 	flow_id = lro_flow_map[hash];
863 	if (flow_id != TCP_LRO_FLOW_NOTFOUND) {
864 		lf = &lro_flow_list[flow_id];
906 	int hash, flow_id;
912 	flow_id = lro_flow_map[hash];
913 	if (flow_id == TCP_LRO_FLOW_UNINIT) {
917 	lf = &lro_flow_list[flow_id];
936 	int hash, flow_id;
942 	flow_id = lro_flow_map[hash];
943 	if (flow_id == TCP_LRO_FLOW_UNINIT) {
947 	lf = &lro_flow_list[flow_id];