Lines Matching refs:sp
217 struct rxrpc_skb_priv *sp; in rxrpc_resend() local
244 sp = rxrpc_skb(txb); in rxrpc_resend()
246 if (sp->need_resend) { in rxrpc_resend()
247 sp->need_resend = false; in rxrpc_resend()
250 sp->hdr.serial = in rxrpc_resend()
254 hdr->serial = sp->hdr.serial; in rxrpc_resend()
257 ntohl(sp->hdr.serial), ntohl(sp->hdr.seq)); in rxrpc_resend()
260 sp->resend_at = jiffies + 3; in rxrpc_resend()
262 sp->resend_at = in rxrpc_resend()
267 if (time_after_eq(jiffies + 1, sp->resend_at)) { in rxrpc_resend()
268 sp->need_resend = true; in rxrpc_resend()
271 if (time_before(sp->resend_at, resend_at)) in rxrpc_resend()
272 resend_at = sp->resend_at; in rxrpc_resend()
274 resend_at = sp->resend_at; in rxrpc_resend()
288 struct rxrpc_skb_priv *sp; in rxrpc_resend_timer() local
310 sp = rxrpc_skb(txb); in rxrpc_resend_timer()
314 if (sp->need_resend) { in rxrpc_resend_timer()
316 } else if (time_after_eq(jiffies + 1, sp->resend_at)) { in rxrpc_resend_timer()
317 sp->need_resend = true; in rxrpc_resend_timer()
320 if (time_before(sp->resend_at, resend_at)) in rxrpc_resend_timer()
321 resend_at = sp->resend_at; in rxrpc_resend_timer()
323 resend_at = sp->resend_at; in rxrpc_resend_timer()
341 struct rxrpc_skb_priv *sp; in rxrpc_process_soft_ACKs() local
362 sp = rxrpc_skb(txb); in rxrpc_process_soft_ACKs()
366 sp->need_resend = false; in rxrpc_process_soft_ACKs()
370 sp->need_resend = true; in rxrpc_process_soft_ACKs()
392 sp = rxrpc_skb(txb); in rxrpc_process_soft_ACKs()
396 sp->need_resend = true; in rxrpc_process_soft_ACKs()
399 } else if (sp->need_resend) { in rxrpc_process_soft_ACKs()
401 } else if (time_after_eq(jiffies + 1, sp->resend_at)) { in rxrpc_process_soft_ACKs()
402 sp->need_resend = true; in rxrpc_process_soft_ACKs()
405 if (time_before(sp->resend_at, resend_at)) in rxrpc_process_soft_ACKs()
406 resend_at = sp->resend_at; in rxrpc_process_soft_ACKs()
408 resend_at = sp->resend_at; in rxrpc_process_soft_ACKs()
463 struct rxrpc_skb_priv *sp; in rxrpc_drain_rx_oos_queue() local
478 sp = rxrpc_skb(skb); in rxrpc_drain_rx_oos_queue()
481 ntohl(sp->hdr.seq), call->rx_first_oos); in rxrpc_drain_rx_oos_queue()
483 if (ntohl(sp->hdr.seq) != call->rx_first_oos) { in rxrpc_drain_rx_oos_queue()
489 terminal = ((sp->hdr.flags & RXRPC_LAST_PACKET) && in rxrpc_drain_rx_oos_queue()
490 !(sp->hdr.flags & RXRPC_CLIENT_INITIATED)); in rxrpc_drain_rx_oos_queue()
520 struct rxrpc_skb_priv *sp, *psp; in rxrpc_insert_oos_packet() local
524 sp = rxrpc_skb(skb); in rxrpc_insert_oos_packet()
525 seq = ntohl(sp->hdr.seq); in rxrpc_insert_oos_packet()
529 ASSERTCMP(sp->call, ==, NULL); in rxrpc_insert_oos_packet()
530 sp->call = call; in rxrpc_insert_oos_packet()
571 struct rxrpc_skb_priv *sp; in rxrpc_zap_tx_window() local
588 sp = rxrpc_skb(skb); in rxrpc_zap_tx_window()
589 _debug("+++ clear Tx %u", ntohl(sp->hdr.seq)); in rxrpc_zap_tx_window()
635 struct rxrpc_skb_priv *sp; in rxrpc_process_rx_queue() local
650 sp = rxrpc_skb(skb); in rxrpc_process_rx_queue()
652 _debug("process %s [st %d]", rxrpc_pkts[sp->hdr.type], call->state); in rxrpc_process_rx_queue()
656 switch (sp->hdr.type) { in rxrpc_process_rx_queue()
661 ntohl(sp->hdr.serial), ntohl(sp->hdr.seq)); in rxrpc_process_rx_queue()
679 latest = ntohl(sp->hdr.serial); in rxrpc_process_rx_queue()
697 sp->hdr.serial, true); in rxrpc_process_rx_queue()
805 sp->call = call; in rxrpc_process_rx_queue()
832 struct rxrpc_skb_priv *sp; in rxrpc_post_message() local
861 sp = rxrpc_skb(skb); in rxrpc_post_message()
862 memset(sp, 0, sizeof(*sp)); in rxrpc_post_message()
863 sp->error = error; in rxrpc_post_message()
864 sp->call = call; in rxrpc_post_message()