Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for deleteCount (0.42 sec)

  1. pkg/controller/podgc/gc_controller.go

    	terminatedPodCount := len(terminatedPods)
    	deleteCount := terminatedPodCount - gcc.terminatedPodThreshold
    
    	if deleteCount <= 0 {
    		return
    	}
    
    	logger := klog.FromContext(ctx)
    	logger.Info("Garbage collecting pods", "numPods", deleteCount)
    	// sort only when necessary
    	sort.Sort(byEvictionAndCreationTimestamp(terminatedPods))
    	var wait sync.WaitGroup
    	for i := 0; i < deleteCount; i++ {
    		wait.Add(1)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  2. pkg/registry/core/pod/storage/eviction_test.go

    					t.Errorf("error mismatch: expected %v, got %v; name %v", tc.expectError, gotErr, pod.Name)
    					return
    				}
    
    				if tc.expectedDeleteCount != ms.deleteCount {
    					t.Errorf("expected delete count=%v, got %v; name %v", tc.expectedDeleteCount, ms.deleteCount, pod.Name)
    				}
    			})
    		}
    	}
    }
    
    func TestEvictionDryRun(t *testing.T) {
    	testcases := []struct {
    		name            string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 09:26:37 UTC 2024
    - 40K bytes
    - Viewed (0)
  3. cmd/xl-storage.go

    		return 0
    	}
    
    	return binary.LittleEndian.Uint64(buf[:8])
    }
    
    func (s *xlStorage) setDeleteAttribute(deleteCount uint64) error {
    	attr := "user.total_deletes"
    
    	data := make([]byte, 8)
    	binary.LittleEndian.PutUint64(data, deleteCount)
    	return xattr.LSet(s.formatFile, attr, data)
    }
    
    func (s *xlStorage) setWriteAttribute(writeCount uint64) error {
    	attr := "user.total_writes"
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 85.3K bytes
    - Viewed (0)
  4. pkg/controller/daemon/daemon_controller.go

    			// retry the slow start process.
    			break
    		}
    	}
    
    	logger.V(4).Info("Pods to delete for daemon set, deleting", "daemonset", klog.KObj(ds), "toDeleteCount", podsToDelete, "deleteCount", deleteDiff)
    	deleteWait := sync.WaitGroup{}
    	deleteWait.Add(deleteDiff)
    	for i := 0; i < deleteDiff; i++ {
    		go func(ix int) {
    			defer deleteWait.Done()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
  5. pkg/kubelet/pod/testing/fake_mirror_client.go

    	// itself. This fake manager does this to track calls.
    	mirrorPods   sets.Set[string]
    	createCounts map[string]int
    	deleteCounts map[string]int
    }
    
    func NewFakeMirrorClient() *FakeMirrorClient {
    	m := FakeMirrorClient{}
    	m.mirrorPods = sets.New[string]()
    	m.createCounts = make(map[string]int)
    	m.deleteCounts = make(map[string]int)
    	return &m
    }
    
    func (fmc *FakeMirrorClient) CreateMirrorPod(pod *v1.Pod) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 2.4K bytes
    - Viewed (0)
Back to top