| /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()
|