Lines Matching refs:sp
448 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_input_queue_data() local
449 bool last = sp->hdr.flags & RXRPC_LAST_PACKET; in rxrpc_input_queue_data()
455 trace_rxrpc_receive(call, last ? why + 1 : why, sp->hdr.serial, sp->hdr.seq); in rxrpc_input_queue_data()
461 rxrpc_end_rx_phase(call, sp->hdr.serial); in rxrpc_input_queue_data()
472 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_input_data_one() local
474 rxrpc_serial_t serial = sp->hdr.serial; in rxrpc_input_data_one()
479 rxrpc_seq_t seq = sp->hdr.seq; in rxrpc_input_data_one()
480 bool last = sp->hdr.flags & RXRPC_LAST_PACKET; in rxrpc_input_data_one()
484 if (sp->hdr.flags & RXRPC_REQUEST_ACK) in rxrpc_input_data_one()
486 if (sp->hdr.flags & RXRPC_JUMBO_PACKET) in rxrpc_input_data_one()
505 trace_rxrpc_rx_data(call->debug_id, seq, serial, sp->hdr.flags); in rxrpc_input_data_one()
518 if (sp->hdr.flags & RXRPC_REQUEST_ACK) in rxrpc_input_data_one()
593 sp->hdr.serial, sp->hdr.seq); in rxrpc_input_data_one()
615 struct rxrpc_skb_priv *sp = rxrpc_skb(skb), *jsp; in rxrpc_input_split_jumbo() local
623 while (sp->hdr.flags & RXRPC_JUMBO_PACKET) { in rxrpc_input_split_jumbo()
626 if (sp->hdr.flags & RXRPC_LAST_PACKET) in rxrpc_input_split_jumbo()
644 sp->hdr.flags = jhdr.flags; in rxrpc_input_split_jumbo()
645 sp->hdr._rsvd = ntohs(jhdr._rsvd); in rxrpc_input_split_jumbo()
646 sp->hdr.seq++; in rxrpc_input_split_jumbo()
647 sp->hdr.serial++; in rxrpc_input_split_jumbo()
653 sp->offset = offset; in rxrpc_input_split_jumbo()
654 sp->len = len; in rxrpc_input_split_jumbo()
665 rxrpc_propose_delay_ACK(call, sp->hdr.serial, in rxrpc_input_split_jumbo()
669 trace_rxrpc_notify_socket(call->debug_id, sp->hdr.serial); in rxrpc_input_split_jumbo()
684 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_input_data() local
685 rxrpc_serial_t serial = sp->hdr.serial; in rxrpc_input_data()
686 rxrpc_seq_t seq0 = sp->hdr.seq; in rxrpc_input_data()
722 rxrpc_proto_abort(call, sp->hdr.seq, rxrpc_badmsg_bad_jumbo); in rxrpc_input_data()
789 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_input_ack_trailer() local
803 trace_rxrpc_rx_rwind_change(call, sp->hdr.serial, rwind, wake); in rxrpc_input_ack_trailer()
811 trace_rxrpc_pmtud_reduce(peer, sp->hdr.serial, max_mtu, in rxrpc_input_ack_trailer()
963 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_input_soft_acks() local
968 rxrpc_seq_t lowest_nak = seq + sp->ack.nr_acks; in rxrpc_input_soft_acks()
971 _enter("%x,%x,%u", tq->qbase, seq, sp->ack.nr_acks); in rxrpc_input_soft_acks()
976 for (unsigned int i = 0; i < sp->ack.nr_acks; i++) { in rxrpc_input_soft_acks()
1060 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_input_ack() local
1068 summary.ack_serial = sp->hdr.serial; in rxrpc_input_ack()
1069 first_soft_ack = sp->ack.first_ack; in rxrpc_input_ack()
1070 prev_pkt = sp->ack.prev_ack; in rxrpc_input_ack()
1071 nr_acks = sp->ack.nr_acks; in rxrpc_input_ack()
1073 summary.acked_serial = sp->ack.acked_serial; in rxrpc_input_ack()
1074 summary.ack_reason = (sp->ack.reason < RXRPC_ACK__INVALID ? in rxrpc_input_ack()
1075 sp->ack.reason : RXRPC_ACK__INVALID); in rxrpc_input_ack()
1077 trace_rxrpc_rx_ack(call, sp); in rxrpc_input_ack()
1198 else if (sp->hdr.flags & RXRPC_REQUEST_ACK) in rxrpc_input_ack()
1219 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_input_abort() local
1221 trace_rxrpc_rx_abort(call, sp->hdr.serial, skb->priority); in rxrpc_input_abort()
1232 struct rxrpc_skb_priv *sp = rxrpc_skb(skb); in rxrpc_input_call_packet() local
1237 if (sp->hdr.serviceId != call->dest_srx.srx_service) in rxrpc_input_call_packet()
1238 call->dest_srx.srx_service = sp->hdr.serviceId; in rxrpc_input_call_packet()
1239 if ((int)sp->hdr.serial - (int)call->rx_serial > 0) in rxrpc_input_call_packet()
1240 call->rx_serial = sp->hdr.serial; in rxrpc_input_call_packet()
1252 switch (sp->hdr.type) { in rxrpc_input_call_packet()