- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 1,735 for itemout (1.08 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/wait/poll.go
} // PollUntilContextTimeout will terminate polling after timeout duration by setting a context // timeout. This is provided as a convenience function for callers not currently executing under // a deadline and is equivalent to: // // deadlineCtx, deadlineCancel := context.WithTimeout(ctx, timeout) // err := PollUntilContextCancel(deadlineCtx, interval, immediate, condition) //
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 26 06:13:35 UTC 2023 - 14K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/httpstream/wsstream/stream.go
// Client should not send anything. IgnoreReceives(ws, r.timeout) // Once the client closes, we should also close closeConn() }() r.err <- messageCopy(ws, r.r, !r.protocols[r.selectedProtocol].Binary, r.ping, r.timeout) } func resetTimeout(ws *websocket.Conn, timeout time.Duration) { if timeout > 0 { ws.SetDeadline(time.Now().Add(timeout)) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 07 18:21:43 UTC 2023 - 5.2K bytes - Viewed (0) -
src/crypto/cipher/fuzz_test.go
cbcAsm = cipher.NewCBCDecrypter(c, commonIV) cbcGeneric = cipher.NewCBCGenericDecrypter(c, commonIV) if testing.Short() { timeout = time.NewTimer(10 * time.Millisecond) } else { timeout = time.NewTimer(2 * time.Second) } fuzzdecrypt: for { select { case <-timeout.C: break fuzzdecrypt default: } rand.Read(indata[:]) cbcGeneric.CryptBlocks(indata, outgeneric)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 03 13:39:12 UTC 2022 - 2K bytes - Viewed (0) -
src/os/error.go
} func (e *SyscallError) Error() string { return e.Syscall + ": " + e.Err.Error() } func (e *SyscallError) Unwrap() error { return e.Err } // Timeout reports whether this error represents a timeout. func (e *SyscallError) Timeout() bool { t, ok := e.Err.(timeout) return ok && t.Timeout() } // NewSyscallError returns, as an error, a new [SyscallError] // with the given system call name and error details.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 21:33:12 UTC 2024 - 4.8K bytes - Viewed (0) -
pilot/pkg/leaderelection/k8sleaderelection/healthzadaptor.go
// checks within the timeout period after the lease expires will still return healthy. func NewLeaderHealthzAdaptor(timeout time.Duration) *HealthzAdaptor { result := &HealthzAdaptor{ timeout: timeout, } return result
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Oct 11 16:58:48 UTC 2021 - 2.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/handlers/finisher/finisher_test.go
} testcases := []struct { name string timeout func() (context.Context, context.CancelFunc) fn ResultFunc expectedObj runtime.Object expectedErr error expectedPanic string expectedPanicObj interface{} }{ { name: "Expected obj is returned", timeout: timeoutFunc, fn: func() (runtime.Object, error) { return exampleObj, nil },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 07 14:20:33 UTC 2021 - 8.2K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/examples/client-go/pkg/client/clientset/versioned/typed/cr/v1/example.go
var timeout time.Duration if opts.TimeoutSeconds != nil { timeout = time.Duration(*opts.TimeoutSeconds) * time.Second } result = &v1.ExampleList{} err = c.client.Get(). Namespace(c.ns). Resource("examples"). VersionedParams(&opts, scheme.ParameterCodec). Timeout(timeout). Do(ctx). Into(result) return }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 10:52:54 UTC 2024 - 8.6K bytes - Viewed (0) -
pkg/istio-agent/health/health_probers.go
return h } // HttpProber_Probe will return whether or not the target is healthy (true -> healthy) // by making an HTTP Get response. func (h *HTTPProber) Probe(timeout time.Duration) (ProbeResult, error) { client := &http.Client{ Timeout: timeout, Transport: h.Transport, } // transform crd into net http header headers := make(http.Header) for _, val := range h.Config.HttpHeaders {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 5.7K bytes - Viewed (0) -
pkg/controller/nodeipam/ipam/timeout_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jan 04 20:48:08 UTC 2018 - 1.4K bytes - Viewed (0) -
src/runtime/netpoll_aix.go
// //go:nowritebarrierrec func netpoll(delay int64) (gList, int32) { var timeout uintptr if delay < 0 { timeout = ^uintptr(0) } else if delay == 0 { // TODO: call poll with timeout == 0 return gList{}, 0 } else if delay < 1e6 { timeout = 1 } else if delay < 1e15 { timeout = uintptr(delay / 1e6) } else { // An arbitrary cap on how long to wait for a timer.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 5.1K bytes - Viewed (0)