Lines Matching defs:rxrpc_call
545 struct rxrpc_call { struct
546 struct rcu_head rcu;
547 struct rxrpc_connection *conn; /* connection carrying call */
548 struct rxrpc_peer *peer; /* Peer record for remote address */
549 struct rxrpc_sock __rcu *socket; /* socket responsible */
550 struct rxrpc_net *rxnet; /* Network namespace to which call belongs */
551 const struct rxrpc_security *security; /* applied security module */
552 struct mutex user_mutex; /* User access mutex */
553 unsigned long ack_at; /* When deferred ACK needs to happen */
554 unsigned long ack_lost_at; /* When ACK is figured as lost */
555 unsigned long resend_at; /* When next resend needs to happen */
556 unsigned long ping_at; /* When next to send a ping */
557 unsigned long keepalive_at; /* When next to send a keepalive ping */
558 unsigned long expect_rx_by; /* When we expect to get a packet by */
559 unsigned long expect_req_by; /* When we expect to get a request DATA packet by */
560 unsigned long expect_term_by; /* When we expect call termination by */
561 u32 next_rx_timo; /* Timeout for next Rx packet (jif) */
562 u32 next_req_timo; /* Timeout for next Rx request packet (jif) */
586 enum rxrpc_call_state state; /* current state of call */ argument
587 enum rxrpc_call_completion completion; /* Call completion condition */ argument
588 refcount_t ref;
589 u16 service_id; /* service ID */
590 u8 security_ix; /* Security type */
591 enum rxrpc_interruptibility interruptibility; /* At what point call may be interrupted */
592 u32 call_id; /* call ID on connection */
593 u32 cid; /* connection ID plus channel index */
594 int debug_id; /* debug ID for printks */
595 unsigned short rx_pkt_offset; /* Current recvmsg packet offset */
596 unsigned short rx_pkt_len; /* Current recvmsg packet len */
597 bool rx_pkt_last; /* Current recvmsg packet is last */
611 struct sk_buff **rxtx_buffer;
612 u8 *rxtx_annotations;
623 rxrpc_seq_t tx_hard_ack; /* Dead slot in buffer; the first transmitted but
626 rxrpc_seq_t tx_top; /* Highest Tx slot allocated. */
627 u16 tx_backoff; /* Delay to insert due to Tx failure */
634 u8 cong_cwnd; /* Congestion window size */
635 u8 cong_extra; /* Extra to send for congestion management */
636 u8 cong_ssthresh; /* Slow-start threshold */
637 enum rxrpc_congest_mode cong_mode:8; /* Congestion management mode */
638 u8 cong_dup_acks; /* Count of ACKs showing missing packets */
639 u8 cong_cumul_acks; /* Cumulative ACK count */
640 ktime_t cong_tstamp; /* Last time cwnd was changed */
642 rxrpc_seq_t rx_hard_ack; /* Dead slot in buffer; the first received but not
645 rxrpc_seq_t rx_top; /* Highest Rx slot allocated. */
646 rxrpc_seq_t rx_expect_next; /* Expected next packet sequence number */
647 rxrpc_serial_t rx_serial; /* Highest serial received for this call */
648 u8 rx_winsize; /* Size of Rx window */
649 u8 tx_winsize; /* Maximum size of Tx window */
650 bool tx_phase; /* T if transmission phase, F if receive phase */
651 u8 nr_jumbo_bad; /* Number of jumbo dups/exceeds-windows */
653 spinlock_t input_lock; /* Lock for packet input to this call */
656 u8 ackr_reason; /* reason to ACK */
657 rxrpc_serial_t ackr_serial; /* serial of packet being ACK'd */
658 rxrpc_seq_t ackr_highest_seq; /* Higest sequence number received */
659 atomic_t ackr_nr_unacked; /* Number of unacked packets */
660 atomic_t ackr_nr_consumed; /* Number of packets needing hard ACK */
663 rxrpc_serial_t rtt_serial[4]; /* Serial number of DATA or PING sent */
664 ktime_t rtt_sent_at[4]; /* Time packet sent */
665 unsigned long rtt_avail; /* Mask of available slots in bits 0-3,
671 ktime_t acks_latest_ts; /* Timestamp of latest ACK received */
672 rxrpc_seq_t acks_first_seq; /* first sequence number received */
673 rxrpc_seq_t acks_prev_seq; /* Highest previousPacket received */
674 rxrpc_seq_t acks_lowest_nak; /* Lowest NACK in the buffer (or ==tx_hard_ack) */
675 rxrpc_seq_t acks_lost_top; /* tx_top at the time lost-ack ping sent */
676 rxrpc_serial_t acks_lost_ping; /* Serial number of probe ACK */