net/rxrpc/ar-internal.h

609 struct rxrpc_call {  struct
610 	struct rcu_head		rcu;
611 	struct rxrpc_connection	*conn;		/* connection carrying call */
612 	struct rxrpc_bundle	*bundle;	/* Connection bundle to use */
613 	struct rxrpc_peer	*peer;		/* Peer record for remote address */
614 	struct rxrpc_local	*local;		/* Representation of local endpoint */
615 	struct rxrpc_sock __rcu	*socket;	/* socket responsible */
616 	struct rxrpc_net	*rxnet;		/* Network namespace to which call belongs */
617 	struct key		*key;		/* Security details */
618 	const struct rxrpc_security *security;	/* applied security module */
619 	struct mutex		user_mutex;	/* User access mutex */
620 	struct sockaddr_rxrpc	dest_srx;	/* Destination address */
621 	unsigned long		delay_ack_at;	/* When DELAY ACK needs to happen */
622 	unsigned long		ack_lost_at;	/* When ACK is figured as lost */
623 	unsigned long		resend_at;	/* When next resend needs to happen */
624 	unsigned long		ping_at;	/* When next to send a ping */
625 	unsigned long		keepalive_at;	/* When next to send a keepalive ping */
626 	unsigned long		expect_rx_by;	/* When we expect to get a packet by */
627 	unsigned long		expect_req_by;	/* When we expect to get a request DATA packet by */
628 	unsigned long		expect_term_by;	/* When we expect call termination by */
629 	u32			next_rx_timo;	/* Timeout for next Rx packet (jif) */
630 	u32			next_req_timo;	/* Timeout for next Rx request packet (jif) */
631 	u32			hard_timo;	/* Maximum lifetime or 0 (jif) */
632 	struct timer_list	timer;		/* Combined event timer */
656 	enum rxrpc_call_state	_state;		/* Current state of call (needs barrier) */  argument
657 	enum rxrpc_call_completion completion;	/* Call completion condition */  argument
658 	refcount_t		ref;
659 	u8			security_ix;	/* Security type */
660 	enum rxrpc_interruptibility interruptibility; /* At what point call may be interrupted */
661 	u32			call_id;	/* call ID on connection  */
662 	u32			cid;		/* connection ID plus channel index */
663 	u32			security_level;	/* Security level selected */
664 	int			debug_id;	/* debug ID for printks */
665 	unsigned short		rx_pkt_offset;	/* Current recvmsg packet offset */
666 	unsigned short		rx_pkt_len;	/* Current recvmsg packet len */
669 	spinlock_t		tx_lock;	/* Transmit queue lock */
670 	struct list_head	tx_sendmsg;	/* Sendmsg prepared packets */
671 	struct list_head	tx_buffer;	/* Buffer of transmissible packets */
672 	rxrpc_seq_t		tx_bottom;	/* First packet in buffer */
673 	rxrpc_seq_t		tx_transmitted;	/* Highest packet transmitted */
674 	rxrpc_seq_t		tx_prepared;	/* Highest Tx slot prepared. */
675 	rxrpc_seq_t		tx_top;		/* Highest Tx slot allocated. */
676 	u16			tx_backoff;	/* Delay to insert due to Tx failure */
677 	u8			tx_winsize;	/* Maximum size of Tx window */
679 	ktime_t			tx_last_sent;	/* Last time a transmission occurred */
682 	struct sk_buff_head	recvmsg_queue;	/* Queue of packets ready for recvmsg() */
683 	struct sk_buff_head	rx_oos_queue;	/* Queue of out of sequence packets */
685 	rxrpc_seq_t		rx_highest_seq;	/* Higest sequence number received */
686 	rxrpc_seq_t		rx_consumed;	/* Highest packet consumed */
687 	rxrpc_serial_t		rx_serial;	/* Highest serial received for this call */
688 	u8			rx_winsize;	/* Size of Rx window */
696 	u8			cong_cwnd;	/* Congestion window size */
697 	u8			cong_extra;	/* Extra to send for congestion management */
698 	u8			cong_ssthresh;	/* Slow-start threshold */
699 	enum rxrpc_congest_mode	cong_mode:8;	/* Congestion management mode */
700 	u8			cong_dup_acks;	/* Count of ACKs showing missing packets */
701 	u8			cong_cumul_acks; /* Cumulative ACK count */
702 	ktime_t			cong_tstamp;	/* Last time cwnd was changed */
703 	struct sk_buff		*cong_last_nack; /* Last ACK with nacks received */
706 	u8			ackr_reason;	/* reason to ACK */
707 	u16			ackr_sack_base;	/* Starting slot in SACK table ring */
708 	rxrpc_seq_t		ackr_window;	/* Base of SACK window */
709 	rxrpc_seq_t		ackr_wtop;	/* Base of SACK window */
710 	unsigned int		ackr_nr_unacked; /* Number of unacked packets */
711 	atomic_t		ackr_nr_consumed; /* Number of packets needing hard ACK */
712 	struct {
719 	rxrpc_serial_t		rtt_serial[4];	/* Serial number of DATA or PING sent */
720 	ktime_t			rtt_sent_at[4];	/* Time packet sent */
721 	unsigned long		rtt_avail;	/* Mask of available slots in bits 0-3,
727 	ktime_t			acks_latest_ts;	/* Timestamp of latest ACK received */
728 	rxrpc_seq_t		acks_first_seq;	/* first sequence number received */
729 	rxrpc_seq_t		acks_prev_seq;	/* Highest previousPacket received */
730 	rxrpc_seq_t		acks_hard_ack;	/* Latest hard-ack point */
731 	rxrpc_seq_t		acks_lowest_nak; /* Lowest NACK in the buffer (or ==tx_hard_ack) */
732 	rxrpc_serial_t		acks_highest_serial; /* Highest serial number ACK'd */