- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,052 for signalfd (0.17 sec)
-
src/os/signal/signal_test.go
} func waitSig(t *testing.T, c <-chan os.Signal, sig os.Signal) { t.Helper() waitSig1(t, c, sig, false) } func waitSigAll(t *testing.T, c <-chan os.Signal, sig os.Signal) { t.Helper() waitSig1(t, c, sig, true) } func waitSig1(t *testing.T, c <-chan os.Signal, sig os.Signal, all bool) { t.Helper() // Sleep multiple times to give the kernel more tries to // deliver the signal. start := time.Now()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Nov 09 15:34:56 UTC 2023 - 27.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
* the monitor without signalling. If it timed out without being signalled, it does not need to * "pass on" the signal to another thread. If it *was* signalled, then its guard must have been * satisfied at the time of signal, and has since been modified by some other thread to be * non-satisfied before reacquiring the lock, and that other thread takes over the responsibility
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 38.6K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/DefaultFileLockManagerAwaitableFileLockReleasedSignalTest.groovy
@Subject def signal = new DefaultFileLockManager.AwaitableFileLockReleasedSignal() def "can reuse signal"() { given: def signalCount = new AtomicInteger() when: start { while (signalCount.get() < 2) { def signaled = signal.await(10000) if (signaled) { signalCount.incrementAndGet()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:08:47 UTC 2023 - 1.8K bytes - Viewed (0) -
src/runtime/sigqueue.go
} } } // signalWaitUntilIdle waits until the signal delivery mechanism is idle. // This is used to ensure that we do not drop a signal notification due // to a race between disabling a signal and receiving a signal. // This assumes that signal delivery has already been disabled for // the signal(s) in question, and here we are just waiting to make sure // that all the signals have been delivered to the user channels
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.6K bytes - Viewed (0) -
src/os/signal/doc.go
asynchronous signal, a Go signal handler will be installed for that signal. If, later, Reset is called for that signal, the original handling for that signal will be reinstalled, restoring the non-Go signal handler if any. Go code built without -buildmode=c-archive or -buildmode=c-shared will install a signal handler for the asynchronous signals listed above, and save any existing signal handler. If a signal is delivered to a
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 18:11:00 UTC 2024 - 11K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
defer notAcceptingNewRequestCh.Signal() // wait for the delayed stopCh before closing the handler chain <-delayedStopCh.Signaled() // Additionally wait for preshutdown hooks to also be finished, as some of them need // to send API calls to clean up after themselves (e.g. lease reconcilers removing // itself from the active servers). <-preShutdownHooksHasStoppedCh.Signaled() }()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 42.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Monitor.java
* the monitor without signalling. If it timed out without being signalled, it does not need to * "pass on" the signal to another thread. If it *was* signalled, then its guard must have been * satisfied at the time of signal, and has since been modified by some other thread to be * non-satisfied before reacquiring the lock, and that other thread takes over the responsibility
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 42.5K bytes - Viewed (0) -
src/runtime/os_linux.go
func getpid() int func tgkill(tgid, tid, sig int) // signalM sends a signal to mp. func signalM(mp *m, sig int) { tgkill(getpid(), int(mp.procid), sig) } // validSIGPROF compares this signal delivery's code against the signal sources // that the profiler uses, returning whether the delivery should be processed. // To be processed, a signal delivery from a known profiling mechanism should
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 25.9K bytes - Viewed (0) -
src/os/signal/example_test.go
// Set up channel on which to send signal notifications. // We must use a buffered channel or risk missing the signal // if we're not ready to receive when the signal is sent. c := make(chan os.Signal, 1) // Passing no signals to Notify means that // all signals will be sent to the channel. signal.Notify(c) // Block until any signal is received. s := <-c fmt.Println("Got signal:", s)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 01 18:38:23 UTC 2017 - 1001 bytes - Viewed (0) -
platforms/core-runtime/time/src/main/java/org/gradle/internal/time/ExponentialBackoff.java
} public static <T extends Signal> ExponentialBackoff<T> of(int amount, TimeUnit unit, T signal) { return new ExponentialBackoff<T>((int) TimeUnit.MILLISECONDS.convert(amount, unit), signal, SLOT_TIME); } public static ExponentialBackoff<Signal> of(int amount, TimeUnit unit, int slotTime, TimeUnit slotTimeUnit) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 12 08:49:35 UTC 2024 - 4.8K bytes - Viewed (0)