- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 172 for addpad (0.18 sec)
-
guava-tests/test/com/google/common/util/concurrent/AtomicLongMapTest.java
String key = "key"; long addend = random.nextInt(MAX_ADDEND); for (int i = 0; i < ITERATIONS; i++) { long before = map.get(key); long result = map.addAndGet(key, addend); long after = map.get(key); assertEquals(before + addend, after); assertEquals(after, result); addend = after; } assertEquals(1, map.size());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 17.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/pod.go
pc.addPod(pod, ip, key) } else { return nil } case model.EventUpdate: if !shouldPodBeInEndpoints(pod) || !IsPodReady(pod) { // delete only if this pod was in the cache if !pc.deleteIP(ip, key) { return nil } ev = model.EventDelete } else if shouldPodBeInEndpoints(pod) && IsPodReady(pod) { pc.addPod(pod, ip, key) } else { return nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 10.8K bytes - Viewed (0) -
pkg/scheduler/internal/cache/cache.go
// The pod was added to a different node than it was assumed to. logger.Info("Pod was added to a different node than it was assumed", "podKey", key, "pod", klog.KObj(pod), "assumedNode", klog.KRef("", pod.Spec.NodeName), "currentNode", klog.KRef("", currState.pod.Spec.NodeName)) return nil } case !ok: // Pod was expired. We should add it back. if err = cache.addPod(logger, pod, false); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 09:56:48 UTC 2023 - 24.9K bytes - Viewed (0) -
src/cmd/link/internal/arm64/asm.go
rt := r.Type siz := r.Size xadd := r.Xadd if xadd != signext24(xadd) && rt != objabi.R_ADDR { // If the relocation target would overflow the addend, then target // a linker-manufactured label symbol with a smaller addend instead. // R_ADDR has full-width addend encoded in data content, so it doesn't // use a label symbol. label := ldr.Lookup(offsetLabelName(ldr, rs, xadd/machoRelocLimit*machoRelocLimit), ldr.SymVersion(rs))
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jan 30 20:09:45 UTC 2024 - 47K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AtomicLongMapTest.java
String key = "key"; long addend = random.nextInt(MAX_ADDEND); for (int i = 0; i < ITERATIONS; i++) { long before = map.get(key); long result = map.addAndGet(key, addend); long after = map.get(key); assertEquals(before + addend, after); assertEquals(after, result); addend = after; } assertEquals(1, map.size());
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Feb 13 14:28:25 UTC 2024 - 17.4K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/node_authorizer_test.go
p := &graphPopulator{} p.graph = graph for _, pod := range pods { p.addPod(pod) } for _, pv := range pvs { p.addPV(pv) } for _, attachment := range attachments { p.addVolumeAttachment(attachment) } for _, slice := range slices { p.addResourceSlice(slice) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 40.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/api/v1/compile_tf_graph.cc
applyTensorflowAndCLOptions(manager); manager.addPass(mlir::TF::CreatePrepareTpuComputationForTfExportPass()); manager.addPass(mlir::TF::CreateTFRegionControlFlowToFunctional()); manager.addPass(mlir::TF::CreateTFShapeInferencePass()); manager.addNestedPass<mlir::func::FuncOp>( mlir::CreateFunctionalToExecutorDialectConversionPass()); manager.addPass(mlir::CreateBreakUpIslandsPass());
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Jun 12 22:19:26 UTC 2024 - 14K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_extender.go
var potentialVictims []*v1.Pod removePod := func(rp *v1.Pod) error { return nodeInfoCopy.RemovePod(logger, rp) } addPod := func(ap *v1.Pod) { nodeInfoCopy.AddPod(ap) } // As the first step, remove all the lower priority pods from the node and // check if the given pod can be scheduled. podPriority := corev1helpers.PodPriority(pod)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.9K bytes - Viewed (0) -
pkg/kubelet/prober/scale_test.go
Running: &v1.ContainerStateRunning{ StartedAt: metav1.Now(), }, }, Started: utilpointer.Bool(true), }) } podManager.AddPod(&pod) m.statusManager.SetPodStatus(&pod, pod.Status) m.AddPod(&pod) } t.Logf("Adding %d pods with %d containers each in %v", numTestPods, numContainers, time.Since(now))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 16 16:33:01 UTC 2023 - 8.2K bytes - Viewed (0) -
src/cmd/link/internal/mips64/asm.go
// mips64 ELF relocation (endian neutral) // offset uint64 // sym uint32 // ssym uint8 // type3 uint8 // type2 uint8 // type uint8 // addend int64 addend := r.Xadd out.Write64(uint64(sectoff)) elfsym := ld.ElfSymForReloc(ctxt, r.Xsym) out.Write32(uint32(elfsym)) out.Write8(0) out.Write8(0) out.Write8(0) switch r.Type {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Aug 23 05:58:20 UTC 2023 - 11K bytes - Viewed (0)