Struct DcPool 

pub struct DcPool {
    pub conns: HashMap<i32, Vec<Arc<ConnSlot>>>,
    /* private fields */
}

Pool of per-DC authenticated connections. Each DC holds up to MAX_CONNS_PER_DC slots. The pool lock is dropped before any network I/O so concurrent callers don’t serialize on it.

Fields

conns: HashMap<i32, Vec<Arc<ConnSlot>>>

Per-DC connection slots; inner Vec holds slot Arcs.

Implementations

impl DcPool

pub fn new( home_dc_id: i32, dc_entries: &[DcEntry], socks5: Option<Socks5Config>, transport: TransportKind, ) -> Self

pub fn has_connection(&self, dc_id: i32) -> bool

Returns true if at least one connection slot exists for dc_id.

pub fn insert(&mut self, dc_id: i32, conn: DcConnection)

Insert a pre-built connection into the pool as a new slot.

pub fn evict(&mut self, dc_id: i32)

Evict all slots for a DC (called on IO error to force reconnection).

pub async fn invoke_on_dc<R: RemoteCall>( &mut self, dc_id: i32, _dc_entries: &[DcEntry], req: &R, ) -> Result<Vec<u8>, InvocationError>

Invoke a raw RPC call on the given DC. Pool lock is released before the network round-trip begins.

pub fn mark_init_done(&mut self, dc_id: i32)

Mark a DC as having completed initConnection.

pub fn is_init_done(&self, dc_id: i32) -> bool

Returns true if this DC has already received initConnection this session.

pub async fn invoke_on_dc_serializable<S: Serializable>( &mut self, dc_id: i32, req: &S, ) -> Result<Vec<u8>, InvocationError>

Like invoke_on_dc but accepts any Serializable type.

pub fn update_addrs(&mut self, entries: &[DcEntry])

Update the address table (called after initConnection).

pub fn collect_keys(&self, entries: &mut [DcEntry])

Save the auth keys from pool connections back into the DC entry list. Uses the first slot per DC (all slots share the same auth key).