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