- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 78 for updateDir (0.24 sec)
-
guava/src/com/google/common/util/concurrent/AtomicDouble.java
long next = doubleToRawLongBits(newValue); updater.lazySet(this, next); } /** * Atomically sets to the given value and returns the old value. * * @param newValue the new value * @return the previous value */ public final double getAndSet(double newValue) { long next = doubleToRawLongBits(newValue); return longBitsToDouble(updater.getAndSet(this, next)); } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Apr 04 09:45:04 UTC 2023 - 9.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/internal/structuredmerge.go
typeConverter TypeConverter objectConverter runtime.ObjectConvertor objectDefaulter runtime.ObjectDefaulter groupVersion schema.GroupVersion hubVersion schema.GroupVersion updater merge.Updater } var _ Manager = &structuredMergeManager{} // NewStructuredMergeManager creates a new Manager that merges apply requests // and update managed fields for other types of requests.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 22:55:50 UTC 2023 - 7.3K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_utils.go
fmt.Sprintf("sequence No: %v->%v", rs.Status.ObservedGeneration, newStatus.ObservedGeneration)) rs.Status = newStatus updatedRS, updateErr = c.UpdateStatus(context.TODO(), rs, metav1.UpdateOptions{}) if updateErr == nil { return updatedRS, nil } // Stop retrying if we exceed statusUpdateRetries - the replicaSet will be requeued with a rate limit. if i >= statusUpdateRetries { break
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 07 12:19:51 UTC 2023 - 7.1K bytes - Viewed (0) -
pkg/volume/util/resize_util.go
} updatedClaim, updateErr := kubeClient.CoreV1().PersistentVolumeClaims(pvc.Namespace). Patch(context.TODO(), pvc.Name, types.StrategicMergePatchType, patchBytes, metav1.PatchOptions{}, "status") if updateErr != nil { return pvc, fmt.Errorf("patchPVCStatus failed to patch PVC %q: %v", pvc.Name, updateErr) } return updatedClaim, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:30:35 UTC 2023 - 14.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/fake.go
t.Cleanup(func() { close(stop) }) } for _, crd := range opts.CRDs { clienttest.MakeCRD(t, c.client, crd) } opts.Client.RunAndWait(c.stop) var fx *xdsfake.Updater if x, ok := xdsUpdater.(*xdsfake.Updater); ok { fx = x } if !opts.SkipRun { go c.Run(c.stop) kubelib.WaitForCacheSync("test", c.stop, c.HasSynced) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 4K bytes - Viewed (0) -
pkg/registry/registrytest/service.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 13:43:36 UTC 2023 - 2.9K bytes - Viewed (0) -
pkg/kubelet/util/cache/object_cache_test.go
deleteChan := make(chan string, 1) return &ObjectCache{ updater: f, cache: expirationcache.NewFakeExpirationStore(stringKeyFunc, deleteChan, ttlPolicy, clock), } } func TestAddAndGet(t *testing.T) { testObj := testObject{ key: "foo", val: "bar", } objectCache := NewFakeObjectCache(func() (interface{}, error) { return nil, fmt.Errorf("Unexpected Error: updater should never be called in this test")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 17 13:19:08 UTC 2021 - 2.6K bytes - Viewed (0) -
pkg/registry/core/service/ipallocator/controller/repair_test.go
err error updateCalled bool updated *api.RangeAllocation updateErr error } func (r *mockRangeRegistry) Get() (*api.RangeAllocation, error) { r.getCalled = true return r.item, r.err } func (r *mockRangeRegistry) CreateOrUpdate(alloc *api.RangeAllocation) error { r.updateCalled = true r.updated = alloc return r.updateErr } func TestRepair(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 21.1K bytes - Viewed (0) -
pkg/registry/core/service/portallocator/controller/repair_test.go
err error updateCalled bool updated *api.RangeAllocation updateErr error } func (r *mockRangeRegistry) Get() (*api.RangeAllocation, error) { r.getCalled = true return r.item, r.err } func (r *mockRangeRegistry) CreateOrUpdate(alloc *api.RangeAllocation) error { r.updateCalled = true r.updated = alloc return r.updateErr } func TestRepair(t *testing.T) { clearMetrics()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Sep 30 15:46:06 UTC 2023 - 10.6K bytes - Viewed (0) -
maven-embedder/src/main/java/org/apache/maven/cli/transfer/SimplexTransferListener.java
} this.batchMaxSize = batchMaxSize; this.blockOnLastEvent = blockOnLastEvent; this.eventQueue = new ArrayBlockingQueue<>(queueSize); Thread updater = new Thread(this::feedConsumer); updater.setDaemon(true); updater.start(); } public TransferListener getDelegate() { return delegate; } private void feedConsumer() {
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Tue Jun 11 20:50:56 UTC 2024 - 8.4K bytes - Viewed (0)