- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 123 for popList (0.28 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)