Lines Matching refs:whdr
19 struct rxrpc_wire_header whdr; member
27 struct rxrpc_wire_header whdr; member
105 pkt->whdr.flags |= RXRPC_REQUEST_ACK; in rxrpc_fill_out_ack()
207 pkt->whdr.epoch = htonl(conn->proto.epoch); in rxrpc_send_ack_packet()
208 pkt->whdr.cid = htonl(call->cid); in rxrpc_send_ack_packet()
209 pkt->whdr.callNumber = htonl(call->call_id); in rxrpc_send_ack_packet()
210 pkt->whdr.seq = 0; in rxrpc_send_ack_packet()
211 pkt->whdr.type = RXRPC_PACKET_TYPE_ACK; in rxrpc_send_ack_packet()
212 pkt->whdr.flags = RXRPC_SLOW_START_OK | conn->out_clientflag; in rxrpc_send_ack_packet()
213 pkt->whdr.userStatus = 0; in rxrpc_send_ack_packet()
214 pkt->whdr.securityIndex = call->security_ix; in rxrpc_send_ack_packet()
215 pkt->whdr._rsvd = 0; in rxrpc_send_ack_packet()
216 pkt->whdr.serviceId = htons(call->service_id); in rxrpc_send_ack_packet()
239 iov[0].iov_len = sizeof(pkt->whdr) + sizeof(pkt->ack) + n; in rxrpc_send_ack_packet()
245 pkt->whdr.serial = htonl(serial); in rxrpc_send_ack_packet()
262 trace_rxrpc_tx_packet(call->debug_id, &pkt->whdr, in rxrpc_send_ack_packet()
316 pkt.whdr.epoch = htonl(conn->proto.epoch); in rxrpc_send_abort_packet()
317 pkt.whdr.cid = htonl(call->cid); in rxrpc_send_abort_packet()
318 pkt.whdr.callNumber = htonl(call->call_id); in rxrpc_send_abort_packet()
319 pkt.whdr.seq = 0; in rxrpc_send_abort_packet()
320 pkt.whdr.type = RXRPC_PACKET_TYPE_ABORT; in rxrpc_send_abort_packet()
321 pkt.whdr.flags = conn->out_clientflag; in rxrpc_send_abort_packet()
322 pkt.whdr.userStatus = 0; in rxrpc_send_abort_packet()
323 pkt.whdr.securityIndex = call->security_ix; in rxrpc_send_abort_packet()
324 pkt.whdr._rsvd = 0; in rxrpc_send_abort_packet()
325 pkt.whdr.serviceId = htons(call->service_id); in rxrpc_send_abort_packet()
332 pkt.whdr.serial = htonl(serial); in rxrpc_send_abort_packet()
341 trace_rxrpc_tx_packet(call->debug_id, &pkt.whdr, in rxrpc_send_abort_packet()
354 struct rxrpc_wire_header whdr; in rxrpc_send_data_packet() local
373 whdr.epoch = htonl(conn->proto.epoch); in rxrpc_send_data_packet()
374 whdr.cid = htonl(call->cid); in rxrpc_send_data_packet()
375 whdr.callNumber = htonl(call->call_id); in rxrpc_send_data_packet()
376 whdr.seq = htonl(sp->hdr.seq); in rxrpc_send_data_packet()
377 whdr.serial = htonl(serial); in rxrpc_send_data_packet()
378 whdr.type = RXRPC_PACKET_TYPE_DATA; in rxrpc_send_data_packet()
379 whdr.flags = sp->hdr.flags; in rxrpc_send_data_packet()
380 whdr.userStatus = 0; in rxrpc_send_data_packet()
381 whdr.securityIndex = call->security_ix; in rxrpc_send_data_packet()
382 whdr._rsvd = htons(sp->hdr._rsvd); in rxrpc_send_data_packet()
383 whdr.serviceId = htons(call->service_id); in rxrpc_send_data_packet()
387 whdr.userStatus = RXRPC_USERSTATUS_SERVICE_UPGRADE; in rxrpc_send_data_packet()
389 iov[0].iov_base = &whdr; in rxrpc_send_data_packet()
390 iov[0].iov_len = sizeof(whdr); in rxrpc_send_data_packet()
417 whdr.flags |= RXRPC_REQUEST_ACK; in rxrpc_send_data_packet()
424 whdr.flags, retrans, true); in rxrpc_send_data_packet()
429 trace_rxrpc_tx_data(call, sp->hdr.seq, serial, whdr.flags, retrans, in rxrpc_send_data_packet()
442 if (whdr.flags & RXRPC_REQUEST_ACK) in rxrpc_send_data_packet()
460 trace_rxrpc_tx_packet(call->debug_id, &whdr, in rxrpc_send_data_packet()
470 if (whdr.flags & RXRPC_REQUEST_ACK) { in rxrpc_send_data_packet()
518 if (whdr.flags & RXRPC_REQUEST_ACK) in rxrpc_send_data_packet()
543 trace_rxrpc_tx_packet(call->debug_id, &whdr, in rxrpc_send_data_packet()
559 struct rxrpc_wire_header whdr; in rxrpc_reject_packets() local
569 iov[0].iov_base = &whdr; in rxrpc_reject_packets()
570 iov[0].iov_len = sizeof(whdr); in rxrpc_reject_packets()
579 memset(&whdr, 0, sizeof(whdr)); in rxrpc_reject_packets()
587 whdr.type = RXRPC_PACKET_TYPE_BUSY; in rxrpc_reject_packets()
588 size = sizeof(whdr); in rxrpc_reject_packets()
592 whdr.type = RXRPC_PACKET_TYPE_ABORT; in rxrpc_reject_packets()
594 size = sizeof(whdr) + sizeof(code); in rxrpc_reject_packets()
605 whdr.epoch = htonl(sp->hdr.epoch); in rxrpc_reject_packets()
606 whdr.cid = htonl(sp->hdr.cid); in rxrpc_reject_packets()
607 whdr.callNumber = htonl(sp->hdr.callNumber); in rxrpc_reject_packets()
608 whdr.serviceId = htons(sp->hdr.serviceId); in rxrpc_reject_packets()
609 whdr.flags = sp->hdr.flags; in rxrpc_reject_packets()
610 whdr.flags ^= RXRPC_CLIENT_INITIATED; in rxrpc_reject_packets()
611 whdr.flags &= RXRPC_CLIENT_INITIATED; in rxrpc_reject_packets()
619 trace_rxrpc_tx_packet(local->debug_id, &whdr, in rxrpc_reject_packets()
634 struct rxrpc_wire_header whdr; in rxrpc_send_keepalive() local
648 whdr.epoch = htonl(peer->local->rxnet->epoch); in rxrpc_send_keepalive()
649 whdr.cid = 0; in rxrpc_send_keepalive()
650 whdr.callNumber = 0; in rxrpc_send_keepalive()
651 whdr.seq = 0; in rxrpc_send_keepalive()
652 whdr.serial = 0; in rxrpc_send_keepalive()
653 whdr.type = RXRPC_PACKET_TYPE_VERSION; /* Not client-initiated */ in rxrpc_send_keepalive()
654 whdr.flags = RXRPC_LAST_PACKET; in rxrpc_send_keepalive()
655 whdr.userStatus = 0; in rxrpc_send_keepalive()
656 whdr.securityIndex = 0; in rxrpc_send_keepalive()
657 whdr._rsvd = 0; in rxrpc_send_keepalive()
658 whdr.serviceId = 0; in rxrpc_send_keepalive()
660 iov[0].iov_base = &whdr; in rxrpc_send_keepalive()
661 iov[0].iov_len = sizeof(whdr); in rxrpc_send_keepalive()
674 trace_rxrpc_tx_packet(peer->debug_id, &whdr, in rxrpc_send_keepalive()