- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for waitc (0.25 sec)
-
pkg/kubelet/kubelet.go
// fairness effect. go wait.JitterUntil(kl.syncNodeStatus, kl.nodeStatusUpdateFrequency, 0.04, true, wait.NeverStop) go kl.fastStatusUpdateOnce() // start syncing lease go kl.nodeLeaseController.Run(context.Background()) } go wait.Until(kl.updateRuntimeUp, 5*time.Second, wait.NeverStop) // Set up iptables util rules if kl.makeIPTablesUtilChains {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
cluster/gce/util.sh
# Report logging choice (if any). if [[ "${ENABLE_NODE_LOGGING-}" == "true" ]]; then echo "+++ Logging using Fluentd to ${LOGGING_DESTINATION:-unknown}" fi # Wait for last batch of jobs kube::util::wait-for-jobs || { code=$? echo -e "${color_red}Failed to create firewall rule.${color_norm}" >&2 exit $code } } function get-scope-flags() { local scope_flags=
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 21:47:17 UTC 2024 - 161.6K bytes - Viewed (0) -
cluster/gce/gci/configure-helper.sh
function start-fluentd-resource-update { wait-for-apiserver-and-update-fluentd & } # VolumeSnapshot CRDs and controller are installed by cluster addon manager, # which may not be available at this point. Run this as a background process. function wait-for-volumesnapshot-crd-and-controller { # Wait until volumesnapshot CRDs and controller are in place. echo "Wait until volume snapshot CRDs are installed"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 22:07:47 UTC 2024 - 141.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
} return nil } func retryWithExponentialBackOff(initialDuration time.Duration, fn wait.ConditionFunc) error { backoff := wait.Backoff{ Duration: initialDuration, Factor: 3, Jitter: 0, Steps: 6, } return wait.ExponentialBackoff(backoff, fn) } func simulateVolumeInUseUpdate( volumeName v1.UniqueVolumeName, stopCh <-chan struct{},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
src/cmd/link/internal/ld/data.go
writeBlock(ctxt, out, ldr, syms, addr, length, pad) } // Prepare for the next loop. if idx != -1 { syms = syms[idx+1:] } written += length addr += length } wg.Wait() } func writeBlock(ctxt *Link, out *OutBuf, ldr *loader.Loader, syms []loader.Sym, addr, size int64, pad []byte) { st := ctxt.makeRelocSymState()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 12 15:10:50 UTC 2024 - 100.5K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
if len(q.nominator.nominatedPods["node1"]) != 1 { t.Errorf("Expected medPriorityPodInfo to be present in nomindatePods: %v", q.nominator.nominatedPods["node1"]) } }() q.Add(logger, medPriorityPodInfo.Pod) wg.Wait() } func TestPriorityQueue_Update(t *testing.T) { c := testingclock.NewFakeClock(time.Now()) queuePlugin := "queuePlugin" skipPlugin := "skipPlugin" queueingHintMap := QueueingHintMapPerProfile{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder_test.go
model.TrafficDirectionOutbound, "v1", "foo.com", 8080, service, dr, ) eps := eb.FromServiceEndpoints() mu.Lock() actual = eps mu.Unlock() wg.Done() }() } wg.Wait() sortEndpoints(actual) if v := cmp.Diff(expected, actual, protocmp.Transform()); v != "" { t.Fatalf("Expected (-) != actual (+):\n%s", v) } } func TestBuildPassthroughClusters(t *testing.T) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 110.4K bytes - Viewed (0) -
src/cmd/go/internal/work/exec.go
b.exec.Lock() a := b.ready.pop() b.exec.Unlock() handle(ctx, a) case <-base.Interrupted: base.SetExitStatus(1) return } } }() } wg.Wait() // Write action graph again, this time with timing information. writeActionGraph() } // buildActionID computes the action ID for a build action. func (b *Builder) buildActionID(a *Action) cache.ActionID {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 10 14:46:37 UTC 2024 - 105.6K bytes - Viewed (0)