- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 145 for timediv (0.14 sec)
-
pkg/kube/multicluster/cluster.go
Client kube.Client kubeConfigSha [sha256.Size]byte stop chan struct{} // initialSync is marked when RunAndWait completes initialSync *atomic.Bool // initialSyncTimeout is set when RunAndWait timed out initialSyncTimeout *atomic.Bool } type ACTION int const ( Add ACTION = iota Update ) func (a ACTION) String() string { switch a { case Add: return "Add" case Update:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 02:13:10 UTC 2024 - 3.8K bytes - Viewed (0) -
src/runtime/netpoll_epoll.go
if errno != 0 { if errno != _EINTR { println("runtime: epollwait on fd", epfd, "failed with", errno) throw("runtime: netpoll failed") } // If a timed sleep was interrupted, just return to // recalculate how long we should sleep now. if waitms > 0 { return gList{}, 0 } goto retry } var toRun gList delta := int32(0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 4.6K bytes - Viewed (0) -
src/net/http/responsecontroller_test.go
if err == nil { t.Errorf("client reading from truncated request body: got nil error, want non-nil") } err = <-errc // io.Copy error if !errors.Is(err, os.ErrDeadlineExceeded) { t.Errorf("server timed out writing request body: got err %v; want os.ErrDeadlineExceeded", err) } } func TestResponseControllerSetPastReadDeadline(t *testing.T) { run(t, testResponseControllerSetPastReadDeadline) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 06 19:20:31 UTC 2024 - 10.2K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/AbstractDaemonLifecycleSpec.groovy
System.exit(1) } if (System.currentTimeMillis() > sanityCheck) { println "timed out waiting for stop file, failing" throw new RuntimeException("It seems the stop file was never created") } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 13:32:55 UTC 2024 - 7.1K bytes - Viewed (0) -
pkg/util/filesystem/util_windows.go
"filePath", filePath, "err", lastSocketErr, "socketDialRetryPeriod", socketDialRetryPeriod) return false, nil }) // PollImmediate will return "timed out waiting for the condition" if the function it // invokes never returns true if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 10 17:13:59 UTC 2024 - 4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/authorizer/webhook/metrics_test.go
expectedRegisteredStatusCode: "200", expectEvalutionResult: "success", expectDurationResult: "success", expectFailOpenResult: "", }, { name: "timed out request", clientCert: clientCert, clientKey: clientKey, clientCA: caCert, serverCert: serverCert, serverKey: serverKey, serverCA: caCert, authzFakeServiceStatusCode: http.StatusGatewayTimeout,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Mar 04 19:01:15 UTC 2024 - 6.6K bytes - Viewed (0) -
pkg/proxy/config/config_test.go
return } // Unittests will hard timeout in 5m with a stack trace, prevent that // and surface a clearer reason for failure. case <-time.After(wait.ForeverTestTimeout): t.Errorf("Timed out. Expected %#v, Got %#v", expectedServices, services) return } } } type sortedEndpointSlices []*discoveryv1.EndpointSlice func (s sortedEndpointSlices) Len() int { return len(s) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 22 05:08:41 UTC 2024 - 14.3K bytes - Viewed (0) -
src/internal/trace/batchcursor.go
// into e. It does not try to interpret the arguments // but it does validate that the event is a regular // event with a timestamp (vs. a structural event). // // It requires that the event its reading be timed, which must // be the case for every event in a plain EventBatch. func readTimedBaseEvent(b []byte, e *baseEvent) (int, timestamp, error) { // Get the event type. typ := event.Type(b[0]) specs := go122.Specs()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 4.1K bytes - Viewed (0) -
src/runtime/netpoll_kqueue.go
// see https://go.dev/issue/59679 for details. if n != -_EINTR && n != -_ETIMEDOUT { println("runtime: kevent on fd", kq, "failed with", -n) throw("runtime: netpoll failed") } // If a timed sleep was interrupted, just return to // recalculate how long we should sleep now. if delay > 0 { return gList{}, 0 } goto retry } var toRun gList delta := int32(0)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 12 21:17:22 UTC 2024 - 4.6K bytes - Viewed (0) -
src/runtime/netpoll_aix.go
n, e := poll(&pfds[0], uintptr(len(pfds)), timeout) if n < 0 { if e != _EINTR { println("errno=", e, " len(pfds)=", len(pfds)) throw("poll failed") } unlock(&mtxset) // If a timed sleep was interrupted, just return to // recalculate how long we should sleep now. if timeout > 0 { return gList{}, 0 } goto retry } // Check if some descriptors need to be changed
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 5.1K bytes - Viewed (0)