Home
last modified time | relevance | path

Searched refs:signal (Results 1 - 25 of 33) sorted by relevance

12

/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dsignal.rs14 #![cfg(feature = "signal")]
24 use ylong_runtime::signal::{signal, SignalKind};
41 /// SDV cases for signal `recv()`.
46 /// 2. Spawns a task to loop and listen to a signal.
51 let mut stream = signal(SignalKind::alarm()).unwrap(); in sdv_signal_recv_test()
60 /// SDV cases for signal `recv()` in multi thread.
64 /// 2. Spawns some tasks to listen to a signal.
65 /// 3. Send a notification signal when all signals are waiting.
73 let mut stream = signal(SignalKin in sdv_signal_recv_multi_thread_test()
137 let mut signal = signal(SignalKind::alarm()).unwrap(); sdv_signal_alarm() variables
152 let mut signal = signal(SignalKind::child()).unwrap(); sdv_signal_child() variables
167 let mut signal = signal(SignalKind::hangup()).unwrap(); sdv_signal_hangup() variables
182 let mut signal = signal(SignalKind::interrupt()).unwrap(); sdv_signal_interrupt() variables
197 let mut signal = signal(SignalKind::io()).unwrap(); sdv_signal_io() variables
212 let mut signal = signal(SignalKind::pipe()).unwrap(); sdv_signal_pipe() variables
227 let mut signal = signal(SignalKind::terminate()).unwrap(); sdv_signal_terminate() variables
242 let mut signal = signal(SignalKind::user_defined1()).unwrap(); sdv_signal_user_defined1() variables
257 let mut signal = signal(SignalKind::user_defined2()).unwrap(); sdv_signal_user_defined2() variables
272 let mut signal = signal(SignalKind::window_change()).unwrap(); sdv_signal_window_change() variables
[all...]
H A Dentry.rs35 mod signal; modules
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/
H A Dmod.rs14 //! Asynchronous signal handling.
27 use crate::signal::Signal;
48 /// use ylong_runtime::signal::{signal, SignalKind};
52 /// let mut signal = signal(signal_kind).unwrap();
53 /// signal.recv().await;
67 /// use ylong_runtime::signal::SignalKind;
77 /// SIGALRM signal.
86 /// use ylong_runtime::signal
401 pub fn signal(kind: SignalKind) -> io::Result<Signal> { signal() functions
454 let mut signal = signal(SignalKind::alarm()).unwrap(); ut_signal_recv_and_poll_recv() variables
459 let mut signal = signal(SignalKind::alarm()).unwrap(); ut_signal_recv_and_poll_recv() variables
473 let mut signal = signal(SignalKind::alarm()).unwrap(); ut_signal_alarm() variables
488 let mut signal = signal(SignalKind::child()).unwrap(); ut_signal_child() variables
503 let mut signal = signal(SignalKind::hangup()).unwrap(); ut_signal_hangup() variables
518 let mut signal = signal(SignalKind::interrupt()).unwrap(); ut_signal_interrupt() variables
533 let mut signal = signal(SignalKind::io()).unwrap(); ut_signal_io() variables
548 let mut signal = signal(SignalKind::pipe()).unwrap(); ut_signal_pipe() variables
563 let mut signal = signal(SignalKind::terminate()).unwrap(); ut_signal_terminate() variables
578 let mut signal = signal(SignalKind::user_defined1()).unwrap(); ut_signal_user_defined1() variables
593 let mut signal = signal(SignalKind::user_defined2()).unwrap(); ut_signal_user_defined2() variables
608 let mut signal = signal(SignalKind::window_change()).unwrap(); ut_signal_window_change() variables
[all...]
H A Ddriver.rs21 use crate::signal::unix::registry::Registry;
37 Ok(0) => panic!("EOF occurs in signal stream"),
40 Err(e) => panic!("Error occurs in signal stream: {e}"),
H A Dregistry.rs25 use crate::signal::SignalKind;
63 Err(Error::new(ErrorKind::Other, "Failed to register signal"))
110 // Invalid signal kinds have been forbidden, the scope of signal kinds has been
118 // Invalid signal kinds have been forbidden, the scope of signal kinds has been
/commonlibrary/rust/ylong_runtime/ylong_signal/src/
H A Dwindows.rs14 //! windows wrapping of signal syscall
25 let old_act = unsafe { libc::signal(sig_num, SIG_GET) };
41 let old_act = unsafe { libc::signal(sig_num, new_action) };
53 let old = unsafe { libc::signal(sig_num, sig_handler as usize) };
65 if let Some(signal) = data.get(&sig_num) {
66 if let Some(act) = &signal.new_act {
76 // of the signal cannot be found, we execute this old handler instead if the
H A Dunix.rs14 //! Linux wrapping of signal syscall
61 if let Some(signal) = signals.get(&sig_num) {
69 if let Some(act) = &signal.new_act {
79 // of the signal cannot be found, we execute this old handler instead if the
91 // SIG_IGN to ignore this signal. in execute_act()
96 // If SA_SIGINFO flag is set, then the signal handler takes three arguments, not in execute_act()
/commonlibrary/ets_utils/platform/ohos/
H A Dprocess_helper.cpp20 void ProcessExit(int signal) in ProcessExit() argument
22 quick_exit(signal); in ProcessExit()
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_signal.rs27 use ylong_runtime::signal::{signal, SignalKind};
44 let mut stream = signal(SignalKind::child()).unwrap(); in run_multi_thread_signal()
63 let mut stream = signal(SignalKind::ctrl_c()).unwrap(); in run_multi_thread_signal()
66 println!("signal received"); in run_multi_thread_signal()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/
H A Dchild.rs26 use crate::signal::{signal, Signal, SignalKind};
30 signal: Signal,
37 signal: signal(SignalKind::child())?,
68 let signal_pending = self.signal.poll_recv(cx).is_pending(); in fmt()
H A Dzombie_manager.rs18 use crate::signal::unix::signal_return_watch;
19 use crate::signal::SignalKind;
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Ddriver.rs29 use crate::signal::unix::SignalDriver;
42 #[cfg(all(feature = "signal", target_family = "unix"))]
43 signal: SignalDriver,
60 #[cfg(all(feature = "signal", target_family = "unix"))]
65 #[cfg(all(feature = "signal", target_family = "unix"))]
66 signal: signal_driver,
81 #[cfg(all(feature = "signal", target_family = "unix"))]
83 self.signal.broadcast();
105 #[cfg(all(feature = "signal", target_family = "unix"))]
107 self.signal
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/
H A Dmod.rs14 //! Asynchronous signal handling.
19 pub use unix::{signal, SignalKind};
26 pub use windows::{signal, SignalKind};
34 /// stream, so for multiple triggers of the same signal, the receiver may only
35 /// receive one notification, which includes all triggered signal kinds.
37 /// When registering a listener for a certain kind of signal for the first time,
49 /// use ylong_runtime::signal::{signal, SignalKind};
52 /// let mut signal = signal(SignalKin
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_signal.rs14 //! Benchmarks for signal.
17 //! - Multiple threads listen to the same signal and wake up once when all
18 //! threads are waiting for the signal.
19 //! - A single thread loops to wait for a signal, and the loop notifies until
135 use tokio::signal::unix::{signal as tokio_signal, SignalKind as TokioSignalKind};
136 #[cfg(feature = "signal")]
137 use ylong_runtime::signal::{signal as ylong_signal, SignalKind as YlongSignalKind};
/commonlibrary/ets_utils/platform/default/
H A Dprocess_helper.cpp28 void ProcessExit(int signal) in ProcessExit() argument
30 quick_exit(signal); in ProcessExit()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/windows/
H A Dmod.rs14 //! Asynchronous signal handling in windows system.
24 use crate::signal::Signal;
31 /// "ctrl-break" signal type.
36 /// use ylong_runtime::signal::{signal, SignalKind};
39 /// let mut signal = signal(SignalKind::ctrl_break()).unwrap();
40 /// signal.recv().await;
49 /// "ctrl-close" signal type.
54 /// use ylong_runtime::signal
162 pub fn signal(kind: SignalKind) -> io::Result<Signal> { signal() functions
[all...]
/commonlibrary/ets_utils/js_concurrent_module/utils/locks/
H A Dlock_request.cpp198 if (options_.signal == nullptr) { in AbortIfNeeded()
201 napi_value signal; in AbortIfNeeded() local
202 napi_get_reference_value(env_, options_.signal, &signal); in AbortIfNeeded()
203 napi_value aborted = NapiHelper::GetNameProperty(env_, signal, "aborted"); in AbortIfNeeded()
209 napi_value reason = NapiHelper::GetNameProperty(env_, signal, "reason"); in AbortIfNeeded()
H A Dasync_lock_manager.cpp46 napi_value signal; in AsyncLockOptionsCtor() local
47 napi_get_null(env, &signal); in AsyncLockOptionsCtor()
53 DECLARE_NAPI_DEFAULT_PROPERTY("signal", signal), in AsyncLockOptionsCtor()
458 napi_value signal = NapiHelper::GetNameProperty(env, val, "signal"); in GetLockOptions() local
463 if (signal != nullptr) { in GetLockOptions()
464 napi_create_reference(env, signal, 1, &options.signal); in GetLockOptions()
H A Dlock_request.h36 napi_ref signal = nullptr; member
/commonlibrary/rust/ylong_runtime/ylong_signal/tests/
H A Dentry.rs18 mod signal; modules
/commonlibrary/ets_utils/platform/
H A Dprocess_helper.h26 void ProcessExit(int signal);
/commonlibrary/ets_utils/js_sys_module/process/
H A Djs_process.h106 * Send a signal to the specified process and end the specified process.
109 * @param signal The parameter is the signal sent.
112 napi_value Kill(napi_env env, napi_value signal, napi_value proid);
295 * Send a signal to the specified process and end the specified process.
298 * @param signal The parameter is the signal sent.
301 napi_value Kill(napi_env env, napi_value signal, napi_value proid);
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/
H A Dlib.rs65 pub mod signal; modules
/commonlibrary/utils_lite/kal/timer/include/
H A Dkal.h18 #include <signal.h>
/commonlibrary/ets_utils/js_sys_module/test/
H A Dtest_process.cpp100 * @tc.desc: Test process kill signal.
115 napi_value signal = nullptr; in HWTEST_F() local
116 napi_create_int32(env, 9, &signal); in HWTEST_F()
117 napi_value result = process.Kill(env, pid, signal); in HWTEST_F()
125 * @tc.desc: Test process kill signal.
140 napi_value signal = nullptr; in HWTEST_F() local
141 napi_create_int32(env, 999, &signal); in HWTEST_F()
142 napi_value result = process.Kill(env, pid, signal); in HWTEST_F()
711 * @tc.desc: Send a signal to process.

Completed in 9 milliseconds

12