Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for podstore (0.14 sec)

  1. pkg/controller/endpointslice/endpointslice_controller_test.go

    	ns := metav1.NamespaceDefault
    
    	pod1 := newPod(1, ns, true, 0, false)
    	esController.podStore.Add(pod1)
    
    	// ensure this pod will not match the selector
    	pod2 := newPod(2, ns, true, 0, false)
    	pod2.Labels["foo"] = "boo"
    	esController.podStore.Add(pod2)
    
    	standardSyncService(t, esController, ns, "testing-1")
    	expectActions(t, client.Actions(), 1, "create", "endpointslices")
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller.go

    	finalizerExpectations *uidTrackingExpectations
    
    	// A store of jobs
    	jobLister batchv1listers.JobLister
    
    	// A store of pods, populated by the podController
    	podStore corelisters.PodLister
    
    	// Jobs that need to be updated
    	queue workqueue.TypedRateLimitingInterface[string]
    
    	// Orphan deleted pods that still have a Job tracking finalizer to be removed
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  3. pkg/controller/job/job_controller_test.go

    	pod, err = clientset.CoreV1().Pods(pod.GetNamespace()).Create(ctx, pod, metav1.CreateOptions{})
    	if err != nil {
    		t.Fatalf("Creating pod: %v", err)
    	}
    
    	// Await for the Pod to appear in the podStore to ensure that the pod exists when cleaning up the Job.
    	// In a production environment, there wouldn't be these guarantees, but the Pod would be cleaned up
    	// by the orphan pod worker, when the Pod finishes.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  4. pkg/kubelet/config/config.go

    func (c *PodConfig) Sync() {
    	c.pods.sync()
    }
    
    // podStorage manages the current pod state at any point in time and ensures updates
    // to the channel are delivered in order.  Note that this object is an in-memory source of
    // "truth" and on creation contains zero entries.  Once all previously read sources are
    // available, then this object should be considered authoritative.
    type podStorage struct {
    	podLock sync.RWMutex
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/ssa/_gen/PPC64.rules

    // Common with math Float64bits, Float64frombits
    (MOVDload [off] {sym} ptr (FMOVDstore [off] {sym} ptr x _)) => (MFVSRD x)
    (FMOVDload [off] {sym} ptr (MOVDstore [off] {sym} ptr x _)) => (MTVSRD x)
    
    (FMOVDstore [off] {sym} ptr (MTVSRD x) mem) => (MOVDstore [off] {sym} ptr x mem)
    (MOVDstore [off] {sym} ptr (MFVSRD x) mem) => (FMOVDstore [off] {sym} ptr x mem)
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:02:52 UTC 2024
    - 53.2K bytes
    - Viewed (0)
  6. src/cmd/compile/internal/ssa/rewritePPC64.go

    	return false
    }
    func rewriteValuePPC64_OpSelectN(v *Value) bool {
    	v_0 := v.Args[0]
    	b := v.Block
    	config := b.Func.Config
    	// match: (SelectN [0] call:(CALLstatic {sym} s1:(MOVDstore _ (MOVDconst [sz]) s2:(MOVDstore _ src s3:(MOVDstore {t} _ dst mem)))))
    	// cond: sz >= 0 && isSameCall(sym, "runtime.memmove") && s1.Uses == 1 && s2.Uses == 1 && s3.Uses == 1 && isInlinableMemmove(dst, src, sz, config) && clobber(s1, s2, s3, call)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:02:52 UTC 2024
    - 360.2K bytes
    - Viewed (0)
  7. src/cmd/compile/internal/ssa/rewrite.go

    			}
    		}
    	}
    	if isSameCall(sym, "runtime.racefuncenter") {
    		// TODO REGISTER ABI this needs to be cleaned up.
    		// If we're removing racefuncenter, remove its argument as well.
    		if v.Args[0].Op != OpStore {
    			if v.Op == OpStaticLECall {
    				// there is no store, yet.
    				return true
    			}
    			return false
    		}
    		mem := v.Args[0].Args[2]
    		v.Args[0].reset(OpCopy)
    		v.Args[0].AddArg(mem)
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri Jun 07 19:02:52 UTC 2024
    - 64.2K bytes
    - Viewed (0)
  8. src/cmd/compile/internal/ssagen/ssa.go

    func (s *state) rawLoad(t *types.Type, src *ssa.Value) *ssa.Value {
    	return s.newValue2(ssa.OpLoad, t, src, s.mem())
    }
    
    func (s *state) store(t *types.Type, dst, val *ssa.Value) {
    	s.vars[memVar] = s.newValue3A(ssa.OpStore, types.TypeMem, t, dst, val, s.mem())
    }
    
    func (s *state) zero(t *types.Type, dst *ssa.Value) {
    	s.instrument(t, dst, instrumentWrite)
    	store := s.newValue2I(ssa.OpZero, types.TypeMem, t.Size(), dst, s.mem())
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 19:44:43 UTC 2024
    - 284.9K bytes
    - Viewed (0)
Back to top