- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 460 for signalfd (0.5 sec)
-
staging/src/k8s.io/apiserver/pkg/server/lifecycle_signals.go
type lifecycleSignal interface { // Signal signals the event, indicating that the event has occurred. // Signal is idempotent, once signaled the event stays signaled and // it immediately unblocks any goroutine waiting for this event. Signal() // Signaled returns a channel that is closed when the underlying event // has been signaled. Successive calls to Signaled return the same value. Signaled() <-chan struct{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:30 UTC 2023 - 7.8K bytes - Viewed (0) -
src/internal/fuzz/sys_posix.go
// If not, -1 and false. func terminationSignal(err error) (os.Signal, bool) { exitErr, ok := err.(*exec.ExitError) if !ok || exitErr.ExitCode() >= 0 { return syscall.Signal(-1), false } status := exitErr.Sys().(syscall.WaitStatus) return status.Signal(), status.Signaled() } // isCrashSignal returns whether a signal was likely to have been caused by an // error in the program that received it, triggered by a fuzz input. For
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 12 19:47:40 UTC 2022 - 4.1K bytes - Viewed (0) -
src/cmd/cgo/internal/testsanitizers/testdata/tsan11.go
// This program hung when run under the C/C++ ThreadSanitizer. TSAN defers // asynchronous signals until the signaled thread calls into libc. The runtime's // sysmon goroutine idles itself using direct usleep syscalls, so it could // run for an arbitrarily long time without triggering the libc interceptors. // See https://golang.org/issue/18717. import ( "os" "os/signal" "syscall" ) /* #cgo CFLAGS: -g -fsanitize=thread
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 1.2K bytes - Viewed (0) -
src/runtime/testdata/testwinsignal/main.go
import ( "fmt" "io" "log" "os" "os/signal" "syscall" "time" ) func main() { // Ensure that this process terminates when the test times out, // even if the expected signal never arrives. go func() { io.Copy(io.Discard, os.Stdin) log.Fatal("stdin is closed; terminating") }() // Register to receive all signals. c := make(chan os.Signal, 1) signal.Notify(c) // Get console window handle.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Mar 18 07:37:53 UTC 2022 - 1.3K bytes - Viewed (0) -
src/syscall/syscall_js.go
} // A Signal is a number describing a process signal. // It implements the [os.Signal] interface. type Signal int const ( _ Signal = iota SIGCHLD SIGINT SIGKILL SIGTRAP SIGQUIT SIGTERM ) func (s Signal) Signal() {} func (s Signal) String() string { if 0 <= s && int(s) < len(signals) { str := signals[s] if str != "" { return str }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:03:59 UTC 2024 - 6.7K 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/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) -
src/cmd/vendor/golang.org/x/sys/plan9/mkerrors.sh
buf[0] += a - A; printf("\t%d: \"%s\",\n", e, buf); } printf("}\n\n"); printf("\n\n// Signal table\n"); printf("var signals = [...]string {\n"); qsort(signals, nelem(signals), sizeof signals[0], intcmp); for(i=0; i<nelem(signals); i++) { e = signals[i]; if(i > 0 && signals[i-1] == e) continue; strcpy(buf, strsignal(e)); // lowercase first letter: Bad -> bad, but STREAM -> STREAM.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 26 00:11:50 UTC 2022 - 5.9K bytes - Viewed (2)