ethernet/neterion/s2io.c

2971 	if (ring_data->lro) {
2974 			struct lro *lro = &ring_data->lro0_n[i];
2975 			if (lro->in_use) {
2976 				update_L3L4_header(ring_data->nic, lro);
2977 				queue_rx_frame(lro->parent, lro->vlan_tag);
2978 				clear_lro_session(lro);
7120 		ring->lro = !!(dev->features & NETIF_F_LRO);
7288 	struct lro *lro;
7374 	    ((!ring_data->lro) ||
7386 			if (ring_data->lro) {
7393 							    &tcp_len, &lro,
7397 					lro->parent = skb;
7400 					lro_append_pkt(sp, lro, skb, tcp_len);
7403 					lro_append_pkt(sp, lro, skb, tcp_len);
7404 					queue_rx_frame(lro->parent,
7405 						       lro->vlan_tag);
7406 					clear_lro_session(lro);
7410 					lro->parent->data_len = lro->frags_len;
7412 					queue_rx_frame(lro->parent,
7413 						       lro->vlan_tag);
7414 					clear_lro_session(lro);
8202 static int check_for_socket_match(struct lro *lro, struct iphdr *ip,
8206 	if ((lro->iph->saddr != ip->saddr) ||
8207 	    (lro->iph->daddr != ip->daddr) ||
8208 	    (lro->tcph->source != tcp->source) ||
8209 	    (lro->tcph->dest != tcp->dest))
8219 static void initiate_new_session(struct lro *lro, u8 *l2h,
8224 	lro->l2h = l2h;
8225 	lro->iph = ip;
8226 	lro->tcph = tcp;
8227 	lro->tcp_next_seq = tcp_pyld_len + ntohl(tcp->seq);
8228 	lro->tcp_ack = tcp->ack_seq;
8229 	lro->sg_num = 1;
8230 	lro->total_len = ntohs(ip->tot_len);
8231 	lro->frags_len = 0;
8232 	lro->vlan_tag = vlan_tag;
8240 		lro->saw_ts = 1;
8241 		lro->cur_tsval = ntohl(*(ptr+1));
8242 		lro->cur_tsecr = *(ptr+2);
8244 	lro->in_use = 1;
8247 static void update_L3L4_header(struct s2io_nic *sp, struct lro *lro)
8249 	struct iphdr *ip = lro->iph;
8250 	struct tcphdr *tcp = lro->tcph;
8256 	csum_replace2(&ip->check, ip->tot_len, htons(lro->total_len));
8257 	ip->tot_len = htons(lro->total_len);
8260 	tcp->ack_seq = lro->tcp_ack;
8261 	tcp->window = lro->window;
8264 	if (lro->saw_ts) {
8266 		*(ptr+2) = lro->cur_tsecr;
8272 	swstats->sum_avg_pkts_aggregated += lro->sg_num;
8276 static void aggregate_new_rx(struct lro *lro, struct iphdr *ip,
8280 	lro->total_len += l4_pyld;
8281 	lro->frags_len += l4_pyld;
8282 	lro->tcp_next_seq += l4_pyld;
8283 	lro->sg_num++;
8286 	lro->tcp_ack = tcp->ack_seq;
8287 	lro->window = tcp->window;
8289 	if (lro->saw_ts) {
8293 		lro->cur_tsval = ntohl(*(ptr+1));
8294 		lro->cur_tsecr = *(ptr + 2);
8298 static int verify_l3_l4_lro_capable(struct lro *l_lro, struct iphdr *ip,
8357 				 u8 **tcp, u32 *tcp_len, struct lro **lro,
8377 		struct lro *l_lro = &ring_data->lro0_n[i];
8382 			*lro = l_lro;
8384 			if ((*lro)->tcp_next_seq != ntohl(tcph->seq)) {
8388 					  (*lro)->tcp_next_seq,
8415 			struct lro *l_lro = &ring_data->lro0_n[i];
8417 				*lro = l_lro;
8427 		*lro = NULL;
8433 		initiate_new_session(*lro, buffer, ip, tcph, *tcp_len,
8437 		update_L3L4_header(sp, *lro);
8440 		aggregate_new_rx(*lro, ip, tcph, *tcp_len);
8441 		if ((*lro)->sg_num == sp->lro_max_aggr_per_sess) {
8442 			update_L3L4_header(sp, *lro);
8454 static void clear_lro_session(struct lro *lro)
8456 	static u16 lro_struct_size = sizeof(struct lro);
8458 	memset(lro, 0, lro_struct_size);
8475 static void lro_append_pkt(struct s2io_nic *sp, struct lro *lro,
8478 	struct sk_buff *first = lro->parent;
8482 	first->data_len = lro->frags_len;
8485 		lro->last_frag->next = skb;
8489 	lro->last_frag = skb;