- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for PIDs (0.57 sec)
-
pkg/util/procfs/procfs_linux_test.go
} func TestPidOf(t *testing.T) { if runtime.GOOS == "darwin" || runtime.GOOS == "windows" { t.Skipf("not supported on GOOS=%s", runtime.GOOS) } pids, err := PidOf(filepath.Base(os.Args[0])) assert.Empty(t, err) assert.NotZero(t, pids) assert.Contains(t, pids, os.Getpid()) } func TestPKill(t *testing.T) { if runtime.GOOS == "darwin" || runtime.GOOS == "windows" { t.Skipf("not supported on GOOS=%s", runtime.GOOS)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 20 07:13:28 UTC 2022 - 3.1K bytes - Viewed (0) -
pkg/util/procfs/procfs_linux.go
return fmt.Errorf("name should not be empty") } re, err := regexp.Compile(name) if err != nil { return err } pids := getPids(re) if len(pids) == 0 { return fmt.Errorf("unable to fetch pids for process name : %q", name) } errList := []error{} for _, pid := range pids { if err = syscall.Kill(pid, sig); err != nil { errList = append(errList, err) } } return utilerrors.NewAggregate(errList) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jan 16 09:22:35 UTC 2023 - 4.1K bytes - Viewed (0) -
src/cmd/go/testdata/script/test2json_interrupt.txt
go 1.20 -- example_test.go -- package example_test import ( "fmt" "os" "strconv" "testing" "strings" "time" ) func FuzzInterrupt(f *testing.F) { pids := os.Getenv("GO_TEST_INTERRUPT_PIDS") if pids == "" { // This is the main test process. // Set the environment variable for fuzz workers. pid := os.Getpid() ppid := os.Getppid()
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Dec 08 03:52:44 UTC 2022 - 1.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/ProcessFixture.groovy
return result == "" ? [] : result.split("\\n") } // Only supported on *nix platforms String[] getProcessInfo(String[] pids) { if (pids == null || pids.size() == 0) { throw new RuntimeException("Unable to get process info because provided pids are null or empty!") } if (!(OperatingSystem.current().unix)) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 5.6K bytes - Viewed (0) -
pkg/kubelet/stats/pidlimit/pidlimit.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 13 19:56:17 UTC 2019 - 713 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/types.go
// foo.slice/foo-bar.slice Name(name CgroupName) string // CgroupName converts the literal cgroupfs name on the host to an internal identifier. CgroupName(name string) CgroupName // Pids scans through all subsystems to find pids associated with specified cgroup. Pids(name CgroupName) []int // ReduceCPULimits reduces the CPU CFS values to the minimum amount of shares. ReduceCPULimits(cgroupName CgroupName) error
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Feb 24 18:21:21 UTC 2023 - 5.4K bytes - Viewed (0) -
build-logic/cleanup/src/main/kotlin/gradlebuild/cleanup/services/DaemonTracker.kt
} private fun cleanUpDaemons() { val alreadyKilled = mutableSetOf<String>() forEachJavaProcess { pid, _ -> suspiciousDaemons.forEach { (suite, pids) -> if (pid in pids && pid !in alreadyKilled) { logger.warn("A process was created in $suite but wasn't shutdown properly. Killing PID $pid") KillLeakingJavaProcesses.pkill(pid)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jan 08 12:45:57 UTC 2024 - 3.4K bytes - Viewed (0) -
operator/cmd/mesh/uninstall.go
rmListString) } if len(pids) != 0 && rev != "" { needConfirmation = true message += fmt.Sprintf("There are still %d proxies pointing to the control plane revision %s\n", len(pids), rev) // just print the count only if there is a large list of proxies if len(pids) <= 30 { message += fmt.Sprintf("%s\n", strings.Join(pids, "\n")) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Mar 15 01:18:49 UTC 2024 - 10.4K bytes - Viewed (0) -
pkg/kubelet/cm/cgroup_manager_linux.go
} return nil } // Scans through all subsystems to find pids associated with specified cgroup. func (m *cgroupManagerImpl) Pids(name CgroupName) []int { // we need the driver specific name cgroupFsName := m.Name(name) // Get a list of processes that we need to kill pidsToKill := sets.New[int]() var pids []int for _, val := range m.subsystems.MountPoints { dir := path.Join(val, cgroupFsName)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 26.5K bytes - Viewed (0)