Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 123 for popList (0.28 sec)

  1. src/runtime/mgcmark.go

    // at the end of a GC cycle. gcBlackenEnabled must be false to prevent
    // new assists from going to sleep after this point.
    func gcWakeAllAssists() {
    	lock(&work.assistQueue.lock)
    	list := work.assistQueue.q.popList()
    	injectglist(&list)
    	unlock(&work.assistQueue.lock)
    }
    
    // gcParkAssist puts the current goroutine on the assist queue and parks.
    //
    // gcParkAssist reports whether the assist is now satisfied. If it
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 21:25:11 UTC 2024
    - 52.5K bytes
    - Viewed (0)
  2. src/runtime/proc.go

    func (q *gQueue) pop() *g {
    	gp := q.head.ptr()
    	if gp != nil {
    		q.head = gp.schedlink
    		if q.head == 0 {
    			q.tail = 0
    		}
    	}
    	return gp
    }
    
    // popList takes all Gs in q and returns them as a gList.
    func (q *gQueue) popList() gList {
    	stack := gList{q.head}
    	*q = gQueue{}
    	return stack
    }
    
    // A gList is a list of Gs linked through g.schedlink. A G can only be
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 17:58:53 UTC 2024
    - 207.5K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/storage/cacher/lister_watcher_test.go

    		t.Fatalf("List failed: %v", err)
    	}
    	pl, ok := obj.(*example.PodList)
    	if !ok {
    		t.Fatalf("Expected PodList but got %v", pl)
    	}
    	if len(pl.Items) != 3 {
    		t.Errorf("Expected PodList of length 3 but got %d", len(pl.Items))
    	}
    }
    
    func TestCacherListerWatcherPagination(t *testing.T) {
    	prefix := "pods"
    	fn := func() runtime.Object { return &example.PodList{} }
    	server, store := newEtcdTestStorage(t, prefix)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Mar 04 11:51:06 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/apis/example/v1/zz_generated.deepcopy.go

    // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodList.
    func (in *PodList) DeepCopy() *PodList {
    	if in == nil {
    		return nil
    	}
    	out := new(PodList)
    	in.DeepCopyInto(out)
    	return out
    }
    
    // DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
    func (in *PodList) DeepCopyObject() runtime.Object {
    	if c := in.DeepCopy(); c != nil {
    		return c
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 4.4K bytes
    - Viewed (0)
  5. pkg/controller/controller_utils_test.go

    	rc := newReplicationController(0)
    	podList := newPodList(nil, 7, v1.PodRunning, rc)
    	podList.Items[0].Status.Phase = v1.PodSucceeded
    	podList.Items[1].Status.Phase = v1.PodFailed
    	podList.Items[2].Status.Phase = v1.PodPending
    	podList.Items[2].SetDeletionTimestamp(&now)
    	podList.Items[3].Status.Phase = v1.PodRunning
    	podList.Items[3].SetDeletionTimestamp(&now)
    	var podPointers []*v1.Pod
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 39.4K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apiserver/pkg/apis/example/v1/zz_generated.conversion.go

    	}); err != nil {
    		return err
    	}
    	if err := s.AddGeneratedConversionFunc((*PodList)(nil), (*example.PodList)(nil), func(a, b interface{}, scope conversion.Scope) error {
    		return Convert_v1_PodList_To_example_PodList(a.(*PodList), b.(*example.PodList), scope)
    	}); err != nil {
    		return err
    	}
    	if err := s.AddGeneratedConversionFunc((*example.PodList)(nil), (*PodList)(nil), func(a, b interface{}, scope conversion.Scope) error {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 10.6K bytes
    - Viewed (0)
  7. src/internal/coverage/pods/pods_test.go

    	mkmeta(o2, "m1")
    	mkcounter(o2, "m1", 11, 35)
    
    	// Collect pods.
    	podlist, err := pods.CollectPods([]string{o1, o2}, true)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	// Verify pods
    	if len(podlist) != 2 {
    		t.Fatalf("expected 2 pods got %d pods", len(podlist))
    	}
    
    	for k, p := range podlist {
    		t.Logf("%d: mf=%s\n", k, p.MetaFile)
    	}
    
    	expected := []string{
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 31 14:00:17 UTC 2023
    - 3.5K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apiserver/pkg/apis/example/zz_generated.deepcopy.go

    // DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new PodList.
    func (in *PodList) DeepCopy() *PodList {
    	if in == nil {
    		return nil
    	}
    	out := new(PodList)
    	in.DeepCopyInto(out)
    	return out
    }
    
    // DeepCopyObject is an autogenerated deepcopy function, copying the receiver, creating a new runtime.Object.
    func (in *PodList) DeepCopyObject() runtime.Object {
    	if c := in.DeepCopy(); c != nil {
    		return c
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Aug 24 19:47:49 UTC 2021
    - 6.1K bytes
    - Viewed (0)
  9. pkg/kubelet/config/http.go

    	}
    
    	// That didn't work, so try a list of pods.
    	parsed, podList, multiPodErr := tryDecodePodList(data, s.applyDefaults)
    	if parsed {
    		if multiPodErr != nil {
    			// It parsed but could not be used.
    			return multiPodErr
    		}
    		pods := make([]*v1.Pod, 0, len(podList.Items))
    		for i := range podList.Items {
    			pods = append(pods, &podList.Items[i])
    		}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 01 07:19:44 UTC 2021
    - 4.1K bytes
    - Viewed (0)
  10. pkg/apis/core/install/install_test.go

    	if err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	if version != "10" {
    		t.Errorf("unexpected version %v", version)
    	}
    
    	podList := internal.PodList{ListMeta: metav1.ListMeta{ResourceVersion: "10"}}
    	version, err = meta.NewAccessor().ResourceVersion(&podList)
    	if err != nil {
    		t.Fatalf("unexpected error: %v", err)
    	}
    	if version != "10" {
    		t.Errorf("unexpected version %v", version)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 27 06:11:15 UTC 2019
    - 2.1K bytes
    - Viewed (0)
Back to top