- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 386 for signalM (0.13 sec)
-
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) -
src/runtime/cgo/gcc_signal_ios_arm64.c
// Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Emulation of the Unix signal SIGSEGV. // // On iOS, Go tests and apps under development are run by lldb. // The debugger uses a task-level exception handler to intercept signals. // Despite having a 'handle' mechanism like gdb, lldb will not allow a // SIGSEGV to pass to the running program. For Go, this means we cannot
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 21:04:22 UTC 2024 - 6K bytes - Viewed (0) -
src/runtime/testdata/testprogcgo/raceprof.go
//go:build unix // +build unix package main // Test that we can collect a lot of colliding profiling signals from // an external C thread. This used to fail when built with the race // detector, because a call of the predeclared function copy was // turned into a call to runtime.slicecopy, which is not marked nosplit. /* #include <signal.h> #include <stdint.h> #include <pthread.h> #include <sched.h> struct cgoTracebackArg {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 24 18:13:14 UTC 2023 - 1.7K bytes - Viewed (0) -
src/runtime/cpuprof.go
log *profBuf // profile events written here // extra holds extra stacks accumulated in addNonGo // corresponding to profiling signals arriving on // non-Go-created threads. Those stacks are written // to log the next time a normal Go thread gets the // signal handler. // Assuming the stacks are 2 words each (we don't get // a full traceback from those threads), plus one word
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 8.5K bytes - Viewed (0) -
src/os/exec_posix.go
"runtime" "syscall" ) // The only signal values guaranteed to be present in the os package on all // systems are os.Interrupt (send the process an interrupt) and os.Kill (force // the process to exit). On Windows, sending os.Interrupt to a process with // os.Process.Signal is not implemented; it will return an error instead of // sending a signal. var ( Interrupt Signal = syscall.SIGINT Kill Signal = syscall.SIGKILL )
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 22:06:47 UTC 2024 - 3.7K bytes - Viewed (0) -
src/runtime/signal_darwin_amd64.go
// than it does for an attempt to access a valid but unmapped address. // OS X 10.9.2 mishandles the malformed address case, making it look like // a user-generated signal (like someone ran kill -SEGV ourpid). // We pass user-generated signals to os/signal, or else ignore them. // Doing that here - and returning to the faulting code - results in an // infinite loop. It appears the best we can do is rewrite what the kernel
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Aug 19 23:07:11 UTC 2022 - 4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/watch_termination.go
// When apiserver is shutting down, signal clients to retry // There is a good chance the client hit a different server, so a tight retry is good for client responsiveness. waitGroupWriteRetryAfterToResponse(w) return } // attach ServerShutdownSignal to the watch request so that the // watch handler loop can return as soon as the server signals // that it is shutting down.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:49 UTC 2023 - 2K bytes - Viewed (0) -
tensorflow/compiler/mlir/tfrt/ir/mlrt/mlrt_ops.td
} def AwaitAllControlOp: Mlrt_Op<"await_all_control", []> { let summary = "Awaits multiple signals"; let description = [{ Awaits multiple signals $futures: A list of !mlrt.futures }]; let arguments = (ins Variadic<MlrtFutureType>:$futures ); let assemblyFormat = "operands attr-dict `:` type($futures)"; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jun 08 22:07:30 UTC 2023 - 6.4K bytes - Viewed (0) -
src/sync/cond_test.go
} for n > 0 { select { case <-awake: t.Fatal("goroutine not asleep") default: } m.Lock() c.Signal() m.Unlock() <-awake // Will deadlock if no goroutine wakes up select { case <-awake: t.Fatal("too many goroutines awake") default: } n-- } c.Signal() } func TestCondSignalGenerations(t *testing.T) { var m Mutex c := NewCond(&m) n := 100
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 22 18:52:42 UTC 2023 - 5K bytes - Viewed (0)