- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 88 for Signalfd (0.2 sec)
-
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
waitForAPIServerStarted(t, doer) // act if isChanClosed(s.lifecycleSignals.MuxAndDiscoveryComplete.Signaled(), 1*time.Second) { t.Fatalf("%s is closed whereas the TestSignal is still open", s.lifecycleSignals.MuxAndDiscoveryComplete.Name()) } close(testSignal1) if isChanClosed(s.lifecycleSignals.MuxAndDiscoveryComplete.Signaled(), 1*time.Second) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
go func() { defer stopHTTPServer(errors.New("time to stop HTTP server")) timeToStopHttpServerCh := notAcceptingNewRequestCh.Signaled() if s.ShutdownSendRetryAfter { timeToStopHttpServerCh = drainedCh.Signaled() } <-timeToStopHttpServerCh }() // Start the audit backend before any request comes in. This means we must call Backend.Run
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 42.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/request/server_shutdown_signal.go
// ServerShutdownSignal is associated with the request context so // the request handler logic has access to signals rlated to // the server shutdown events type ServerShutdownSignal interface { // Signaled when the apiserver is not receiving any new request ShuttingDown() <-chan struct{} } // ServerShutdownSignalFrom returns the ServerShutdownSignal instance // associated with the request context.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:30 UTC 2023 - 1.9K bytes - Viewed (0) -
src/iter/iter.go
// or after calling stop. These calls will continue // to return the zero V and false. // // Stop ends the iteration. It must be called when the caller is // no longer interested in next values and next has not yet // signaled that the sequence is over (with a false boolean return). // It is valid to call stop multiple times and when next has // already returned false. // // It is an error to call next or stop from multiple goroutines
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 19:09:28 UTC 2024 - 6.6K bytes - Viewed (0) -
src/runtime/time_linux_amd64.s
MOVQ 0(SP), CX // monotonic sec IMULQ $1000000000, CX MOVQ 8(SP), DX // monotonic nsec MOVQ R12, SP // Restore real SP // Restore vdsoPC, vdsoSP // We don't worry about being signaled between the two stores. // If we are not in a signal handler, we'll restore vdsoSP to 0, // and no one will care about vdsoPC. If we are in a signal handler, // we cannot receive another signal. MOVQ 8(SP), SI
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Nov 06 10:24:44 UTC 2021 - 2K bytes - Viewed (0) -
src/runtime/signal_arm.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 2.5K bytes - Viewed (0) -
src/runtime/signal_loong64.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Mar 21 06:51:28 UTC 2023 - 3K bytes - Viewed (0) -
src/runtime/signal_riscv64.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Oct 04 02:55:17 UTC 2023 - 2.9K bytes - Viewed (0) -
src/runtime/signal_mipsx.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 3.1K bytes - Viewed (0) -
src/runtime/signal_mips64x.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 28 18:17:57 UTC 2021 - 3.2K bytes - Viewed (0)