215 	terminal = ((sp->hdr.flags & RXRPC_LAST_PACKET) &&  in rxrpc_fast_process_data()
216 		    !(sp->hdr.flags & RXRPC_CLIENT_INITIATED));  in rxrpc_fast_process_data()
233 	if (sp->hdr.flags & RXRPC_LAST_PACKET)  in rxrpc_fast_process_data()
249 	rxrpc_propose_ACK(call, RXRPC_ACK_DELAY, sp->hdr.serial, false);  in rxrpc_fast_process_data()
262 	__rxrpc_propose_ACK(call, ack, sp->hdr.serial, true);  in rxrpc_fast_process_data()
270 	__rxrpc_propose_ACK(call, ack, sp->hdr.serial, true);  in rxrpc_fast_process_data()
329 	if (sp->hdr.type == RXRPC_PACKET_TYPE_DATA) {  in rxrpc_fast_process_packet()
341 	serial = ntohl(sp->hdr.serial);  in rxrpc_fast_process_packet()
349 	if (sp->hdr.flags & RXRPC_REQUEST_ACK) {  in rxrpc_fast_process_packet()
351 		rxrpc_propose_ACK(call, RXRPC_ACK_REQUESTED, sp->hdr.serial,  in rxrpc_fast_process_packet()
352 				  !(sp->hdr.flags & RXRPC_MORE_PACKETS));  in rxrpc_fast_process_packet()
355 	switch (sp->hdr.type) {  in rxrpc_fast_process_packet()
394 		_proto("Rx %s %%%u", rxrpc_pkts[sp->hdr.type], serial);  in rxrpc_fast_process_packet()
398 		seq = ntohl(sp->hdr.seq);  in rxrpc_fast_process_packet()
405 		call->ackr_prev_seq = sp->hdr.seq;  in rxrpc_fast_process_packet()
470 		sp->hdr.flags &= ~RXRPC_JUMBO_PACKET;  in rxrpc_process_jumbo_packet()
492 		sp->hdr.seq	= htonl(ntohl(sp->hdr.seq) + 1);  in rxrpc_process_jumbo_packet()
493 		sp->hdr.serial	= htonl(ntohl(sp->hdr.serial) + 1);  in rxrpc_process_jumbo_packet()
494 		sp->hdr.flags	= jhdr.flags;  in rxrpc_process_jumbo_packet()
495 		sp->hdr._rsvd	= jhdr._rsvd;  in rxrpc_process_jumbo_packet()
497 		_proto("Rx DATA Jumbo %%%u", ntohl(sp->hdr.serial) - 1);  in rxrpc_process_jumbo_packet()
502 	} while (sp->hdr.flags & RXRPC_JUMBO_PACKET);  in rxrpc_process_jumbo_packet()
542 	call = conn->channels[ntohl(sp->hdr.cid) & RXRPC_CHANNELMASK];  in rxrpc_post_packet_to_call()
543 	if (!call || call->call_id != sp->hdr.callNumber)  in rxrpc_post_packet_to_call()
566 	if (sp->hdr.type == RXRPC_PACKET_TYPE_DATA &&  in rxrpc_post_packet_to_call()
567 	    sp->hdr.flags & RXRPC_JUMBO_PACKET)  in rxrpc_post_packet_to_call()
580 	call_id = sp->hdr.callNumber;  in rxrpc_post_packet_to_call()
598 	if (sp->hdr.flags & RXRPC_CLIENT_INITIATED &&  in rxrpc_post_packet_to_call()
599 	    sp->hdr.seq == cpu_to_be32(1)) {  in rxrpc_post_packet_to_call()
729 	if (skb_copy_bits(skb, sizeof(struct udphdr), &sp->hdr,  in rxrpc_data_ready()
730 			  sizeof(sp->hdr)) < 0)  in rxrpc_data_ready()
732 	if (!pskb_pull(skb, sizeof(struct udphdr) + sizeof(sp->hdr)))  in rxrpc_data_ready()
736 	     sp->hdr.flags & RXRPC_CLIENT_INITIATED ? "ToServer" : "ToClient",  in rxrpc_data_ready()
737 	     ntohl(sp->hdr.epoch),  in rxrpc_data_ready()
738 	     ntohl(sp->hdr.cid),  in rxrpc_data_ready()
739 	     ntohl(sp->hdr.callNumber));  in rxrpc_data_ready()
741 	if (sp->hdr.type == 0 || sp->hdr.type >= RXRPC_N_PACKET_TYPES) {  in rxrpc_data_ready()
742 		_proto("Rx Bad Packet Type %u", sp->hdr.type);  in rxrpc_data_ready()
746 	if (sp->hdr.type == RXRPC_PACKET_TYPE_DATA &&  in rxrpc_data_ready()
747 	    (sp->hdr.callNumber == 0 || sp->hdr.seq == 0))  in rxrpc_data_ready()
759 	conn = rxrpc_find_connection(trans, &sp->hdr);  in rxrpc_data_ready()
766 	if (sp->hdr.callNumber == 0)  in rxrpc_data_ready()
776 	if (sp->hdr.flags & RXRPC_CLIENT_INITIATED &&  in rxrpc_data_ready()
777 	    sp->hdr.type == RXRPC_PACKET_TYPE_DATA) {  in rxrpc_data_ready()
778 		if (sp->hdr.seq == cpu_to_be32(1)) {  in rxrpc_data_ready()