Lines Matching +full:short +full:- +full:ping
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 */
105 unsigned short peer_backlog_head;
106 unsigned short peer_backlog_tail;
107 unsigned short conn_backlog_head;
108 unsigned short conn_backlog_tail;
109 unsigned short call_backlog_head;
110 unsigned short call_backlog_tail;
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) */
165 u8 userStatus; /* app-layer defined status */
176 * - max 48 bytes (struct sk_buff::cb)
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) /
195 #define rxrpc_skb(__skb) ((struct rxrpc_skb_priv *) &(__skb)->cb)
253 * - owned by a single AF_RXRPC socket
254 * - pointed to by transport socket struct sk_user_data
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[] */
296 unsigned int maxdata; /* data size (MTU - hdrsize) */
297 unsigned short hdrsize; /* header size (IP + UDP + RxRPC) */
345 RXRPC_CONN_IN_SERVICE_CONNS, /* Conn is in peer->service_conns */
391 short alloc_error; /* Error from last conn allocation */
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 */
430 struct rb_node service_node; /* Node in peer->service_conns */
433 struct sk_buff_head rx_queue; /* received conn-level packets */
441 spinlock_t state_lock; /* state-change lock */
447 u32 security_nonce; /* response re-use preventer */
453 u8 bundle_shift; /* Index into bundle->avail_chans */
454 short error; /* Local error code */
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 */
477 RXRPC_CALL_SEND_PING, /* A ping will need to be sent */
494 RXRPC_CALL_EV_PING, /* Ping send required */
496 RXRPC_CALL_EV_ACK_LOST, /* ACK may be lost, send ping */
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 }
556 unsigned long ping_at; /* When next to send a ping */
557 unsigned long keepalive_at; /* When next to send a keepalive ping */
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) */
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 */
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 */
651 u8 nr_jumbo_bad; /* Number of jumbo dups/exceeds-windows */
655 /* Receive-phase ACK management (ACKs we send). */
663 rxrpc_serial_t rtt_serial[4]; /* Serial number of DATA or PING 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 */
701 * sendmsg() cmsg-specified parameters.
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", \