Lines Matching refs:sp
91 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_direct_abort() local
93 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_direct_conn_abort() local
108 trace_rxrpc_abort(0, why, sp->hdr.cid, 0, sp->hdr.seq, abort_code, err); in rxrpc_direct_conn_abort()
126 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_input_version() local
134 rxrpc_send_version_request(local, &sp->hdr, skb); in rxrpc_input_version()
143 static bool rxrpc_extract_header(struct rxrpc_skb_priv *sp, in rxrpc_extract_header() argument
153 memset(sp, 0, sizeof(*sp)); in rxrpc_extract_header()
154 sp->hdr.epoch = ntohl(whdr.epoch); in rxrpc_extract_header()
155 sp->hdr.cid = ntohl(whdr.cid); in rxrpc_extract_header()
156 sp->hdr.callNumber = ntohl(whdr.callNumber); in rxrpc_extract_header()
157 sp->hdr.seq = ntohl(whdr.seq); in rxrpc_extract_header()
158 sp->hdr.serial = ntohl(whdr.serial); in rxrpc_extract_header()
159 sp->hdr.flags = whdr.flags; in rxrpc_extract_header()
160 sp->hdr.type = whdr.type; in rxrpc_extract_header()
161 sp->hdr.userStatus = whdr.userStatus; in rxrpc_extract_header()
162 sp->hdr.securityIndex = whdr.securityIndex; in rxrpc_extract_header()
163 sp->hdr._rsvd = ntohs(whdr._rsvd); in rxrpc_extract_header()
164 sp->hdr.serviceId = ntohs(whdr.serviceId); in rxrpc_extract_header()
166 if (sp->hdr.type == RXRPC_PACKET_TYPE_ACK) { in rxrpc_extract_header()
169 sp->ack.first_ack = ntohl(ack.firstPacket); in rxrpc_extract_header()
170 sp->ack.prev_ack = ntohl(ack.previousPacket); in rxrpc_extract_header()
171 sp->ack.acked_serial = ntohl(ack.serial); in rxrpc_extract_header()
172 sp->ack.reason = ack.reason; in rxrpc_extract_header()
173 sp->ack.nr_acks = ack.nAcks; in rxrpc_extract_header()
199 struct rxrpc_skb_priv *sp; in rxrpc_input_packet() local
206 sp = rxrpc_skb(skb); in rxrpc_input_packet()
209 if (!rxrpc_extract_header(sp, skb)) in rxrpc_input_packet()
215 trace_rxrpc_rx_lose(sp); in rxrpc_input_packet()
220 trace_rxrpc_rx_packet(sp); in rxrpc_input_packet()
222 switch (sp->hdr.type) { in rxrpc_input_packet()
224 if (rxrpc_to_client(sp)) in rxrpc_input_packet()
229 if (rxrpc_to_server(sp)) in rxrpc_input_packet()
234 if (sp->hdr.callNumber == 0) in rxrpc_input_packet()
243 if (sp->hdr.callNumber == 0) in rxrpc_input_packet()
245 if (sp->hdr.seq == 0) in rxrpc_input_packet()
251 if (sp->hdr.securityIndex != 0) { in rxrpc_input_packet()
263 sp = rxrpc_skb(skb); in rxrpc_input_packet()
269 if (rxrpc_to_server(sp)) in rxrpc_input_packet()
273 if (rxrpc_to_client(sp)) in rxrpc_input_packet()
287 if (sp->hdr.serviceId == 0) in rxrpc_input_packet()
302 if (rxrpc_to_client(sp)) { in rxrpc_input_packet()
351 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_input_packet_on_conn() local
356 if (sp->hdr.securityIndex != conn->security_ix) in rxrpc_input_packet_on_conn()
360 if (sp->hdr.serviceId != conn->service_id) { in rxrpc_input_packet_on_conn()
367 sp->hdr.serviceId); in rxrpc_input_packet_on_conn()
369 old_id != sp->hdr.serviceId) in rxrpc_input_packet_on_conn()
373 if (after(sp->hdr.serial, conn->hi_serial)) in rxrpc_input_packet_on_conn()
374 conn->hi_serial = sp->hdr.serial; in rxrpc_input_packet_on_conn()
377 if (sp->hdr.callNumber == 0) in rxrpc_input_packet_on_conn()
381 if (sp->hdr.type == RXRPC_PACKET_TYPE_ACK && in rxrpc_input_packet_on_conn()
383 after_eq(sp->ack.acked_serial, conn->pmtud_probe)) in rxrpc_input_packet_on_conn()
384 rxrpc_input_probe_for_pmtud(conn, sp->ack.acked_serial, false); in rxrpc_input_packet_on_conn()
387 channel = sp->hdr.cid & RXRPC_CHANNELMASK; in rxrpc_input_packet_on_conn()
391 if (sp->hdr.callNumber < chan->last_call) in rxrpc_input_packet_on_conn()
394 if (sp->hdr.callNumber == chan->last_call) { in rxrpc_input_packet_on_conn()
396 sp->hdr.type == RXRPC_PACKET_TYPE_ABORT) in rxrpc_input_packet_on_conn()
409 if (sp->hdr.type == RXRPC_PACKET_TYPE_DATA) in rxrpc_input_packet_on_conn()
411 sp->hdr.seq, in rxrpc_input_packet_on_conn()
412 sp->hdr.serial, in rxrpc_input_packet_on_conn()
413 sp->hdr.flags); in rxrpc_input_packet_on_conn()
420 if (sp->hdr.callNumber > chan->call_id) { in rxrpc_input_packet_on_conn()
421 if (rxrpc_to_client(sp)) { in rxrpc_input_packet_on_conn()
435 if (rxrpc_to_client(sp)) in rxrpc_input_packet_on_conn()
492 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_io_thread() local
506 rxrpc_input_conn_event(sp->poke_conn, skb); in rxrpc_io_thread()
507 rxrpc_put_connection(sp->poke_conn, rxrpc_conn_put_poke); in rxrpc_io_thread()