Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for deletePodReference (0.29 sec)

  1. pkg/kubelet/cm/dra/claiminfo.go

    func (info *ClaimInfo) hasPodReference(podUID types.UID) bool {
    	return info.PodUIDs.Has(string(podUID))
    }
    
    // deletePodReference deletes a pod reference from the claim info.
    func (info *ClaimInfo) deletePodReference(podUID types.UID) {
    	info.PodUIDs.Delete(string(podUID))
    }
    
    // setPrepared marks the claim info as prepared.
    func (info *ClaimInfo) setPrepared() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:30:31 UTC 2024
    - 7.9K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/dra/claiminfo_test.go

    				},
    			},
    		},
    		{
    			description: "empty claim info",
    			claimInfo:   &ClaimInfo{},
    		},
    	} {
    		t.Run(test.description, func(t *testing.T) {
    			test.claimInfo.deletePodReference(podUID)
    			assert.False(t, test.claimInfo.hasPodReference(podUID))
    		})
    	}
    }
    
    func TestClaimInfoSetPrepared(t *testing.T) {
    	for _, test := range []struct {
    		description string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:30:31 UTC 2024
    - 21K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/dra/manager.go

    				// if the checkpoint has succeeded. That means if the kubelet
    				// is ever restarted before this checkpoint succeeds, we will
    				// simply call into this (idempotent) function again.
    				claimInfo.deletePodReference(podUID)
    				return nil
    			}
    
    			// This claimInfo name will be used to update ClaimInfo cache
    			// after NodeUnprepareResources GRPC succeeds
    			claimNamesMap[claimInfo.ClaimUID] = claimInfo.ClaimName
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 03 13:23:29 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top