Lines Matching refs:sa
67 let sa = Session::new(Arc::new(ua), ca, false).await?; in build_session_srtcp_pair() localVariable
70 Ok((sa, sb)) in build_session_srtcp_pair()
77 let (sa, sb) = build_session_srtcp_pair().await?; in test_session_srtcp_accept()
85 sa.write_rtcp(&rtcp_packet).await?; in test_session_srtcp_accept()
106 sa.close().await?; in test_session_srtcp_accept()
114 let (sa, sb) = build_session_srtcp_pair().await?; in test_session_srtcp_listen()
124 sa.write_rtcp(&rtcp_packet).await?; in test_session_srtcp_listen()
138 sa.close().await?; in test_session_srtcp_listen()
170 let (sa, sb) = build_session_srtcp_pair().await?; in test_session_srtcp_replay_protection()
178 let mut local_context = sa.local_context.lock().await; in test_session_srtcp_replay_protection()
218 sa.udp_tx.send(packet).await?; in test_session_srtcp_replay_protection()
221 sa.udp_tx.send(packet).await?; in test_session_srtcp_replay_protection()
225 sa.udp_tx.send(packet).await?; in test_session_srtcp_replay_protection()
230 sa.close().await?; in test_session_srtcp_replay_protection()