Lines Matching refs:hdr
207 terminal = ((sp->hdr.flags & RXRPC_LAST_PACKET) && in rxrpc_fast_process_data()
208 !(sp->hdr.flags & RXRPC_CLIENT_INITIATED)); in rxrpc_fast_process_data()
225 if (sp->hdr.flags & RXRPC_LAST_PACKET) in rxrpc_fast_process_data()
241 rxrpc_propose_ACK(call, RXRPC_ACK_DELAY, sp->hdr.serial, false); in rxrpc_fast_process_data()
254 __rxrpc_propose_ACK(call, ack, sp->hdr.serial, true); in rxrpc_fast_process_data()
262 __rxrpc_propose_ACK(call, ack, sp->hdr.serial, true); in rxrpc_fast_process_data()
321 if (sp->hdr.type == RXRPC_PACKET_TYPE_DATA) { in rxrpc_fast_process_packet()
333 serial = ntohl(sp->hdr.serial); in rxrpc_fast_process_packet()
341 if (sp->hdr.flags & RXRPC_REQUEST_ACK) { in rxrpc_fast_process_packet()
343 rxrpc_propose_ACK(call, RXRPC_ACK_REQUESTED, sp->hdr.serial, false); in rxrpc_fast_process_packet()
346 switch (sp->hdr.type) { in rxrpc_fast_process_packet()
385 _proto("Rx %s %%%u", rxrpc_pkts[sp->hdr.type], serial); in rxrpc_fast_process_packet()
389 seq = ntohl(sp->hdr.seq); in rxrpc_fast_process_packet()
396 call->ackr_prev_seq = sp->hdr.seq; in rxrpc_fast_process_packet()
462 sp->hdr.flags &= ~RXRPC_JUMBO_PACKET; in rxrpc_process_jumbo_packet()
484 sp->hdr.seq = htonl(ntohl(sp->hdr.seq) + 1); in rxrpc_process_jumbo_packet()
485 sp->hdr.serial = htonl(ntohl(sp->hdr.serial) + 1); in rxrpc_process_jumbo_packet()
486 sp->hdr.flags = jhdr.flags; in rxrpc_process_jumbo_packet()
487 sp->hdr._rsvd = jhdr._rsvd; in rxrpc_process_jumbo_packet()
489 _proto("Rx DATA Jumbo %%%u", ntohl(sp->hdr.serial) - 1); in rxrpc_process_jumbo_packet()
494 } while (sp->hdr.flags & RXRPC_JUMBO_PACKET); in rxrpc_process_jumbo_packet()
559 if (sp->hdr.type == RXRPC_PACKET_TYPE_DATA && in rxrpc_post_packet_to_call()
560 sp->hdr.flags & RXRPC_JUMBO_PACKET) in rxrpc_post_packet_to_call()
569 if (sp->hdr.type != RXRPC_PACKET_TYPE_ABORT) { in rxrpc_post_packet_to_call()
628 conn = rxrpc_find_connection(trans, &sp->hdr); in rxrpc_conn_from_local()
699 if (skb_copy_bits(skb, sizeof(struct udphdr), &sp->hdr, in rxrpc_data_ready()
700 sizeof(sp->hdr)) < 0) in rxrpc_data_ready()
702 if (!pskb_pull(skb, sizeof(struct udphdr) + sizeof(sp->hdr))) in rxrpc_data_ready()
706 sp->hdr.flags & RXRPC_CLIENT_INITIATED ? "ToServer" : "ToClient", in rxrpc_data_ready()
707 ntohl(sp->hdr.epoch), in rxrpc_data_ready()
708 ntohl(sp->hdr.cid), in rxrpc_data_ready()
709 ntohl(sp->hdr.callNumber)); in rxrpc_data_ready()
711 if (sp->hdr.type == 0 || sp->hdr.type >= RXRPC_N_PACKET_TYPES) { in rxrpc_data_ready()
712 _proto("Rx Bad Packet Type %u", sp->hdr.type); in rxrpc_data_ready()
716 if (sp->hdr.type == RXRPC_PACKET_TYPE_VERSION) { in rxrpc_data_ready()
721 if (sp->hdr.type == RXRPC_PACKET_TYPE_DATA && in rxrpc_data_ready()
722 (sp->hdr.callNumber == 0 || sp->hdr.seq == 0)) in rxrpc_data_ready()
725 if (sp->hdr.callNumber == 0) { in rxrpc_data_ready()
742 if (sp->hdr.flags & RXRPC_CLIENT_INITIATED) in rxrpc_data_ready()
744 call = rxrpc_find_call_hash(in_clientflag, sp->hdr.cid, in rxrpc_data_ready()
745 sp->hdr.callNumber, sp->hdr.epoch, in rxrpc_data_ready()
746 sp->hdr.serviceId, local, AF_INET, in rxrpc_data_ready()
760 if (sp->hdr.flags & RXRPC_CLIENT_INITIATED && in rxrpc_data_ready()
761 sp->hdr.type == RXRPC_PACKET_TYPE_DATA) { in rxrpc_data_ready()
762 if (sp->hdr.seq == cpu_to_be32(1)) { in rxrpc_data_ready()
775 if (sp->hdr.type != RXRPC_PACKET_TYPE_ABORT) { in rxrpc_data_ready()
776 _debug("reject type %d",sp->hdr.type); in rxrpc_data_ready()