Lines Matching refs:ack
338 struct rxrpc_ackpacket *ack, in rxrpc_process_soft_ACKs() argument
350 ack->nAcks); in rxrpc_process_soft_ACKs()
352 if (skb_copy_bits(skb, 0, sacks, ack->nAcks) < 0) in rxrpc_process_soft_ACKs()
357 for (loop = 0; loop < ack->nAcks; loop++) { in rxrpc_process_soft_ACKs()
634 struct rxrpc_ackpacket ack; in rxrpc_process_rx_queue() local
672 if (skb_copy_bits(skb, 0, &ack, sizeof(ack)) < 0) { in rxrpc_process_rx_queue()
676 if (!skb_pull(skb, sizeof(ack))) in rxrpc_process_rx_queue()
680 hard = ntohl(ack.firstPacket); in rxrpc_process_rx_queue()
685 ntohs(ack.maxSkew), in rxrpc_process_rx_queue()
687 ntohl(ack.previousPacket), in rxrpc_process_rx_queue()
688 ntohl(ack.serial), in rxrpc_process_rx_queue()
689 rxrpc_acks(ack.reason), in rxrpc_process_rx_queue()
690 ack.nAcks); in rxrpc_process_rx_queue()
692 rxrpc_extract_ackinfo(call, skb, latest, ack.nAcks); in rxrpc_process_rx_queue()
694 if (ack.reason == RXRPC_ACK_PING) { in rxrpc_process_rx_queue()
735 if (ack.nAcks > 0) { in rxrpc_process_rx_queue()
736 if (hard - 1 + ack.nAcks > tx) { in rxrpc_process_rx_queue()
739 hard - 1, ack.nAcks, tx); in rxrpc_process_rx_queue()
743 if (rxrpc_process_soft_ACKs(call, &ack, skb) < 0) in rxrpc_process_rx_queue()
884 struct rxrpc_ackpacket ack; in rxrpc_process_call() local
990 ack.bufferSpace = htons(8); in rxrpc_process_call()
991 ack.maxSkew = 0; in rxrpc_process_call()
992 ack.serial = 0; in rxrpc_process_call()
993 ack.reason = RXRPC_ACK_IDLE; in rxrpc_process_call()
994 ack.nAcks = 0; in rxrpc_process_call()
998 ack.serial = call->ackr_serial; in rxrpc_process_call()
999 ack.previousPacket = call->ackr_prev_seq; in rxrpc_process_call()
1000 ack.firstPacket = htonl(call->rx_data_eaten + 1); in rxrpc_process_call()
1005 iov[1].iov_base = &ack; in rxrpc_process_call()
1006 iov[1].iov_len = sizeof(ack); in rxrpc_process_call()
1100 ack.bufferSpace = htons(8); in rxrpc_process_call()
1101 ack.maxSkew = 0; in rxrpc_process_call()
1102 ack.serial = 0; in rxrpc_process_call()
1103 ack.reason = 0; in rxrpc_process_call()
1106 ack.reason = call->ackr_reason; in rxrpc_process_call()
1107 ack.serial = call->ackr_serial; in rxrpc_process_call()
1108 ack.previousPacket = call->ackr_prev_seq; in rxrpc_process_call()
1109 ack.firstPacket = htonl(call->rx_data_eaten + 1); in rxrpc_process_call()
1111 ack.nAcks = 0; in rxrpc_process_call()
1119 ack.nAcks = nbit + 1; in rxrpc_process_call()
1129 iov[1].iov_base = &ack; in rxrpc_process_call()
1130 iov[1].iov_len = sizeof(ack); in rxrpc_process_call()
1132 iov[2].iov_len = ack.nAcks; in rxrpc_process_call()
1138 switch (ack.reason) { in rxrpc_process_call()
1215 ack.maxSkew = htons(atomic_read(&call->conn->hi_serial) - in rxrpc_process_call()
1216 ntohl(ack.serial)); in rxrpc_process_call()
1230 ntohs(ack.maxSkew), in rxrpc_process_call()
1231 ntohl(ack.firstPacket), in rxrpc_process_call()
1232 ntohl(ack.previousPacket), in rxrpc_process_call()
1233 ntohl(ack.serial), in rxrpc_process_call()
1234 rxrpc_acks(ack.reason), in rxrpc_process_call()
1235 ack.nAcks); in rxrpc_process_call()
1238 if (ack.nAcks > 0) in rxrpc_process_call()