Struct PtsState 

pub struct PtsState {
    pub pts: i32,
    pub qts: i32,
    pub date: i32,
    pub seq: i32,
    pub channel_pts: HashMap<i64, i32>,
    pub channel_diff_calls: HashMap<i64, u32>,
    pub last_update_at: Option<Instant>,
    pub getting_diff_for: HashSet<i64>,
    pub getting_global_diff: bool,
    pub getting_global_diff_since: Option<Instant>,
}

Full MTProto sequence-number state, including per-channel counters.

All fields are pub so that connect() can restore them from the persisted session without going through an artificial constructor.

Fields

pts: i32

Main pts counter (messages, non-channel updates).

qts: i32

Secondary counter for secret-chat updates.

date: i32

Date of the last received update (Unix timestamp).

seq: i32

Combined-container sequence number.

channel_pts: HashMap<i64, i32>

Per-channel pts counters. channel_id → pts.

channel_diff_calls: HashMap<i64, u32>

How many times getChannelDifference has been called per channel. tDesktop starts at limit=100, then raises to 1000 after the first successful response. We track call count to implement the same ramp-up.

last_update_at: Option<Instant>

Timestamp of last received update for deadline-based gap detection.

getting_diff_for: HashSet<i64>

Channels currently awaiting a getChannelDifference response. If a channel is in this set, no new gap-fill task is spawned for it.

getting_global_diff: bool

Guard against concurrent global getDifference calls. Without this, two simultaneous gap detections both spawn get_difference(), which double-processes updates and corrupts pts state.

getting_global_diff_since: Option<Instant>

When getting_global_diff was set to true. Used by the stuck-diff watchdog in check_update_deadline: if the flag has been set for >30 s the RPC is assumed hung and the guard is reset so the next gap_tick can retry.

Implementations

impl PtsState

pub fn from_server_state(s: &State) -> Self

pub fn touch(&mut self)

Record that an update was received now (resets the deadline timer).

pub fn deadline_exceeded(&self) -> bool

Returns true if no update has been received for > 15 minutes.

pub fn check_pts(&self, new_pts: i32, pts_count: i32) -> PtsCheckResult

Check whether new_pts is in order given pts_count new updates.

pub fn check_qts(&self, new_qts: i32, qts_count: i32) -> PtsCheckResult

Check a qts value (secret chat updates).

pub fn check_seq(&self, _new_seq: i32, seq_start: i32) -> PtsCheckResult

Check top-level seq for UpdatesCombined containers.

pub fn check_channel_pts( &self, channel_id: i64, new_pts: i32, pts_count: i32, ) -> PtsCheckResult

Check a per-channel pts value.

pub fn advance(&mut self, new_pts: i32)

Advance the global pts.

pub fn advance_qts(&mut self, new_qts: i32)

Advance the qts.

pub fn advance_seq(&mut self, new_seq: i32)

Advance seq.

pub fn advance_channel(&mut self, channel_id: i64, new_pts: i32)

Advance a per-channel pts.

Trait Implementations

impl Clone for PtsState

fn clone(&self) -> PtsState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for PtsState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for PtsState

fn default() -> PtsState

Returns the “default value” for a type.