- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 1,536 for pfds (0.04 sec)
-
src/runtime/netpoll_aix.go
pd.user = uint32(len(pfds)) pfds = append(pfds, pollfd{fd: int32(fd)}) pds = append(pds, pd) unlock(&mtxset) return 0 } func netpollclose(fd uintptr) int32 { lock(&mtxpoll) netpollwakeup() lock(&mtxset) unlock(&mtxpoll) for i := 0; i < len(pfds); i++ { if pfds[i].fd == int32(fd) { pfds[i] = pfds[len(pfds)-1] pfds = pfds[:len(pfds)-1]
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 5.1K bytes - Viewed (0) -
pkg/quota/v1/evaluator/core/pods.go
// where "pods" tracks all pods that have not reached a terminal state, // count/pods tracks all pods independent of state. result := corev1.ResourceList{ podObjectCountName: *(resource.NewQuantity(1, resource.DecimalSI)), } // by convention, we do not quota compute resources that have reached end-of life
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 05 00:02:47 UTC 2023 - 17.4K bytes - Viewed (0) -
src/internal/coverage/pods/pods.go
pod.Origins = append(pod.Origins, e.origin) pod.ProcessIDs = append(pod.ProcessIDs, e.pid) } pods = append(pods, pod) } slices.SortFunc(pods, func(a, b Pod) int { return strings.Compare(a.MetaFile, b.MetaFile) }) return pods } func warning(s string, a ...interface{}) { fmt.Fprintf(os.Stderr, "warning: ") fmt.Fprintf(os.Stderr, s, a...)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:00:11 UTC 2024 - 6.6K bytes - Viewed (0) -
cmd/kubeadm/test/resources/pods.go
} // CreateWithPodSuffix creates a fake static pod using the provided // client and suffix func (p *FakeStaticPod) CreateWithPodSuffix(client clientset.Interface, suffix string) error { _, err := client.CoreV1().Pods(metav1.NamespaceSystem).Create(context.TODO(), p.Pod(suffix), metav1.CreateOptions{}) return err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 17 14:40:46 UTC 2021 - 1.9K bytes - Viewed (0) -
pilot/pkg/xds/pcds.go
John Howard <******@****.***> 1705429542 -0800
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jan 16 18:25:42 UTC 2024 - 2K bytes - Viewed (0) -
pilot/cmd/pilot-agent/app/fds.go
John Howard <******@****.***> 1709763386 -0800
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Mar 06 22:16:26 UTC 2024 - 1.3K bytes - Viewed (0) -
cni/pkg/nodeagent/ztunnelserver_test.go
defer cancel() pods := &fakePodCache{} pod, f := podAndNetns() f.Close() pods.pods = map[string]WorkloadInfo{ string(pod.UID): {}, // simulate unknown netns } fixture := connectWithPods(ctx, pods) ztunClient := fixture.ztunClient // read initial pod add keep, fds := readRequest(t, ztunClient) assert.Equal(t, len(fds), 0)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 21:47:31 UTC 2024 - 8.6K bytes - Viewed (0) -
pkg/kubelet/cm/pod_container_manager_linux.go
func (m *podContainerManagerImpl) tryKillingCgroupProcesses(podCgroup CgroupName) error { pidsToKill := m.cgroupManager.Pids(podCgroup) // No pids charged to the terminated pod cgroup return if len(pidsToKill) == 0 { return nil } var errlist []error // os.Kill often errors out, // We try killing all the pids multiple times removed := map[int]bool{} for i := 0; i < 5; i++ { if i != 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 16:38:36 UTC 2023 - 12.5K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux.go
for _, pid := range allPids { if pid == 1 || isKernelPid(pid) { continue } pids = append(pids, pid) } // Check if we have moved all the non-kernel PIDs. if len(pids) == 0 { return nil } klog.V(3).InfoS("Moving non-kernel processes", "pids", pids) for _, pid := range pids { err := manager.Apply(pid) if err != nil { name := ""
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
pkg/kubelet/cm/node_container_manager_linux.go
nodeAllocatable = cm.getNodeAllocatableInternalAbsolute() } cgroupConfig := &CgroupConfig{ Name: cm.cgroupRoot, // The default limits for cpu shares can be very low which can lead to CPU starvation for pods. ResourceParameters: getCgroupConfig(nodeAllocatable), } if cm.cgroupManager.Exists(cgroupConfig.Name) { return nil } if err := cm.cgroupManager.Create(cgroupConfig); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 10.5K bytes - Viewed (0)