net/rxrpc/ar-internal.h

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