Lines Matching refs:sa
71 let sa = Session::new(Arc::new(ua), ca, true).await?; in build_session_srtp_pair() localVariable
74 Ok((sa, sb)) in build_session_srtp_pair()
85 let (sa, sb) = build_session_srtp_pair().await?; in test_session_srtp_accept()
94 sa.write_rtp(&packet).await?; in test_session_srtp_accept()
113 sa.close().await?; in test_session_srtp_accept()
124 let (sa, sb) = build_session_srtp_pair().await?; in test_session_srtp_listen()
136 sa.write_rtp(&packet).await?; in test_session_srtp_listen()
148 sa.close().await?; in test_session_srtp_listen()
160 let (sa, sb) = build_session_srtp_pair().await?; in test_session_srtp_multi_ssrc()
176 sa.write_rtp(&packet).await?; in test_session_srtp_multi_ssrc()
193 sa.close().await?; in test_session_srtp_multi_ssrc()
230 let (sa, sb) = build_session_srtp_pair().await?; in test_session_srtp_replay_protection()
238 let mut local_context = sa.local_context.lock().await; in test_session_srtp_replay_protection()
287 sa.udp_tx.send(packet).await?; in test_session_srtp_replay_protection()
290 sa.udp_tx.send(packet).await?; in test_session_srtp_replay_protection()
294 sa.udp_tx.send(packet).await?; in test_session_srtp_replay_protection()
299 sa.close().await?; in test_session_srtp_replay_protection()