Lines Matching defs:AgentInternal

21 pub struct AgentInternal {  struct
23     pub(crate) on_connected_tx: Mutex<Option<mpsc::Sender<()>>>,
24     pub(crate) on_connected_rx: Mutex<Option<mpsc::Receiver<()>>>,
27     pub(crate) done_tx: Mutex<Option<mpsc::Sender<()>>>,
29     pub(crate) force_candidate_contact_tx: mpsc::Sender<bool>,
30     pub(crate) done_and_force_candidate_contact_rx:
33     pub(crate) chan_candidate_tx: ChanCandidateTx,
34     pub(crate) chan_candidate_pair_tx: Mutex<Option<mpsc::Sender<()>>>,
35     pub(crate) chan_state_tx: Mutex<Option<mpsc::Sender<ConnectionState>>>,
37     pub(crate) on_connection_state_change_hdlr: ArcSwapOption<Mutex<OnConnectionStateChangeHdlrFn>>,
38     pub(crate) on_selected_candidate_pair_change_hdlr:
40     pub(crate) on_candidate_hdlr: ArcSwapOption<Mutex<OnCandidateHdlrFn>>,
42     pub(crate) tie_breaker: AtomicU64,
43     pub(crate) is_controlling: AtomicBool,
44     pub(crate) lite: AtomicBool,
46     pub(crate) start_time: SyncMutex<Instant>,
47     pub(crate) nominated_pair: Mutex<Option<Arc<CandidatePair>>>,
49     pub(crate) connection_state: AtomicU8, //ConnectionState,
51     pub(crate) started_ch_tx: Mutex<Option<broadcast::Sender<()>>>,
53     pub(crate) ufrag_pwd: Mutex<UfragPwd>,
55     pub(crate) local_candidates: Mutex<HashMap<NetworkType, Vec<Arc<dyn Candidate + Send + Sync>>>>,
56     pub(crate) remote_candidates:
60     pub(crate) pending_binding_requests: Mutex<Vec<BindingRequest>>,
84 impl AgentInternal {  argument