- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 261 for timeEnd (0.11 sec)
-
pkg/kubelet/pluginmanager/plugin_manager_test.go
return true, nil } t.Logf("expected %#v, got %#v, will retry", expected, fakePluginHandler.events) return false, nil }, ) if err != nil { t.Fatalf("Timed out waiting for plugin to be added to actual state of world cache.") } } func retryWithExponentialBackOff(initialDuration time.Duration, fn wait.ConditionFunc) error { backoff := wait.Backoff{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 4.4K bytes - Viewed (0) -
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) -
staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_discovery_controller.go
defer c.queue.ShutDown() defer klog.Info("Shutting down DiscoveryController") klog.Info("Starting DiscoveryController") if !cache.WaitForCacheSync(stopCh, c.crdsSynced) { utilruntime.HandleError(fmt.Errorf("timed out waiting for caches to sync")) return } // initially sync all group versions to make sure we serve complete discovery if err := wait.PollImmediateUntil(time.Second, func() (bool, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Apr 21 11:40:03 UTC 2024 - 12.8K bytes - Viewed (0) -
pkg/test/echo/server/forwarder/util.go
c++ tt += responseTimes[id] } } var avgTime time.Duration if c > 0 { avgTime = tt / time.Duration(c) } return nil, fmt.Errorf("request set timed out after %v and only %d/%d requests completed (%v avg)", cfg.timeout, c, cfg.count, avgTime) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Oct 08 09:39:20 UTC 2023 - 4.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go
} } if len(relevantHooks) == 0 { // no matching hooks return nil } // Check if the request has already timed out before spawning remote calls select { case <-ctx.Done(): // parent context is canceled or timed out, no point in continuing return apierrors.NewTimeoutError("request did not complete within requested timeout", 0) default: } wg := sync.WaitGroup{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 23 20:24:12 UTC 2023 - 13K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DefaultIncomingConnectionHandler.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 7K 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) -
pkg/controller/tainteviction/timed_workers.go
delay := fireAt.Sub(createdAt) logger := klog.FromContext(ctx) fWithErrorLogging := func() { err := f(ctx, fireAt, args) if err != nil { logger.Error(err, "TaintEvictionController: timed worker failed") } } if delay <= 0 { go fWithErrorLogging() return nil } timer := clock.AfterFunc(delay, fWithErrorLogging) return &TimedWorker{ WorkItem: args, CreatedAt: createdAt,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:23:56 UTC 2023 - 4.8K bytes - Viewed (0) -
src/runtime/os_darwin.go
// handler: the sigsend function. The signal handler code does not require // all the features of notes: it does not need to do a timed wait. // This is a separate implementation of notes, based on a pipe, that does // not support timed waits but is async-signal-safe. func sigNoteSetup(*note) { if sigNoteRead != 0 || sigNoteWrite != 0 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Dec 05 20:34:30 UTC 2023 - 11.9K bytes - Viewed (0)