- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 1,105 for psignal (0.43 sec)
-
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) -
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) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_context.go
} // initializationSignalFrom returns an initialization signal function // which when called signals that watch initialization has already finished // to priority and fairness dispatcher. func initializationSignalFrom(ctx context.Context) (InitializationSignal, bool) { signal, ok := ctx.Value(priorityAndFairnessInitializationSignalKey).(InitializationSignal) return signal, ok && signal != nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 14 14:39:15 UTC 2021 - 2.9K 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/cmd/cgo/internal/testcshared/testdata/libgo5/libgo5.go
package main import "C" import ( "os" "os/signal" "syscall" "time" ) // The channel used to read SIGIO signals. var sigioChan chan os.Signal // CatchSIGIO starts catching SIGIO signals. // //export CatchSIGIO func CatchSIGIO() { sigioChan = make(chan os.Signal, 1) signal.Notify(sigioChan, syscall.SIGIO) } // ResetSIGIO stops catching SIGIO signals. // //export ResetSIGIO func ResetSIGIO() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 14 13:19:50 UTC 2023 - 986 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/cgo/internal/testcarchive/testdata/libgo3/libgo3.go
package main import "C" import ( "os" "os/signal" "syscall" "time" ) // The channel used to read SIGIO signals. var sigioChan chan os.Signal // CatchSIGIO starts catching SIGIO signals. // //export CatchSIGIO func CatchSIGIO() { sigioChan = make(chan os.Signal, 1) signal.Notify(sigioChan, syscall.SIGIO) } // ResetSIGIO stops catching SIGIO signals. // //export ResetSIGIO func ResetSIGIO() {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 1020 bytes - Viewed (0) -
src/runtime/os_openbsd.go
func mpreinit(mp *m) { gsignalSize := int32(32 * 1024) if GOARCH == "mips64" { gsignalSize = int32(64 * 1024) } mp.gsignal = malg(gsignalSize) mp.gsignal.m = mp } // Called to initialize a new m (including the bootstrap m). // Called on the new thread, can not allocate memory. func minit() { getg().m.procid = uint64(getthrid())
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 6.2K bytes - Viewed (0) -
src/runtime/os_dragonfly.go
physPageSize = val } } return i / 2 } // raise sends a signal to the calling thread. // // It must be nosplit because it is used by the signal handler before // it definitely has a Go stack. // //go:nosplit func raise(sig uint32) { lwp_kill(-1, lwp_gettid(), int(sig)) } func signalM(mp *m, sig int) { lwp_kill(-1, int32(mp.procid), sig) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 20:34:30 UTC 2023 - 7.1K bytes - Viewed (0)