/dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/video/closedcaption/tests/ |
H A D | ccdetect.rs | 85 state_guard.cc608_count += 1; in test_have_cc_data_notify() 93 state_guard.cc708_count += 1; in test_have_cc_data_notify() 151 state_guard.cc608_count += 1; in test_cc_data_window() 158 state_guard.cc708_count += 1; in test_cc_data_window() 250 state_guard.cc608_count += 1; in test_have_cdp_notify() 257 state_guard.cc708_count += 1; in test_have_cdp_notify() 318 state_guard.cc608_count += 1; in test_malformed_cdp_notify() 325 state_guard.cc708_count += 1; in test_malformed_cdp_notify() 400 state_guard.cc608_count += 1; in test_gap_events() 407 state_guard.cc708_count += 1; in test_gap_events() [all …]
|
/dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/utils/fallbackswitch/src/fallbacksrc/ |
H A D | imp.rs | 1096 drop(state_guard); in start() 1113 drop(state_guard); in stop() 1189 drop(state_guard); in change_source_state() 1435 drop(state_guard); in handle_source_pad_added() 1563 drop(state_guard); in handle_pad_blocked() 1614 drop(state_guard); in handle_pad_blocked() 1874 drop(state_guard); in handle_source_pad_removed() 1913 drop(state_guard); in handle_buffering() 1978 drop(state_guard); in handle_streams_selected() 2005 drop(state_guard); in handle_error() [all …]
|
/dports/net-im/libsignal-client/libsignal-client-0.9.6/rust/bridge/node/futures/src/ |
H A D | future.rs | 77 let mut state_guard = self.state.lock().expect("Lock can be taken"); in poll() localVariable 78 let state = mem::replace(&mut *state_guard, JsFutureState::Consumed); in poll() 85 *state_guard = state.waiting_on(cx.waker().clone()); in poll() 131 let mut state_guard = future_state.lock().expect("Lock can be taken"); in settle_promise() localVariable 132 let previous_state = mem::replace(&mut *state_guard, JsFutureState::Consumed); in settle_promise() 137 *state_guard = JsFutureState::Settled(result); in settle_promise() 139 mem::drop(state_guard); in settle_promise() 144 *state_guard = previous_state; in settle_promise()
|
/dports/devel/sccache/sccache-0.2.15/cargo-crates/async-std-1.8.0/src/io/ |
H A D | stderr.rs | 96 let mut state_guard = self.0.lock().unwrap(); in poll_write() localVariable 97 let state = &mut *state_guard; in poll_write() 142 let mut state_guard = self.0.lock().unwrap(); in poll_flush() localVariable 143 let state = &mut *state_guard; in poll_flush()
|
H A D | stdout.rs | 96 let mut state_guard = self.0.lock().unwrap(); in poll_write() localVariable 97 let state = &mut *state_guard; in poll_write() 142 let mut state_guard = self.0.lock().unwrap(); in poll_flush() localVariable 143 let state = &mut *state_guard; in poll_flush()
|
H A D | stdin.rs | 156 let mut state_guard = self.0.lock().unwrap(); in poll_read() localVariable 157 let state = &mut *state_guard; in poll_read()
|
/dports/games/genact/genact-0.10.0/cargo-crates/async-std-1.6.3/src/io/ |
H A D | stderr.rs | 96 let mut state_guard = self.0.lock().unwrap(); in poll_write() localVariable 97 let state = &mut *state_guard; in poll_write() 142 let mut state_guard = self.0.lock().unwrap(); in poll_flush() localVariable 143 let state = &mut *state_guard; in poll_flush()
|
H A D | stdout.rs | 96 let mut state_guard = self.0.lock().unwrap(); in poll_write() localVariable 97 let state = &mut *state_guard; in poll_write() 142 let mut state_guard = self.0.lock().unwrap(); in poll_flush() localVariable 143 let state = &mut *state_guard; in poll_flush()
|
H A D | stdin.rs | 156 let mut state_guard = self.0.lock().unwrap(); in poll_read() localVariable 157 let state = &mut *state_guard; in poll_read()
|
/dports/security/rustscan/RustScan-2.0.1/cargo-crates/async-std-1.7.0/src/io/ |
H A D | stderr.rs | 96 let mut state_guard = self.0.lock().unwrap(); in poll_write() localVariable 97 let state = &mut *state_guard; in poll_write() 142 let mut state_guard = self.0.lock().unwrap(); in poll_flush() localVariable 143 let state = &mut *state_guard; in poll_flush()
|
H A D | stdout.rs | 96 let mut state_guard = self.0.lock().unwrap(); in poll_write() localVariable 97 let state = &mut *state_guard; in poll_write() 142 let mut state_guard = self.0.lock().unwrap(); in poll_flush() localVariable 143 let state = &mut *state_guard; in poll_flush()
|
H A D | stdin.rs | 156 let mut state_guard = self.0.lock().unwrap(); in poll_read() localVariable 157 let state = &mut *state_guard; in poll_read()
|
/dports/security/arti/arti-9d0ede26801cdb182daa85c3eb5f0058dc178eb6/cargo-crates/async-std-1.10.0/src/io/ |
H A D | stdout.rs | 96 let mut state_guard = self.0.lock().unwrap(); in poll_write() localVariable 97 let state = &mut *state_guard; in poll_write() 142 let mut state_guard = self.0.lock().unwrap(); in poll_flush() localVariable 143 let state = &mut *state_guard; in poll_flush()
|
H A D | stderr.rs | 96 let mut state_guard = self.0.lock().unwrap(); 97 let state = &mut *state_guard; 142 let mut state_guard = self.0.lock().unwrap(); 143 let state = &mut *state_guard;
|
H A D | stdin.rs | 156 let mut state_guard = self.0.lock().unwrap(); 157 let state = &mut *state_guard;
|
/dports/textproc/jql/jql-3.0.6/cargo-crates/async-std-1.10.0/src/io/ |
H A D | stderr.rs | 96 let mut state_guard = self.0.lock().unwrap(); in poll_write() localVariable 97 let state = &mut *state_guard; in poll_write() 142 let mut state_guard = self.0.lock().unwrap(); in poll_flush() localVariable 143 let state = &mut *state_guard; in poll_flush()
|
H A D | stdout.rs | 96 let mut state_guard = self.0.lock().unwrap(); in poll_write() localVariable 97 let state = &mut *state_guard; in poll_write() 142 let mut state_guard = self.0.lock().unwrap(); in poll_flush() localVariable 143 let state = &mut *state_guard; in poll_flush()
|
H A D | stdin.rs | 156 let mut state_guard = self.0.lock().unwrap(); in poll_read() localVariable 157 let state = &mut *state_guard; in poll_read()
|
/dports/biology/ncbi-cxx-toolkit/ncbi_cxx--25_2_0/src/corelib/ |
H A D | ncbithr.cpp | 621 CFastMutexGuard state_guard(s_ThreadMutex); in Wrapper() local 723 CFastMutexGuard state_guard(s_ThreadMutex); in Run() local 829 CFastMutexGuard state_guard(s_ThreadMutex); in Detach() local 861 CFastMutexGuard state_guard(s_ThreadMutex); in Join() local 894 CFastMutexGuard state_guard(s_ThreadMutex); in Join() local 908 CFastMutexGuard state_guard(s_ThreadMutex); in Exit() local 919 CFastMutexGuard state_guard(s_ThreadMutex); in Discard() local
|
/dports/biology/ncbi-blast+/ncbi-blast-2.12.0+-src/c++/src/corelib/ |
H A D | ncbithr.cpp | 621 CFastMutexGuard state_guard(s_ThreadMutex); in Wrapper() local 723 CFastMutexGuard state_guard(s_ThreadMutex); in Run() local 829 CFastMutexGuard state_guard(s_ThreadMutex); in Detach() local 861 CFastMutexGuard state_guard(s_ThreadMutex); in Join() local 894 CFastMutexGuard state_guard(s_ThreadMutex); in Join() local 908 CFastMutexGuard state_guard(s_ThreadMutex); in Exit() local 919 CFastMutexGuard state_guard(s_ThreadMutex); in Discard() local
|
/dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/utils/fallbackswitch/src/fallbacksrc/video_fallback/ |
H A D | imp.rs | 447 let mut state_guard = self.state.lock().unwrap(); in start() localVariable 448 if state_guard.is_some() { in start() 462 *state_guard = Some(State { source }); in start() 470 let mut state_guard = self.state.lock().unwrap(); in stop() localVariable 471 let state = match state_guard.take() { in stop() 476 drop(state_guard); in stop()
|
/dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/audio/lewton/src/lewtondec/ |
H A D | imp.rs | 128 let mut state_guard = self.state.borrow_mut(); in set_format() localVariable 129 *state_guard = Some(State { in set_format() 137 let mut state = state_guard.as_mut().unwrap(); in set_format() 168 let mut state_guard = self.state.borrow_mut(); in flush() localVariable 169 if let Some(ref mut state) = *state_guard { in flush() 191 let mut state_guard = self.state.borrow_mut(); in handle_frame() localVariable 192 let state = state_guard.as_mut().ok_or(gst::FlowError::NotNegotiated)?; in handle_frame()
|
/dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/video/closedcaption/src/ccdetect/ |
H A D | imp.rs | 168 let mut state_guard = self.state.lock().unwrap(); in maybe_update_properties() localVariable 169 let state = state_guard.as_mut().ok_or(gst::FlowError::NotNegotiated)?; in maybe_update_properties() 364 let mut state_guard = self.state.lock().unwrap(); in transform_ip_passthrough() localVariable 365 let state = state_guard.as_mut().ok_or(gst::FlowError::NotNegotiated)?; in transform_ip_passthrough()
|
/dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/video/rav1e/src/rav1enc/ |
H A D | imp.rs | 640 let mut state_guard = self.state.lock().unwrap(); in flush() localVariable 641 if let Some(ref mut state) = *state_guard { in flush() 654 let mut state_guard = self.state.lock().unwrap(); in finish() localVariable 655 if let Some(ref mut state) = *state_guard { in finish() 671 let mut state_guard = self.state.lock().unwrap(); in handle_frame() localVariable 672 let state = state_guard.as_mut().ok_or(gst::FlowError::NotNegotiated)?; in handle_frame()
|
/dports/multimedia/gstreamer1-plugins-rust/gst-plugins-rs-d0466b3eee114207f851b37cae0015c0e718f021/video/rspng/src/pngenc/ |
H A D | imp.rs | 333 let mut state_guard = self.state.lock(); in handle_frame() localVariable 334 let state = state_guard.as_mut().ok_or(gst::FlowError::NotNegotiated)?; in handle_frame() 363 drop(state_guard); in handle_frame()
|