- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 49 for curg (0.34 sec)
-
src/archive/tar/writer.go
/* // Write the sparse map and setup the sparse writer if necessary. if len(spd) > 0 { // Use tw.curr since the sparse map is accounted for in hdr.Size. if _, err := tw.curr.Write(spb); err != nil { return err } tw.curr = &sparseFileWriter{tw.curr, spd, 0} } */ return nil } func (tw *Writer) writeGNUHeader(hdr *Header) error {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 19.6K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/controller.go
func (s *Controller) serviceEntryHandler(old, curr config.Config, event model.Event) { log.Debugf("Handle event %s for service entry %s/%s", event, curr.Namespace, curr.Name) currentServiceEntry := curr.Spec.(*networking.ServiceEntry) cs := convertServices(curr) configsUpdated := sets.New[model.ConfigKey]() key := curr.NamespacedName() s.mutex.Lock()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 15:31:09 UTC 2024 - 36.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/controller.go
) { wrappedHandler := func(prev, curr T, event model.Event) error { curr = informer.Get(curr.GetName(), curr.GetNamespace()) if controllers.IsNil(curr) { // this can happen when an immediate delete after update // the delete event can be handled later return nil } return handler(prev, curr, event) } // Pre-build our metric types to avoid recompute them on each event
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 41.2K bytes - Viewed (0) -
pilot/test/xds/fake.go
// Setup config handlers // TODO code re-use from server.go configHandler := func(_, curr config.Config, event model.Event) { pushReq := &model.PushRequest{ Full: true, ConfigsUpdated: sets.New(model.ConfigKey{Kind: kind.MustFromGVK(curr.GroupVersionKind), Name: curr.Name, Namespace: curr.Namespace}), Reason: model.NewReasonStats(model.ConfigUpdate), } s.ConfigUpdate(pushReq) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 10 16:08:52 UTC 2024 - 18.4K bytes - Viewed (0) -
cluster/gce/gci/configure.sh
# shellcheck disable=SC2086 retry-forever 10 curl ${CURL_FLAGS} \ -H "X-Google-Metadata-Request: True" \ -o "${tmp_kubelet_config}" \ http://metadata.google.internal/computeMetadata/v1/instance/attributes/kubelet-config # only write to the final location if curl succeeds mv "${tmp_kubelet_config}" "${dest}" ) } function download-kube-master-certs {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 04:14:02 UTC 2024 - 36.5K bytes - Viewed (0) -
pkg/controller/daemon/update.go
// Create a new history if the current one isn't found cur, err = dsc.snapshot(ctx, ds, currRevision) if err != nil { return nil, nil, err } default: cur, err = dsc.dedupCurHistories(ctx, ds, currentHistories) if err != nil { return nil, nil, err } // Update revision number if necessary if cur.Revision < currRevision { toUpdate := cur.DeepCopy() toUpdate.Revision = currRevision
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 13 16:53:53 UTC 2024 - 24.4K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
SettableFuture<String> orig = SettableFuture.create(); SettableFuture<String> prev = orig; for (int i = 0; i < 100000; i++) { SettableFuture<String> curr = SettableFuture.create(); prev.setFuture(curr); prev = curr; } // prev represents the 'innermost' future prev.set("done"); assertTrue(orig.isDone()); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
SettableFuture<String> orig = SettableFuture.create(); SettableFuture<String> prev = orig; for (int i = 0; i < 100000; i++) { SettableFuture<String> curr = SettableFuture.create(); prev.setFuture(curr); prev = curr; } // prev represents the 'innermost' future prev.set("done"); assertTrue(orig.isDone()); }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
pilot/pkg/bootstrap/server.go
configHandler := func(prev config.Config, curr config.Config, event model.Event) { if s.statusReporter != nil { defer func() { if event != model.EventDelete { s.statusReporter.AddInProgressResource(curr) } else { s.statusReporter.DeleteInProgressResource(curr) } }() } log.Debugf("Handle event %s for configuration %s", event, curr.Key())
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 17:48:28 UTC 2024 - 46.3K bytes - Viewed (0) -
cluster/gce/upgrade.sh
local release_stable local release_latest local ci_latest release_stable=$(curl -sL https://dl.k8s.io/release/stable.txt) release_latest=$(curl -sL https://dl.k8s.io/release/latest.txt) ci_latest=$(curl -sL https://dl.k8s.io/ci/latest.txt) echo "Right now, versions are as follows:" echo " release/stable: ${0} ${release_stable}"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 21:13:22 UTC 2024 - 25.2K bytes - Viewed (0)