- Sort Score
- Result 10 results
- Languages All
Results 91 - 100 of 1,673 for waits (0.07 sec)
-
cni/pkg/install/cniconfig.go
} installLog.Infof("Created CNI config %s", cniConfigFilepath) installLog.Debugf("CNI config: %s", pluginConfig) return cniConfigFilepath, nil } // If configured as chained CNI plugin, waits indefinitely for a main CNI config file to exist before returning // Or until cancelled by parent context func getCNIConfigFilepath(ctx context.Context, cniConfName, mountedCNINetDir string, chained bool) (string, error) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 21 18:32:01 UTC 2024 - 8.3K bytes - Viewed (0) -
pilot/cmd/pilot-agent/options/options.go
minimumDrainDurationEnv = env.Register("MINIMUM_DRAIN_DURATION", 5*time.Second, "The minimum duration for which agent waits before it checks for active connections and terminates proxy "+ "when number of active connections become zero").Get() exitOnZeroActiveConnectionsEnv = env.Register("EXIT_ON_ZERO_ACTIVE_CONNECTIONS", false,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 09 19:21:50 UTC 2024 - 8.1K bytes - Viewed (0) -
pkg/proxy/servicechangetracker.go
// last Update. UpdatedServices sets.Set[types.NamespacedName] // DeletedUDPClusterIPs holds stale (no longer assigned to a Service) Service IPs // that had UDP ports. Callers can use this to abort timeout-waits or clear // connection-tracking information. DeletedUDPClusterIPs sets.Set[string] } // HealthCheckNodePorts returns a map of Service names to HealthCheckNodePort values
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Dec 21 14:44:08 UTC 2023 - 8.7K bytes - Viewed (0) -
src/runtime/proc_test.go
defer debug.SetGCPercent(debug.SetGCPercent(-1)) // SetGCPercent waits until the mark phase is over, but the runtime // also preempts at the start of the sweep phase, so make sure that's // done too. See #45867. runtime.GC() for try := 0; try < N; try++ { if load { // Create P goroutines and wait until they all run. // When we run the actual test below, worker threads
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 25.8K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler.go
Run(ctx context.Context) } // NewReconciler returns a new instance of Reconciler that waits loopPeriod // between successive executions. // loopPeriod is the amount of time the reconciler loop waits between // successive executions. // maxWaitForUnmountDuration is the max amount of time the reconciler will wait // for the volume to be safely unmounted, after this it will detach the volume
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 22 21:02:38 UTC 2024 - 21.1K bytes - Viewed (0) -
pilot/pkg/model/test/mockopenidserver.go
}, } wait := 10 * time.Millisecond for try := 0; try < 10; try++ { // Try to call the server res, err := httpClient.Get(fmt.Sprintf("%s/.well-known/openid-configuration", ms.URL)) if err != nil { log.Infof("Server not yet serving: %v", err) // Retry after some sleep. wait *= 2 time.Sleep(wait) continue } res.Body.Close()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 23 09:47:21 UTC 2024 - 9.4K bytes - Viewed (0) -
src/cmd/go/internal/script/state.go
return s, nil } // CloseAndWait cancels the State's Context and waits for any background commands to // finish. If any remaining background command ended in an unexpected state, // Close returns a non-nil error. func (s *State) CloseAndWait(log io.Writer) error { s.cancel() wait, err := Wait().Run(s) if wait != nil { panic("script: internal error: Wait unexpectedly returns its own WaitFunc") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 31 20:33:02 UTC 2023 - 6.9K bytes - Viewed (0) -
src/runtime/sigqueue.go
} } } // Incorporate updates from sender into local copy. for i := range sig.mask { sig.recv[i] = atomic.Xchg(&sig.mask[i], 0) } } } // 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.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness_test.go
} postEnqueue.Done() postEnqueue.Wait() } postDequeueFunc := func() { preDequeue.Done() preDequeue.Wait() if atomicReadOnlyWaiting != 0 { t.Errorf("Wanted %d requests in queue, got %d", 0, atomicReadOnlyWaiting) } postDequeue.Done() postDequeue.Wait() } postExecuteFunc := func() { finishExecute.Done() finishExecute.Wait() }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:18:40 UTC 2023 - 52.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
/** * Asserts that a prior call that had caused this thread to block or wait has since returned * normally. */ public void assertPriorCallReturns(@Nullable String methodName) throws Exception { assertEquals(null, getResponse(methodName).getResult()); } /** * Asserts that a prior call that had caused this thread to block or wait has since returned the * expected boolean value. */
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0)