Lines Matching refs:ack
337 struct rxrpc_ackpacket *ack, in rxrpc_process_soft_ACKs() argument
349 ack->nAcks); in rxrpc_process_soft_ACKs()
351 if (skb_copy_bits(skb, 0, sacks, ack->nAcks) < 0) in rxrpc_process_soft_ACKs()
356 for (loop = 0; loop < ack->nAcks; loop++) { in rxrpc_process_soft_ACKs()
633 struct rxrpc_ackpacket ack; in rxrpc_process_rx_queue() local
671 if (skb_copy_bits(skb, 0, &ack, sizeof(ack)) < 0) { in rxrpc_process_rx_queue()
675 if (!skb_pull(skb, sizeof(ack))) in rxrpc_process_rx_queue()
679 hard = ntohl(ack.firstPacket); in rxrpc_process_rx_queue()
684 ntohs(ack.maxSkew), in rxrpc_process_rx_queue()
686 ntohl(ack.previousPacket), in rxrpc_process_rx_queue()
687 ntohl(ack.serial), in rxrpc_process_rx_queue()
688 rxrpc_acks(ack.reason), in rxrpc_process_rx_queue()
689 ack.nAcks); in rxrpc_process_rx_queue()
691 rxrpc_extract_ackinfo(call, skb, latest, ack.nAcks); in rxrpc_process_rx_queue()
693 if (ack.reason == RXRPC_ACK_PING) { in rxrpc_process_rx_queue()
732 if (ack.nAcks > 0) { in rxrpc_process_rx_queue()
733 if (hard - 1 + ack.nAcks > tx) { in rxrpc_process_rx_queue()
736 hard - 1, ack.nAcks, tx); in rxrpc_process_rx_queue()
740 if (rxrpc_process_soft_ACKs(call, &ack, skb) < 0) in rxrpc_process_rx_queue()
881 struct rxrpc_ackpacket ack; in rxrpc_process_call() local
987 ack.bufferSpace = htons(8); in rxrpc_process_call()
988 ack.maxSkew = 0; in rxrpc_process_call()
989 ack.serial = 0; in rxrpc_process_call()
990 ack.reason = RXRPC_ACK_IDLE; in rxrpc_process_call()
991 ack.nAcks = 0; in rxrpc_process_call()
995 ack.serial = call->ackr_serial; in rxrpc_process_call()
996 ack.previousPacket = call->ackr_prev_seq; in rxrpc_process_call()
997 ack.firstPacket = htonl(call->rx_data_eaten + 1); in rxrpc_process_call()
1002 iov[1].iov_base = &ack; in rxrpc_process_call()
1003 iov[1].iov_len = sizeof(ack); in rxrpc_process_call()
1097 ack.bufferSpace = htons(8); in rxrpc_process_call()
1098 ack.maxSkew = 0; in rxrpc_process_call()
1099 ack.serial = 0; in rxrpc_process_call()
1100 ack.reason = 0; in rxrpc_process_call()
1103 ack.reason = call->ackr_reason; in rxrpc_process_call()
1104 ack.serial = call->ackr_serial; in rxrpc_process_call()
1105 ack.previousPacket = call->ackr_prev_seq; in rxrpc_process_call()
1106 ack.firstPacket = htonl(call->rx_data_eaten + 1); in rxrpc_process_call()
1108 ack.nAcks = 0; in rxrpc_process_call()
1116 ack.nAcks = nbit + 1; in rxrpc_process_call()
1126 iov[1].iov_base = &ack; in rxrpc_process_call()
1127 iov[1].iov_len = sizeof(ack); in rxrpc_process_call()
1129 iov[2].iov_len = ack.nAcks; in rxrpc_process_call()
1135 switch (ack.reason) { in rxrpc_process_call()
1212 ack.maxSkew = htons(atomic_read(&call->conn->hi_serial) - in rxrpc_process_call()
1213 ntohl(ack.serial)); in rxrpc_process_call()
1227 ntohs(ack.maxSkew), in rxrpc_process_call()
1228 ntohl(ack.firstPacket), in rxrpc_process_call()
1229 ntohl(ack.previousPacket), in rxrpc_process_call()
1230 ntohl(ack.serial), in rxrpc_process_call()
1231 rxrpc_acks(ack.reason), in rxrpc_process_call()
1232 ack.nAcks); in rxrpc_process_call()
1235 if (ack.nAcks > 0) in rxrpc_process_call()