- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 348 for Signals (0.12 sec)
-
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) -
src/runtime/signal_unix.go
flags = sigtable[sig].flags } // If the signal is ignored, raising the signal is no-op. if handler == _SIG_IGN || (handler == _SIG_DFL && flags&_SigIgn != 0) { return } // Reset the signal handler and raise the signal. // We are currently running inside a signal handler, so the // signal is blocked. We need to unblock it before raising the // signal, or the signal we raise will be ignored until we return
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 10 16:04:54 UTC 2024 - 45K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
// an asynchronous process. signals.AfterShutdownDelayDuration = wrapLifecycleSignal(t, signals.AfterShutdownDelayDuration, before, nil) signals.PreShutdownHooksStopped = wrapLifecycleSignal(t, signals.PreShutdownHooksStopped, before, nil) signals.NotAcceptingNewRequest = wrapLifecycleSignal(t, signals.NotAcceptingNewRequest, before, nil) signals.HTTPServerStoppedListening = wrapLifecycleSignal(t, signals.HTTPServerStoppedListening, before, nil)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0) -
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) -
src/cmd/vendor/golang.org/x/sys/unix/mkerrors.sh
} printf("}\n\n"); printf("\n\n// Signal table\n"); printf("var signalList = [...]struct {\n"); printf("\tnum syscall.Signal\n"); printf("\tname string\n"); printf("\tdesc string\n"); printf("} {\n"); qsort(signals, nelem(signals), sizeof signals[0], tuplecmp); for(i=0; i<nelem(signals); i++) { e = signals[i].num; if(i > 0 && signals[i-1].num == e) continue;
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 20.2K 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) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_test.go
// setup cfg, assert := setUp(t) // scenario 1: single server with some signals root, err := cfg.Complete(nil).New("rootServer", NewEmptyDelegate()) assert.NoError(err) if len(root.MuxAndDiscoveryCompleteSignals()) != 0 { assert.Error(fmt.Errorf("unexpected signals %v registered in the root server", root.MuxAndDiscoveryCompleteSignals())) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 23.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/watch.go
} encoder = runtime.NewEncoderWithAllocator(encoderWithAllocator, memoryAllocator) } var serverShuttingDownCh <-chan struct{} if signals := apirequest.ServerShutdownSignalFrom(req.Context()); signals != nil { serverShuttingDownCh = signals.ShuttingDown() } server := &WatchServer{ Watching: watcher, Scope: scope, UseTextFraming: useTextFraming, MediaType: mediaType,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 14 16:37:25 UTC 2023 - 11.4K bytes - Viewed (0) -
src/net/http/roundtrip_js.go
opt.Set("mode", h) req.Header.Del(jsFetchMode) } if h := req.Header.Get(jsFetchRedirect); h != "" { opt.Set("redirect", h) req.Header.Del(jsFetchRedirect) } if !ac.IsUndefined() { opt.Set("signal", ac.Get("signal")) } headers := js.Global().Get("Headers").New() for key, values := range req.Header { for _, value := range values { headers.Call("append", key, value) } } opt.Set("headers", headers)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 10 03:29:50 UTC 2024 - 11.8K bytes - Viewed (0) -
src/runtime/crash_cgo_test.go
case "plan9", "windows": t.Skipf("no EINTR on %s", runtime.GOOS) case "linux": if runtime.GOARCH == "386" { // On linux-386 the Go signal handler sets // a restorer function that is not preserved // by the C sigaction call in the test, // causing the signal handler to crash when // returning the normal code. The test is not // architecture-specific, so just skip on 386
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 16:44:47 UTC 2024 - 22.2K bytes - Viewed (0)