- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 506 for signalM (0.43 sec)
-
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/runtime/testdata/testprogcgo/eintr.go
} } return r1, r2 } // winch sends a few SIGWINCH signals to the process. func winch() { ticker := time.NewTicker(100 * time.Microsecond) defer ticker.Stop() pid := syscall.Getpid() for n := 10; n > 0; n-- { syscall.Kill(pid, syscall.SIGWINCH) <-ticker.C } } // sendSomeSignals triggers a few SIGURG and SIGWINCH signals. func sendSomeSignals() { done := make(chan struct{}) go func() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Apr 05 17:54:15 UTC 2022 - 5.2K bytes - Viewed (0) -
src/cmd/cgo/internal/testsanitizers/testdata/tsan9.go
// license that can be found in the LICENSE file. package main // This program failed when run under the C/C++ ThreadSanitizer. The // TSAN library was not keeping track of whether signals should be // delivered on the alternate signal stack, and the Go signal handler // was not preserving callee-saved registers from C callers. /* #cgo CFLAGS: -g -fsanitize=thread #cgo LDFLAGS: -g -fsanitize=thread #include <stdlib.h>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 1.3K bytes - Viewed (0) -
pkg/util/interrupt/interrupt.go
h.once.Do(func() { for _, fn := range h.notify { fn() } }) } // Signal is called when an os.Signal is received, and guarantees that all notifications // are executed, then the final handler is executed. This function should only be called once // per Handler instance. func (h *Handler) Signal(s os.Signal) { h.once.Do(func() { for _, fn := range h.notify { fn() } if h.final == nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 09:22:35 UTC 2023 - 2.7K bytes - Viewed (0) -
src/runtime/cgo/gcc_netbsd.c
free(v); // On NetBSD, a new thread inherits the signal stack of the // creating thread. That confuses minit, so we remove that // signal stack here before calling the regular mstart. It's // a bit baroque to remove a signal stack here only to add one // in minit, but it's a simple change that keeps NetBSD // working like other OS's. At this point all signals are // blocked, so there is no race. memset(&ss, 0, sizeof ss);
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Aug 15 03:55:51 UTC 2023 - 1.7K bytes - Viewed (0) -
src/runtime/debuglog_on.go
func getCachedDlogger() *dlogger { mp := acquirem() // We don't return a cached dlogger if we're running on the // signal stack in case the signal arrived while in // get/putCachedDlogger. (Too bad we don't have non-atomic // exchange!) var l *dlogger if getg() != mp.gsignal { l = mp.dlogCache mp.dlogCache = nil } releasem(mp) return l }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 1.1K bytes - Viewed (0) -
src/runtime/testdata/testprogcgo/racesig.go
//go:build unix // +build unix package main // Test that an external C thread that is calling malloc can be hit // with SIGCHLD signals. This used to fail when built with the race // detector, because in that case the signal handler would indirectly // call the C malloc function. /* #include <errno.h> #include <signal.h> #include <stdint.h> #include <stdio.h> #include <stdlib.h> #include <pthread.h> #include <sched.h>
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 01:46:05 UTC 2023 - 1.7K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/test/groovy/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandlerTest.groovy
} def "client receives signal when lock is released"() { def signaled = new AtomicBoolean() when: int port = handler.reservePort() handler.start(10) { signal -> signal.trigger() } client.reservePort() client.start(11) {} client.maybePingOwner(port, 10, "lock 1", 50000) { signaled.set(true) } then:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:49 UTC 2024 - 6.1K bytes - Viewed (0) -
pkg/ctrlz/ctrlz_test.go
t.Fatal("Timed out waiting for listeningTestProbe to be called") } } func TestSignals(t *testing.T) { c := make(chan os.Signal, 1) signal.Notify(c, syscall.SIGUSR1) server := startAndWaitForServer(t) defer server.Close() reloadURL := fmt.Sprintf("http://%v/signalj/SIGUSR1", server.Address()) resp, err := http.DefaultClient.Post(reloadURL, "text/plain", nil) if err != nil { t.Fatalf("Run: %v", err) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 15 18:23:41 UTC 2024 - 2K bytes - Viewed (0) -
pkg/windows/service/service.go
case svc.Interrogate: s <- c.CurrentStatus case svc.Stop, svc.Shutdown: klog.Infof("Service stopping") // We need to translate this request into a signal that can be handled by the signal handler // handling shutdowns normally (currently apiserver/pkg/server/signal.go). // If we do not do this, our main threads won't be notified of the upcoming shutdown.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 24 11:25:33 UTC 2022 - 3.3K bytes - Viewed (0)