Home
last modified time | relevance | path

Searched refs:signal (Results 126 - 150 of 2892) sorted by relevance

12345678910>>...116

/third_party/node/lib/internal/streams/
H A Dend-of-stream.js65 validateAbortSignal(options.signal, 'options.signal');
245 if (options.signal && !closed) {
252 new AbortError(undefined, { cause: options.signal.reason }));
254 if (options.signal.aborted) {
258 const disposable = addAbortListener(options.signal, abort);
273 if (options.signal) {
276 callback.call(stream, new AbortError(undefined, { cause: options.signal.reason }));
278 if (options.signal.aborted) {
282 const disposable = addAbortListener(options.signal, abor
[all...]
/third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/
H A Devent.h27 // Event is a synchronization primitive used to block until a signal is raised.
31 // The event signal will be automatically reset when a call to wait()
33 // A single call to signal() will only unblock a single (possibly
47 // signal() signals the event, possibly unblocking a call to wait().
48 MARL_NO_EXPORT inline void signal() const;
85 // Unlike test() the signal is not automatically cleared when the event was
110 MARL_NO_EXPORT inline void signal();
134 void Event::Shared::signal() { in signal() function in marl::Event::Shared
146 dep->signal(); in signal()
189 void Event::signal() cons function in marl::Event
[all...]
/third_party/libdrm/etnaviv/
H A Detnaviv_perfmon.c50 INFO_MSG("perfmon signal:"); in etna_perfmon_query_signals()
55 sig->signal = req.id; in etna_perfmon_query_signals()
175 struct etna_perfmon_signal *signal; in etna_perfmon_get_sig_by_name() local
178 LIST_FOR_EACH_ENTRY(signal, &dom->signals, head) { in etna_perfmon_get_sig_by_name()
179 if (!strcmp(signal->name, name)) in etna_perfmon_get_sig_by_name()
180 return signal; in etna_perfmon_get_sig_by_name()
/third_party/mesa3d/src/etnaviv/drm/
H A Detnaviv_perfmon.c50 DEBUG_MSG("perfmon signal:"); in etna_perfmon_query_signals()
55 sig->signal = req.id; in etna_perfmon_query_signals()
175 struct etna_perfmon_signal *signal; in etna_perfmon_get_sig_by_name() local
178 LIST_FOR_EACH_ENTRY(signal, &dom->signals, head) { in etna_perfmon_get_sig_by_name()
179 if (!strcmp(signal->name, name)) in etna_perfmon_get_sig_by_name()
180 return signal; in etna_perfmon_get_sig_by_name()
/third_party/node/test/parallel/
H A Dtest-domain-with-abort-on-uncaught-exception.js111 child.on('exit', function onChildExited(exitCode, signal) {
116 assert(common.nodeProcessAborted(exitCode, signal),
122 assert.strictEqual(signal, null);
129 assert.strictEqual(signal, null);
H A Dtest-stdout-stderr-reading.js36 c1.on('close', common.mustCall(function(code, signal) {
38 assert(!signal);
53 c2.on('close', common.mustCall(function(code, signal) {
55 assert(!signal);
H A Dtest-runner-cli.js17 assert.strictEqual(child.signal, null);
29 assert.strictEqual(child.signal, null);
53 assert.strictEqual(child.signal, null);
63 assert.strictEqual(child.signal, null);
75 assert.strictEqual(child.signal, null);
88 assert.strictEqual(child.signal, null);
112 assert.strictEqual(child.signal, null);
131 assert.strictEqual(child.signal, null);
179 assert.strictEqual(child.signal, null);
206 assert.strictEqual(child.signal, nul
[all...]
H A Dtest-stream-map.js162 const stream = range.map(common.mustCall(async (_, { signal }) => {
163 await once(signal, 'abort');
164 throw signal.reason;
165 }, 2), { signal: ac.signal, concurrency: 2, highWaterMark: 0 });
182 const stream = Readable.from([1, 2]).map(async (item, { signal }) => {
183 await setTimeout(10 - item, { signal });
354 assert.throws(() => Readable.from([1]).map((x) => x, { signal: true }), /ERR_INVALID_ARG_TYPE/);
/third_party/musl/libc-test/src/functionalext/supplement/time/
H A Dtimer_settime.c17 #include <signal.h>
54 signal(SIGNUM, handler); in timer_settime_0100()
89 signal(SIGSEGV, exception_handler); in timer_settime_0200()
108 signal(SIGNUM, handler); in timer_settime64_0100()
/third_party/rust/crates/nix/test/
H A Dtest_timer.rs1 use nix::sys::signal::{
16 let signal = Signal::try_from(raw_signal).unwrap(); in handle_sigalarm()
17 if signal == SIG { in handle_sigalarm()
24 // Avoid interfering with other signal using tests by taking a mutex shared in alarm_fires()
33 // Create a handler for the test signal, `SIG`. The handler is responsible in alarm_fires()
40 .expect("unable to set signal handler for alarm") in alarm_fires()
48 signal: SIG, in alarm_fires()
94 // 2) Replace the old signal handler now that we've completed the test. If in alarm_fires()
100 sigaction(SIG, &old_handler).expect("unable to reset signal handler"); in alarm_fires()
/third_party/libunwind/libunwind/tests/
H A Dmapper.c32 #include <signal.h>
60 signal (SIGUSR1, SIG_IGN); in main()
61 signal (SIGUSR2, SIG_IGN); in main()
/third_party/python/Lib/test/
H A Dwin_console_handler.py12 import signal namespace
22 if sig == signal.CTRL_C_EVENT:
24 elif sig == signal.CTRL_BREAK_EVENT:
47 # Do nothing but wait for the signal
H A Dtest_selectors.py5 import signal namespace
392 @unittest.skipUnless(hasattr(signal, "alarm"),
393 "signal.alarm() required for this test")
406 orig_alrm_handler = signal.signal(signal.SIGALRM, handler)
407 self.addCleanup(signal.signal, signal.SIGALRM, orig_alrm_handler)
410 signal
[all...]
/third_party/rust/crates/nix/src/sys/
H A Dpthread.rs23 #![feature = "signal"]
25 /// Send a signal to a thread (see [`pthread_kill(3)`]).
27 /// If `signal` is `None`, `pthread_kill` will only preform error checking and
28 /// won't send any signal.
33 pub fn pthread_kill<T>(thread: Pthread, signal: T) -> Result<()> in pthread_kill()
34 where T: Into<Option<crate::sys::signal::Signal>> in pthread_kill()
36 let sig = match signal.into() { in pthread_kill()
/third_party/node/lib/internal/test_runner/
H A Dtest.js81 function stopTest(timeout, signal) {
83 const abortListener = addAbortListener(signal, deferred.resolve);
127 get signal() {
128 return this.#test.signal;
194 get signal() {
195 return this.#suite.signal;
212 const { concurrency, loc, only, timeout, todo, signal } = options;
304 this.outerSignal = signal;
305 this.signal = this.abortController.signal;
[all...]
/third_party/python/Lib/asyncio/
H A Dunix_events.py1 """Selector event loop for Unix with signal handling."""
8 import signal namespace
43 """Dummy signal handler."""
60 Adds signal handling and UNIX Domain Socket support to SelectorEventLoop.
76 f"stage, skipping signal handlers removal",
89 """Add a handler for a signal. UNIX only.
91 Raise ValueError if the signal number is invalid or uncatchable.
103 # event loop running in another thread cannot add a signal
105 signal.set_wakeup_fd(self._csock.fileno())
113 # Register a dummy signal handle
[all...]
/third_party/node/lib/internal/fs/
H A Dpromises.js430 function checkAborted(signal) {
431 if (signal?.aborted)
432 throw new AbortError(undefined, { cause: signal?.reason });
435 async function writeFileHandle(filehandle, data, signal, encoding) {
436 checkAborted(signal);
439 checkAborted(signal);
448 checkAborted(signal);
457 checkAborted(signal);
471 const signal = options?.signal;
[all...]
/foundation/multimedia/av_codec/test/nativedemo/audio_demo/
H A Davcodec_audio_aac_encoder_demo.cpp63 AEncSignal *signal = static_cast<AEncSignal *>(userData); in OnInputBufferAvailable() local
64 unique_lock<mutex> lock(signal->inMutex_); in OnInputBufferAvailable()
65 signal->inQueue_.push(index); in OnInputBufferAvailable()
66 signal->inBufferQueue_.push(data); in OnInputBufferAvailable()
67 signal->inCond_.notify_all(); in OnInputBufferAvailable()
74 AEncSignal *signal = static_cast<AEncSignal *>(userData); in OnOutputBufferAvailable() local
75 unique_lock<mutex> lock(signal->outMutex_); in OnOutputBufferAvailable()
76 signal->outQueue_.push(index); in OnOutputBufferAvailable()
77 signal->outBufferQueue_.push(data); in OnOutputBufferAvailable()
81 signal in OnOutputBufferAvailable()
[all...]
H A Davcodec_audio_decoder_demo.cpp78 ADecSignal *signal = static_cast<ADecSignal *>(userData); in OnInputBufferAvailable() local
79 unique_lock<mutex> lock(signal->inMutex_); in OnInputBufferAvailable()
80 signal->inQueue_.push(index); in OnInputBufferAvailable()
81 signal->inBufferQueue_.push(data); in OnInputBufferAvailable()
82 signal->inCond_.notify_all(); in OnInputBufferAvailable()
89 ADecSignal *signal = static_cast<ADecSignal *>(userData); in OnOutputBufferAvailable() local
90 unique_lock<mutex> lock(signal->outMutex_); in OnOutputBufferAvailable()
91 signal->outQueue_.push(index); in OnOutputBufferAvailable()
92 signal->outBufferQueue_.push(data); in OnOutputBufferAvailable()
94 signal in OnOutputBufferAvailable()
[all...]
H A Davcodec_audio_flac_encoder_demo.cpp69 AEncSignal *signal = static_cast<AEncSignal *>(userData); in OnInputBufferAvailable() local
70 unique_lock<mutex> lock(signal->inMutex_); in OnInputBufferAvailable()
71 signal->inQueue_.push(index); in OnInputBufferAvailable()
72 signal->inBufferQueue_.push(data); in OnInputBufferAvailable()
73 signal->inCond_.notify_all(); in OnInputBufferAvailable()
80 AEncSignal *signal = static_cast<AEncSignal *>(userData); in OnOutputBufferAvailable() local
81 unique_lock<mutex> lock(signal->outMutex_); in OnOutputBufferAvailable()
82 signal->outQueue_.push(index); in OnOutputBufferAvailable()
83 signal->outBufferQueue_.push(data); in OnOutputBufferAvailable()
85 signal in OnOutputBufferAvailable()
[all...]
H A Davcodec_audio_g711mu_encoder_demo.cpp63 AEncSignal *signal = static_cast<AEncSignal *>(userData); in OnInputBufferAvailable() local
64 unique_lock<mutex> lock(signal->inMutex_); in OnInputBufferAvailable()
65 signal->inQueue_.push(index); in OnInputBufferAvailable()
66 signal->inBufferQueue_.push(data); in OnInputBufferAvailable()
67 signal->inCond_.notify_all(); in OnInputBufferAvailable()
74 AEncSignal *signal = static_cast<AEncSignal *>(userData); in OnOutputBufferAvailable() local
75 unique_lock<mutex> lock(signal->outMutex_); in OnOutputBufferAvailable()
76 signal->outQueue_.push(index); in OnOutputBufferAvailable()
77 signal->outBufferQueue_.push(data); in OnOutputBufferAvailable()
81 signal in OnOutputBufferAvailable()
[all...]
/third_party/node/deps/undici/src/lib/core/
H A Dutil.js430 function throwIfAborted (signal) {
431 if (!signal) { return }
432 if (typeof signal.throwIfAborted === 'function') {
433 signal.throwIfAborted()
435 if (signal.aborted) {
444 function addAbortListener (signal, listener) {
445 if ('addEventListener' in signal) {
446 signal.addEventListener('abort', listener, { once: true })
447 return () => signal.removeEventListener('abort', listener)
449 signal
[all...]
/third_party/ltp/testcases/kernel/mem/mtest06/
H A Dmmap2.c68 #include <signal.h>
71 #include <signal.h>
119 static void sig_handler(int signal) in sig_handler() argument
121 if (signal != SIGALRM) { in sig_handler()
122 fprintf(stderr, "sig_handlder(): unexpected signal caught" in sig_handler()
123 "[%d]\n", signal); in sig_handler()
/third_party/python/Lib/multiprocessing/
H A Dresource_sharer.py12 import signal namespace
134 if hasattr(signal, 'pthread_sigmask'):
135 signal.pthread_sigmask(signal.SIG_BLOCK, signal.valid_signals())
/third_party/python/Lib/test/libregrtest/
H A Dsetup.py4 import signal namespace
34 # Display the Python traceback on SIGALRM or SIGUSR1 signal
36 if hasattr(signal, 'SIGALRM'):
37 signals.append(signal.SIGALRM)
38 if hasattr(signal, 'SIGUSR1'):
39 signals.append(signal.SIGUSR1)

Completed in 10 milliseconds

12345678910>>...116