Lines Matching +full:packet +full:- +full:processor
1 /* SPDX-License-Identifier: GPL-2.0-or-later */
32 * Mark applied to socket buffers in skb->mark. skb->priority is used
37 RXRPC_SKB_MARK_REJECT_ABORT, /* Reject with ABORT (code in skb->priority) */
55 * Per-network namespace data.
59 u32 epoch; /* Local epoch for detecting local-end reset */
61 rwlock_t call_lock; /* Lock for ->calls */
67 rwlock_t conn_lock; /* Lock for ->conn_proc_list, ->service_conns */
75 spinlock_t client_conn_cache_lock; /* Lock for ->*_client_conns */
82 struct mutex local_mutex; /* Lock for ->local_endpoints */
85 spinlock_t peer_hash_lock; /* Lock for ->peer_hash */
134 struct rb_root calls; /* User ID -> call mapping */
155 * CPU-byteorder normalised Rx packet header.
160 u32 callNumber; /* call ID (0 for connection-level packets) */
163 u8 type; /* packet type */
164 u8 flags; /* packet flags */
165 u8 userStatus; /* app-layer defined status */
176 * - max 48 bytes (struct sk_buff::cb)
181 u8 rx_flags; /* Received packet flags */
182 #define RXRPC_SKB_INCL_LAST 0x01 /* - Includes last packet */
183 #define RXRPC_SKB_TX_BUFFER 0x02 /* - Is transmit buffer */
188 unsigned long rx_req_ack[(RXRPC_MAX_NR_JUMBO + BITS_PER_LONG - 1) /
192 struct rxrpc_host_header hdr; /* RxRPC packet header from this packet */
195 #define rxrpc_skb(__skb) ((struct rxrpc_skb_priv *) &(__skb)->cb)
214 /* prime a connection's packet security */
217 /* impose security on a packet */
223 /* verify the security on a received packet */
230 /* Locate the data in a received packet that has been verified. */
253 * - owned by a single AF_RXRPC socket
254 * - pointed to by transport socket struct sk_user_data
263 struct work_struct processor; member
265 struct rw_semaphore defrag_sem; /* control re-enablement of IP DF bit */
280 * - matched by local endpoint, remote port, address and protocol type
290 struct list_head keepalive_link; /* Link in net->peer_keepalive[] */
291 time64_t last_tx_at; /* Last time packet sent here */
296 unsigned int maxdata; /* data size (MTU - hdrsize) */
345 RXRPC_CONN_IN_SERVICE_CONNS, /* Conn is in peer->service_conns */
363 RXRPC_CONN_EV_CHALLENGE, /* Send challenge packet */
393 struct rb_node local_node; /* Node in local->client_conns */
401 * - matched by { local, peer, epoch, conn_id, direction }
402 * - each connection can only handle four simultaneous calls
416 unsigned int call_debug_id; /* call->debug_id */
420 u8 last_type; /* Type of last packet */
428 struct work_struct processor; /* connection event processor */ member
430 struct rb_node service_node; /* Node in peer->service_conns */
433 struct sk_buff_head rx_queue; /* received conn-level packets */
437 struct rxrpc_crypt csum_iv; /* packet checksum base */
441 spinlock_t state_lock; /* state-change lock */
445 atomic_t serial; /* packet serial number counter */
447 u32 security_nonce; /* response re-use preventer */
453 u8 bundle_shift; /* Index into bundle->avail_chans */
459 return sp->hdr.flags & RXRPC_CLIENT_INITIATED; in rxrpc_to_server()
468 * Flags in call->flags.
471 RXRPC_CALL_RELEASED, /* call has been released - no more message to userspace */
475 RXRPC_CALL_RX_LAST, /* Received the last packet (at rxtx_top) */
476 RXRPC_CALL_TX_LAST, /* Last packet in Tx buffer (at rxtx_top) */
504 RXRPC_CALL_CLIENT_AWAIT_CONN, /* - client waiting for connection to become available */
505 RXRPC_CALL_CLIENT_SEND_REQUEST, /* - client sending request phase */
506 RXRPC_CALL_CLIENT_AWAIT_REPLY, /* - client awaiting reply */
507 RXRPC_CALL_CLIENT_RECV_REPLY, /* - client receiving reply phase */
508 RXRPC_CALL_SERVER_PREALLOC, /* - service preallocation */
509 RXRPC_CALL_SERVER_SECURING, /* - server securing request connection */
510 RXRPC_CALL_SERVER_RECV_REQUEST, /* - server receiving request */
511 RXRPC_CALL_SERVER_ACK_REQUEST, /* - server pending ACK of request */
512 RXRPC_CALL_SERVER_SEND_REPLY, /* - server sending reply */
513 RXRPC_CALL_SERVER_AWAIT_ACK, /* - server awaiting final ACK */
514 RXRPC_CALL_COMPLETE, /* - call complete */
522 RXRPC_CALL_SUCCEEDED, /* - Normal termination */
523 RXRPC_CALL_REMOTELY_ABORTED, /* - call aborted by peer */
524 RXRPC_CALL_LOCALLY_ABORTED, /* - call aborted locally on error or close */
525 RXRPC_CALL_LOCAL_ERROR, /* - call failed due to local error */
526 RXRPC_CALL_NETWORK_ERROR, /* - call terminated by network error */
543 * - matched by { connection, call_id }
558 unsigned long expect_rx_by; /* When we expect to get a packet by */
559 unsigned long expect_req_by; /* When we expect to get a request DATA packet by */
561 u32 next_rx_timo; /* Timeout for next Rx packet (jif) */
562 u32 next_req_timo; /* Timeout for next Rx request packet (jif) */
563 struct skcipher_request *cipher_req; /* Packet cipher request buffer */
565 struct work_struct processor; /* Event processor */ member
568 struct list_head chan_wait_link; /* Link in conn->bundle->waiting_calls */
570 struct list_head accept_link; /* Link in rx->acceptq */
571 struct list_head recvmsg_link; /* Link in rx->recvmsg_q */
572 struct list_head sock_link; /* Link in rx->sock_calls */
573 struct rb_node sock_node; /* Node in rx->calls */
576 s64 tx_total_len; /* Total length left to be transmitted (or -1) */
577 __be32 crypto_buf[2]; /* Temporary packet crypto buffer */
578 unsigned long user_call_ID; /* user-defined call ID */
595 unsigned short rx_pkt_offset; /* Current recvmsg packet offset */
596 unsigned short rx_pkt_len; /* Current recvmsg packet len */
597 bool rx_pkt_last; /* Current recvmsg packet is last */
602 * segment of a jumbo packet each buffer refers to. There can be up to
603 * 47 segments in a maximum-size UDP packet.
609 #define RXRPC_RXTX_BUFF_MASK (RXRPC_RXTX_BUFF_SIZE - 1)
624 * not hard-ACK'd packet follows this.
629 /* TCP-style slow-start congestion control [RFC5681]. Since the SMSS
636 u8 cong_ssthresh; /* Slow-start threshold */
643 * consumed packet follows this.
646 rxrpc_seq_t rx_expect_next; /* Expected next packet sequence number */
651 u8 nr_jumbo_bad; /* Number of jumbo dups/exceeds-windows */
653 spinlock_t input_lock; /* Lock for packet input to this call */
655 /* Receive-phase ACK management (ACKs we send). */
657 rxrpc_serial_t ackr_serial; /* serial of packet being ACK'd */
664 ktime_t rtt_sent_at[4]; /* Time packet sent */
665 unsigned long rtt_avail; /* Mask of available slots in bits 0-3,
666 * Mask of pending samples in 8-11 */
670 /* Transmission-phase ACK management (ACKs we've received). */
675 rxrpc_seq_t acks_lost_top; /* tx_top at the time lost-ack ping sent */
680 * Summary of a new ACK and the changes it made to the Tx buffer packet states.
684 u8 nr_acks; /* Number of ACKs in packet */
685 u8 nr_nacks; /* Number of NACKs in packet */
686 u8 nr_new_acks; /* Number of new ACKs in packet */
687 u8 nr_new_nacks; /* Number of new NACKs in packet */
701 * sendmsg() cmsg-specified parameters.
715 u32 idle; /* Max time since last data packet (msec) */
716 u32 normal; /* Max time since last call packet (msec) */
794 return test_bit(RXRPC_CALL_IS_SERVICE, &call->flags); in rxrpc_is_service_call()
852 return conn->out_clientflag; in rxrpc_conn_is_client()
874 timer_reduce(&conn->timer, expire_at); in rxrpc_reduce_conn_timer()
928 return atomic_dec_return(&local->active_users) == 0; in __rxrpc_unuse_local()
933 return atomic_fetch_add_unless(&local->active_users, 1, 0) != 0; in __rxrpc_use_local()
1022 trace_rxrpc_rx_eproto(call, sp->hdr.serial, eproto_why); in __rxrpc_abort_eproto()
1023 return rxrpc_abort_call(why, call, sp->hdr.seq, abort_code, -EPROTO); in __rxrpc_abort_eproto()
1090 return (s32)(seq1 - seq2) < 0; in before()
1094 return (s32)(seq1 - seq2) <= 0; in before_eq()
1098 return (s32)(seq1 - seq2) > 0; in after()
1102 return (s32)(seq1 - seq2) >= 0; in after_eq()
1111 printk("[%-6.6s] "FMT"\n", current->comm ,##__VA_ARGS__)
1190 pr_err("Assertion failed - %lu(0x%lx) %s %lu(0x%lx) is false\n", \
1210 pr_err("Assertion failed - %lu(0x%lx) %s %lu(0x%lx) is false\n", \