85 	struct rxrpc_skb_priv *sp = rxrpc_skb(skb);  in rxrpc_direct_abort()  local
87 	trace_rxrpc_abort(0, why, sp->hdr.cid, sp->hdr.callNumber, sp->hdr.seq,  in rxrpc_direct_abort()
106 	struct rxrpc_skb_priv *sp = rxrpc_skb(skb);  in rxrpc_input_version()  local
114 			rxrpc_send_version_request(local, &sp->hdr, skb);  in rxrpc_input_version()
123 static bool rxrpc_extract_header(struct rxrpc_skb_priv *sp,  in rxrpc_extract_header()  argument
132 	memset(sp, 0, sizeof(*sp));  in rxrpc_extract_header()
133 	sp->hdr.epoch		= ntohl(whdr.epoch);  in rxrpc_extract_header()
134 	sp->hdr.cid		= ntohl(whdr.cid);  in rxrpc_extract_header()
135 	sp->hdr.callNumber	= ntohl(whdr.callNumber);  in rxrpc_extract_header()
136 	sp->hdr.seq		= ntohl(whdr.seq);  in rxrpc_extract_header()
137 	sp->hdr.serial		= ntohl(whdr.serial);  in rxrpc_extract_header()
138 	sp->hdr.flags		= whdr.flags;  in rxrpc_extract_header()
139 	sp->hdr.type		= whdr.type;  in rxrpc_extract_header()
140 	sp->hdr.userStatus	= whdr.userStatus;  in rxrpc_extract_header()
141 	sp->hdr.securityIndex	= whdr.securityIndex;  in rxrpc_extract_header()
142 	sp->hdr._rsvd		= ntohs(whdr._rsvd);  in rxrpc_extract_header()
143 	sp->hdr.serviceId	= ntohs(whdr.serviceId);  in rxrpc_extract_header()
168 	struct rxrpc_skb_priv *sp;  in rxrpc_input_packet()  local
175 	sp = rxrpc_skb(skb);  in rxrpc_input_packet()
178 	if (!rxrpc_extract_header(sp, skb))  in rxrpc_input_packet()
184 			trace_rxrpc_rx_lose(sp);  in rxrpc_input_packet()
189 	trace_rxrpc_rx_packet(sp);  in rxrpc_input_packet()
191 	switch (sp->hdr.type) {  in rxrpc_input_packet()
193 		if (rxrpc_to_client(sp))  in rxrpc_input_packet()
198 		if (rxrpc_to_server(sp))  in rxrpc_input_packet()
203 		if (sp->hdr.callNumber == 0)  in rxrpc_input_packet()
212 		if (sp->hdr.callNumber == 0)  in rxrpc_input_packet()
214 		if (sp->hdr.seq == 0)  in rxrpc_input_packet()
220 		if (sp->hdr.securityIndex != 0) {  in rxrpc_input_packet()
232 				sp = rxrpc_skb(skb);  in rxrpc_input_packet()
238 		if (rxrpc_to_server(sp))  in rxrpc_input_packet()
242 		if (rxrpc_to_client(sp))  in rxrpc_input_packet()
256 	if (sp->hdr.serviceId == 0)  in rxrpc_input_packet()
271 	if (rxrpc_to_client(sp)) {  in rxrpc_input_packet()
320 	struct rxrpc_skb_priv *sp = rxrpc_skb(skb);  in rxrpc_input_packet_on_conn()  local
326 	if (sp->hdr.securityIndex != conn->security_ix)  in rxrpc_input_packet_on_conn()
330 	if (sp->hdr.serviceId != conn->service_id) {  in rxrpc_input_packet_on_conn()
337 				 sp->hdr.serviceId);  in rxrpc_input_packet_on_conn()
339 		    old_id != sp->hdr.serviceId)  in rxrpc_input_packet_on_conn()
343 	if (after(sp->hdr.serial, conn->hi_serial))  in rxrpc_input_packet_on_conn()
344 		conn->hi_serial = sp->hdr.serial;  in rxrpc_input_packet_on_conn()
347 	if (sp->hdr.callNumber == 0)  in rxrpc_input_packet_on_conn()
351 	channel = sp->hdr.cid & RXRPC_CHANNELMASK;  in rxrpc_input_packet_on_conn()
355 	if (sp->hdr.callNumber < chan->last_call)  in rxrpc_input_packet_on_conn()
358 	if (sp->hdr.callNumber == chan->last_call) {  in rxrpc_input_packet_on_conn()
360 		    sp->hdr.type == RXRPC_PACKET_TYPE_ABORT)  in rxrpc_input_packet_on_conn()
373 		if (sp->hdr.type == RXRPC_PACKET_TYPE_DATA)  in rxrpc_input_packet_on_conn()
375 					    sp->hdr.seq,  in rxrpc_input_packet_on_conn()
376 					    sp->hdr.serial,  in rxrpc_input_packet_on_conn()
377 					    sp->hdr.flags);  in rxrpc_input_packet_on_conn()
384 	if (sp->hdr.callNumber > chan->call_id) {  in rxrpc_input_packet_on_conn()
385 		if (rxrpc_to_client(sp)) {  in rxrpc_input_packet_on_conn()
399 		if (rxrpc_to_client(sp))  in rxrpc_input_packet_on_conn()
471 			struct rxrpc_skb_priv *sp = rxrpc_skb(skb);  in rxrpc_io_thread()  local
485 				rxrpc_input_conn_event(sp->conn, skb);  in rxrpc_io_thread()
486 				rxrpc_put_connection(sp->conn, rxrpc_conn_put_poke);  in rxrpc_io_thread()