/third_party/python/Lib/test/ |
H A D | test_signal.py | 6 import signal namespace 27 for name in dir(signal): 28 sig = getattr(signal, name) 30 self.assertIsInstance(sig, signal.Handlers) 32 self.assertIsInstance(sig, signal.Sigmasks) 34 self.assertIsInstance(sig, signal.Signals) 36 self.assertIsInstance(sig, signal.Signals) 40 enum.IntEnum, 'Signals', 'signal', 45 source=signal, 47 enum._test_simple_enum(CheckedSignals, signal [all...] |
H A D | test_threadsignals.py | 1 """PyUnit testing that threads honor our signal semantics""" 4 import signal namespace 12 raise unittest.SkipTest("Can't test signal on %s" % sys.platform) 21 usr1 = signal.signal(signal.SIGUSR1, for_usr1) 22 usr2 = signal.signal(signal.SIGUSR2, for_usr2) 23 alrm = signal [all...] |
H A D | signalinterproctester.py | 2 import signal namespace 37 signal.pause() 39 self.fail('signal %s not received after %s seconds' 43 code = 'import os, signal; os.kill(%s, signal.%s)' % (pid, signame) 50 signal.signal(signal.SIGHUP, self.sighup_handler) 51 signal.signal(signa [all...] |
H A D | _test_eintr.py | 8 sub-second periodicity (contrarily to signal()). 17 import signal namespace 39 @unittest.skipUnless(hasattr(signal, "setitimer"), "requires setitimer()") 43 # delay for initial signal delivery 45 # signal delivery periodicity 56 self.orig_handler = signal.signal(signal.SIGALRM, self.sighandler) 57 signal.setitimer(signal [all...] |
/third_party/python/Lib/unittest/test/ |
H A D | test_break.py | 5 import signal namespace 21 self._default_handler = signal.getsignal(signal.SIGINT) 23 signal.signal(signal.SIGINT, self.int_handler) 26 signal.signal(signal.SIGINT, self._default_handler) 53 default_handler = signal [all...] |
/third_party/node/lib/internal/ |
H A D | abort_controller.js | 119 // the created timer object. Separately, we add the signal to a 120 // FinalizerRegistry that will clear the timeout when the signal is gc'd. 123 const signal = weakRef.deref(); 124 if (signal !== undefined) { 125 gcPersistentSignals.delete(signal); 127 signal, 186 const signal = createAbortSignal(); 187 signal[kTimeout] = true; 189 signal, 190 setWeakAbortSignalTimeout(new WeakRef(signal), dela [all...] |
/third_party/node/lib/timers/ |
H A D | promises.js | 45 function cancelListenerHandler(clear, reject, signal) { 48 reject(new AbortError(undefined, { cause: signal?.reason })); 61 const { signal, ref = true } = options; 63 validateAbortSignal(signal, 'options.signal'); 75 if (signal?.aborted) { 76 return PromiseReject(new AbortError(undefined, { cause: signal.reason })); 82 if (signal) { 84 timeout, clearTimeout, reject, signal); 86 signal [all...] |
/third_party/node/test/fixtures/wpt/streams/piping/ |
H A D | abort.any.js | 28 return promise_rejects_js(t, TypeError, rs.pipeTo(ws, { signal: invalidSignal }), 'pipeTo should reject') 33 }, `a signal argument '${invalidSignal}' should cause pipeTo() to reject`); 40 const signal = abortController.signal; 42 return promise_rejects_dom(t, 'AbortError', rs.pipeTo(ws, { signal }), 'pipeTo should reject') 54 }, 'an aborted signal should cause the writable stream to reject with an AbortError'); 61 const signal = abortController.signal; 63 const pipeToPromise = rs.pipeTo(ws, { signal }); 72 assert_equals(signal [all...] |
/third_party/node/test/fixtures/wpt/dom/abort/resources/ |
H A D | abort-signal-any-tests.js | 6 const signal = signalInterface.any([]); 7 assert_false(signal.aborted); 18 const signal = controller.signal; 19 const cloneSignal = signalInterface.any([signal]); 24 assert_not_equals(signal, cloneSignal, 25 `${desc} returns a new signal.`); 30 `The event target is the signal returned by ${desc}`); 35 assert_true(signal.aborted); 40 }, `${desc} follows a single signal [all...] |
/third_party/python/Lib/unittest/ |
H A D | signals.py | 1 import signal namespace 14 if default_handler == signal.SIG_DFL: 15 # Pretend it's signal.default_int_handler instead. 16 default_handler = signal.default_int_handler 17 elif default_handler == signal.SIG_IGN: 23 raise TypeError("expected SIGINT signal handler to be " 24 "signal.SIG_IGN, signal.SIG_DFL, or a " 29 installed_handler = signal.getsignal(signal [all...] |
/third_party/node/test/parallel/ |
H A D | test-whatwg-events-add-event-listener-options-signal.js | 9 // Manually ported from: wpt@dom/events/AddEventListenerOptions-signal.any.js 20 et.addEventListener('test', handler, { signal: controller.signal }); 22 strictEqual(count, 1, 'Adding a signal still adds a listener'); 31 et.addEventListener('test', handler, { signal: controller.signal }), 34 strictEqual(count, 2, 'Passing an aborted signal never adds the handler'); 45 et.addEventListener('test', handler, { signal: controller.signal }); 52 // Removing a once listener works with a passed signal [all...] |
H A D | test-child-process-exec-abortcontroller-promisified.js | 19 const signal = ac.signal; 20 const promise = execPromisifed(waitCommand, { signal }); 31 const signal = ac.signal; 32 const promise = execPromisifed(waitCommand, { signal }); 42 const signal = ac.signal; 43 const promise = execPromisifed(waitCommand, { signal }); 53 execPromisifed(waitCommand, { signal [all...] |
H A D | test-tls-connect-abort-controller.js | 19 const connectOptions = (signal) => ({ 22 signal, 37 const { signal } = ac; 38 const socket = tls.connect(connectOptions(signal)); 39 assert.strictEqual(getEventListeners(signal, 'abort').length, 1); 46 const { signal } = ac; 48 const socket = tls.connect(connectOptions(signal)); 49 assert.strictEqual(getEventListeners(signal, 'abort').length, 0); 55 const { signal } = ac; 56 const socket = tls.connect(connectOptions(signal)); [all...] |
H A D | test-abortcontroller.js | 23 ok(ac.signal); 24 ac.signal.onabort = common.mustCall((event) => { 28 ac.signal.addEventListener('abort', common.mustCall((event) => { 34 ok(ac.signal.aborted); 40 ac.signal.addEventListener('abort', common.mustCall((event) => { 52 first.signal.addEventListener('abort', common.mustCall((event) => { 55 second.signal.addEventListener('abort', common.mustCall((event) => { 70 throws(() => new ac.signal.constructor(), { 79 strictEqual(toString(ac.signal), '[object AbortSignal]'); 83 const signal [all...] |
H A D | test-abortsignal-cloneable.js | 33 mc.port2.postMessage(ac.signal, [ac.signal]); 36 mc.port2.postMessage(ac.signal, [ac.signal]); 42 ac.signal.addEventListener('abort', common.mustCall(() => { 43 strictEqual(ac.signal.reason, 'boom'); 62 const signal = transferableAbortSignal(AbortSignal.abort('boom')); 63 ok(signal.aborted); 64 strictEqual(signal.reason, 'boom'); 72 mc.port2.postMessage(signal, [signa [all...] |
H A D | test-child-process-execFile-promisified-abortController.js | 17 // Verify that the signal option works properly 19 const signal = ac.signal; 20 const promise = promisified(process.execPath, [echoFixture, 0], { signal }); 31 // Verify that the signal option works properly when already aborted 32 const signal = AbortSignal.abort(); 35 promisified(process.execPath, [echoFixture, 0], { signal }), 41 // Verify that if something different than Abortcontroller.signal 43 const signal = {}; 45 promisified(process.execPath, [echoFixture, 0], { signal }); [all...] |
H A D | test-child-process-execfile.js | 36 assert.strictEqual(err.signal, null); 53 // Verify that the signal option works properly 55 const { signal } = ac; 61 assert.strictEqual(err.signal, undefined); 63 execFile(process.execPath, [echoFixture, 0], { signal }, check); 66 // Verify that it still works the same way now that the signal is aborted. 73 const signal = AbortSignal.abort(); 78 assert.strictEqual(err.signal, undefined); 80 execFile(process.execPath, [echoFixture, 0], { signal }, check); 84 // Verify that if something different than Abortcontroller.signal [all...] |
/third_party/node/lib/internal/streams/ |
H A D | operators.js | 24 } = require('internal/streams/add-abort-signal'); 48 if (options?.signal != null) { 49 validateAbortSignal(options.signal, 'options.signal'); 58 if (options?.signal) { 61 options.signal, 77 if (options?.signal != null) { 78 validateAbortSignal(options.signal, 'options.signal'); 97 const signal [all...] |
H A D | add-abort-signal.js | 23 // It also does not allow for signal to not exist on the stream 25 const validateAbortSignal = (signal, name) => { 26 if (typeof signal !== 'object' || 27 !('aborted' in signal)) { 28 throw new ERR_INVALID_ARG_TYPE(name, 'AbortSignal', signal); 32 module.exports.addAbortSignal = function addAbortSignal(signal, stream) { 33 validateAbortSignal(signal, 'signal'); 37 return module.exports.addAbortSignalNoValidate(signal, stream); 40 module.exports.addAbortSignalNoValidate = function(signal, strea [all...] |
/third_party/skia/third_party/externals/swiftshader/third_party/marl/src/ |
H A D | conditionvariable_test.cpp | 24 bool signal[3] = {false, false, false}; in TEST_F() local 36 signal[i] = true; in TEST_F() 41 ASSERT_FALSE(signal[0]); in TEST_F() 42 ASSERT_FALSE(signal[1]); in TEST_F() 43 ASSERT_FALSE(signal[2]); in TEST_F() 52 return signal[i]; in TEST_F() 57 ASSERT_EQ(signal[0], 0 <= i); in TEST_F() 58 ASSERT_EQ(signal[1], 1 <= i); in TEST_F() 59 ASSERT_EQ(signal[2], 2 <= i); in TEST_F() 67 bool signal[ in TEST_P() local [all...] |
/third_party/python/Lib/multiprocessing/ |
H A D | resource_tracker.py | 19 import signal namespace 29 _HAVE_SIGMASK = hasattr(signal, 'pthread_sigmask') 30 _IGNORED_SIGNALS = (signal.SIGINT, signal.SIGTERM) 120 # bpo-33613: Register a signal mask that will block the signals. 121 # This signal mask will be inherited by the child that is going 123 # that can make the child die before it registers signal handlers 128 signal.pthread_sigmask(signal.SIG_BLOCK, _IGNORED_SIGNALS) 132 signal [all...] |
/third_party/ffmpeg/tests/ |
H A D | audiomatch.c | 44 int16_t *signal, *data; in main() local 82 signal = malloc(siglen * sizeof(*signal)); in main() 86 if (fread(signal, 1, siglen, f[1]) != siglen) in main() 92 signal[i] = ((uint8_t*)(signal + i))[0] + 256*((uint8_t*)(signal + i))[1]; in main() 93 sigamp += signal[i] * signal[i]; in main() 103 c += signal[ in main() [all...] |
/third_party/musl/libc-test/src/eabi/ |
H A D | __sigtimedwait_time64.c | 18 #include <signal.h> 44 int signal; in sigtimedwait_0100() local 47 signal = sigtimedwait(&set2, &siginfo, &timeout); in sigtimedwait_0100() 48 if (signal < 0) { in sigtimedwait_0100() 49 t_error( "%s sigtimedwait error get result is %d\n", __func__, signal); in sigtimedwait_0100() 73 int signal; in sigtimedwait_time64_0100() local 76 signal = __sigtimedwait_time64(&set2, &siginfo, &timeout); in sigtimedwait_time64_0100() 77 if (signal < 0) { in sigtimedwait_time64_0100() 78 t_error( "%s __sigtimedwait_time64 error get result is %d\n", __func__, signal); in sigtimedwait_time64_0100()
|
/third_party/node/deps/v8/tools/testrunner/local/ |
H A D | pool.py | 9 import signal namespace 97 int_handler = signal.signal(signal.SIGINT, signal.SIG_IGN) 98 term_handler = signal.signal(signal.SIGTERM, signal.SIG_IGN) 102 signal [all...] |
/third_party/python/Lib/asyncio/ |
H A D | runners.py | 7 import signal namespace 103 and signal.getsignal(signal.SIGINT) is signal.default_int_handler 107 signal.signal(signal.SIGINT, sigint_handler) 109 # `signal.signal` may throw if `threading.main_thread` does 127 and signal [all...] |