Lines Matching defs:rxrpc_call
552 struct rxrpc_call { struct
553 struct rcu_head rcu;
554 struct rxrpc_connection *conn; /* connection carrying call */
555 struct rxrpc_peer *peer; /* Peer record for remote address */
556 struct rxrpc_sock __rcu *socket; /* socket responsible */
557 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */
558 const struct rxrpc_security *security; /* applied security module */
559 struct mutex user_mutex; /* User access mutex */
560 unsigned long ack_at; /* When deferred ACK needs to happen */
561 unsigned long ack_lost_at; /* When ACK is figured as lost */
562 unsigned long resend_at; /* When next resend needs to happen */
563 unsigned long ping_at; /* When next to send a ping */
564 unsigned long keepalive_at; /* When next to send a keepalive ping */
565 unsigned long expect_rx_by; /* When we expect to get a packet by */
566 unsigned long expect_req_by; /* When we expect to get a request DATA packet by */
567 unsigned long expect_term_by; /* When we expect call termination by */
568 u32 next_rx_timo; /* Timeout for next Rx packet (jif) */
569 u32 next_req_timo; /* Timeout for next Rx request packet (jif) */
593 enum rxrpc_call_state state; /* current state of call */ argument
594 enum rxrpc_call_completion completion; /* Call completion condition */ argument
595 atomic_t usage;
596 u16 service_id; /* service ID */
597 u8 security_ix; /* Security type */
598 enum rxrpc_interruptibility interruptibility; /* At what point call may be interrupted */
599 u32 call_id; /* call ID on connection */
600 u32 cid; /* connection ID plus channel index */
601 int debug_id; /* debug ID for printks */
602 unsigned short rx_pkt_offset; /* Current recvmsg packet offset */
603 unsigned short rx_pkt_len; /* Current recvmsg packet len */
604 bool rx_pkt_last; /* Current recvmsg packet is last */
618 struct sk_buff **rxtx_buffer;
619 u8 *rxtx_annotations;
630 rxrpc_seq_t tx_hard_ack; /* Dead slot in buffer; the first transmitted but
633 rxrpc_seq_t tx_top; /* Highest Tx slot allocated. */
634 u16 tx_backoff; /* Delay to insert due to Tx failure */
641 u8 cong_cwnd; /* Congestion window size */
642 u8 cong_extra; /* Extra to send for congestion management */
643 u8 cong_ssthresh; /* Slow-start threshold */
644 enum rxrpc_congest_mode cong_mode:8; /* Congestion management mode */
645 u8 cong_dup_acks; /* Count of ACKs showing missing packets */
646 u8 cong_cumul_acks; /* Cumulative ACK count */
647 ktime_t cong_tstamp; /* Last time cwnd was changed */
649 rxrpc_seq_t rx_hard_ack; /* Dead slot in buffer; the first received but not
652 rxrpc_seq_t rx_top; /* Highest Rx slot allocated. */
653 rxrpc_seq_t rx_expect_next; /* Expected next packet sequence number */
654 rxrpc_serial_t rx_serial; /* Highest serial received for this call */
655 u8 rx_winsize; /* Size of Rx window */
656 u8 tx_winsize; /* Maximum size of Tx window */
657 bool tx_phase; /* T if transmission phase, F if receive phase */
658 u8 nr_jumbo_bad; /* Number of jumbo dups/exceeds-windows */
660 spinlock_t input_lock; /* Lock for packet input to this call */
663 u8 ackr_reason; /* reason to ACK */
664 rxrpc_serial_t ackr_serial; /* serial of packet being ACK'd */
665 rxrpc_serial_t ackr_first_seq; /* first sequence number received */
666 rxrpc_seq_t ackr_prev_seq; /* previous sequence number received */
667 rxrpc_seq_t ackr_consumed; /* Highest packet shown consumed */
668 rxrpc_seq_t ackr_seen; /* Highest packet shown seen */
671 rxrpc_serial_t rtt_serial[4]; /* Serial number of DATA or PING sent */
672 ktime_t rtt_sent_at[4]; /* Time packet sent */
673 unsigned long rtt_avail; /* Mask of available slots in bits 0-3,
679 ktime_t acks_latest_ts; /* Timestamp of latest ACK received */
680 rxrpc_seq_t acks_lowest_nak; /* Lowest NACK in the buffer (or ==tx_hard_ack) */
681 rxrpc_seq_t acks_lost_top; /* tx_top at the time lost-ack ping sent */
682 rxrpc_serial_t acks_lost_ping; /* Serial number of probe ACK */