Lines Matching refs:pkt

60 				 struct rxrpc_ack_buffer *pkt,  in rxrpc_fill_out_ack()  argument
69 u8 *ackp = pkt->acks; in rxrpc_fill_out_ack()
78 pkt->ack.bufferSpace = htons(8); in rxrpc_fill_out_ack()
79 pkt->ack.maxSkew = htons(call->ackr_skew); in rxrpc_fill_out_ack()
80 pkt->ack.firstPacket = htonl(hard_ack + 1); in rxrpc_fill_out_ack()
81 pkt->ack.previousPacket = htonl(call->ackr_prev_seq); in rxrpc_fill_out_ack()
82 pkt->ack.serial = htonl(serial); in rxrpc_fill_out_ack()
83 pkt->ack.reason = reason; in rxrpc_fill_out_ack()
84 pkt->ack.nAcks = top - hard_ack; in rxrpc_fill_out_ack()
87 pkt->whdr.flags |= RXRPC_REQUEST_ACK; in rxrpc_fill_out_ack()
104 pkt->ackinfo.rxMTU = htonl(rxrpc_rx_mtu); in rxrpc_fill_out_ack()
105 pkt->ackinfo.maxMTU = htonl(mtu); in rxrpc_fill_out_ack()
106 pkt->ackinfo.rwind = htonl(call->rx_winsize); in rxrpc_fill_out_ack()
107 pkt->ackinfo.jumbo_max = htonl(jmax); in rxrpc_fill_out_ack()
122 struct rxrpc_ack_buffer *pkt; in rxrpc_send_ack_packet() local
138 pkt = kzalloc(sizeof(*pkt), GFP_KERNEL); in rxrpc_send_ack_packet()
139 if (!pkt) { in rxrpc_send_ack_packet()
150 pkt->whdr.epoch = htonl(conn->proto.epoch); in rxrpc_send_ack_packet()
151 pkt->whdr.cid = htonl(call->cid); in rxrpc_send_ack_packet()
152 pkt->whdr.callNumber = htonl(call->call_id); in rxrpc_send_ack_packet()
153 pkt->whdr.seq = 0; in rxrpc_send_ack_packet()
154 pkt->whdr.type = RXRPC_PACKET_TYPE_ACK; in rxrpc_send_ack_packet()
155 pkt->whdr.flags = RXRPC_SLOW_START_OK | conn->out_clientflag; in rxrpc_send_ack_packet()
156 pkt->whdr.userStatus = 0; in rxrpc_send_ack_packet()
157 pkt->whdr.securityIndex = call->security_ix; in rxrpc_send_ack_packet()
158 pkt->whdr._rsvd = 0; in rxrpc_send_ack_packet()
159 pkt->whdr.serviceId = htons(call->service_id); in rxrpc_send_ack_packet()
173 n = rxrpc_fill_out_ack(conn, call, pkt, &hard_ack, &top, reason); in rxrpc_send_ack_packet()
177 iov[0].iov_base = pkt; in rxrpc_send_ack_packet()
178 iov[0].iov_len = sizeof(pkt->whdr) + sizeof(pkt->ack) + n; in rxrpc_send_ack_packet()
179 iov[1].iov_base = &pkt->ackinfo; in rxrpc_send_ack_packet()
180 iov[1].iov_len = sizeof(pkt->ackinfo); in rxrpc_send_ack_packet()
184 pkt->whdr.serial = htonl(serial); in rxrpc_send_ack_packet()
186 ntohl(pkt->ack.firstPacket), in rxrpc_send_ack_packet()
187 ntohl(pkt->ack.serial), in rxrpc_send_ack_packet()
188 pkt->ack.reason, pkt->ack.nAcks); in rxrpc_send_ack_packet()
211 trace_rxrpc_tx_packet(call->debug_id, &pkt->whdr, in rxrpc_send_ack_packet()
218 rxrpc_propose_ACK(call, pkt->ack.reason, in rxrpc_send_ack_packet()
219 ntohs(pkt->ack.maxSkew), in rxrpc_send_ack_packet()
220 ntohl(pkt->ack.serial), in rxrpc_send_ack_packet()
237 kfree(pkt); in rxrpc_send_ack_packet()
247 struct rxrpc_abort_buffer pkt; in rxrpc_send_abort_packet() local
276 pkt.whdr.epoch = htonl(conn->proto.epoch); in rxrpc_send_abort_packet()
277 pkt.whdr.cid = htonl(call->cid); in rxrpc_send_abort_packet()
278 pkt.whdr.callNumber = htonl(call->call_id); in rxrpc_send_abort_packet()
279 pkt.whdr.seq = 0; in rxrpc_send_abort_packet()
280 pkt.whdr.type = RXRPC_PACKET_TYPE_ABORT; in rxrpc_send_abort_packet()
281 pkt.whdr.flags = conn->out_clientflag; in rxrpc_send_abort_packet()
282 pkt.whdr.userStatus = 0; in rxrpc_send_abort_packet()
283 pkt.whdr.securityIndex = call->security_ix; in rxrpc_send_abort_packet()
284 pkt.whdr._rsvd = 0; in rxrpc_send_abort_packet()
285 pkt.whdr.serviceId = htons(call->service_id); in rxrpc_send_abort_packet()
286 pkt.abort_code = htonl(call->abort_code); in rxrpc_send_abort_packet()
288 iov[0].iov_base = &pkt; in rxrpc_send_abort_packet()
289 iov[0].iov_len = sizeof(pkt); in rxrpc_send_abort_packet()
292 pkt.whdr.serial = htonl(serial); in rxrpc_send_abort_packet()
295 &msg, iov, 1, sizeof(pkt)); in rxrpc_send_abort_packet()
301 trace_rxrpc_tx_packet(call->debug_id, &pkt.whdr, in rxrpc_send_abort_packet()