Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 49 for getPids (0.11 sec)

  1. pkg/util/procfs/procfs_linux.go

    	if len(name) == 0 {
    		return []int{}, fmt.Errorf("name should not be empty")
    	}
    	re, err := regexp.Compile("(^|/)" + name + "$")
    	if err != nil {
    		return []int{}, err
    	}
    	return getPids(re), nil
    }
    
    func getPids(re *regexp.Regexp) []int {
    	pids := []int{}
    
    	dirFD, err := os.Open("/proc")
    	if err != nil {
    		return nil
    	}
    	defer dirFD.Close()
    
    	for {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jan 16 09:22:35 UTC 2023
    - 4.1K bytes
    - Viewed (0)
  2. pkg/util/oom/oom_linux.go

    )
    
    func NewOOMAdjuster() *OOMAdjuster {
    	oomAdjuster := &OOMAdjuster{
    		pidLister:        getPids,
    		ApplyOOMScoreAdj: applyOOMScoreAdj,
    	}
    	oomAdjuster.ApplyOOMScoreAdjContainer = oomAdjuster.applyOOMScoreAdjContainer
    	return oomAdjuster
    }
    
    func getPids(cgroupName string) ([]int, error) {
    	return cmutil.GetPids(filepath.Join("/", cgroupName))
    }
    
    // Writes 'value' to /proc/<pid>/oom_score_adj. PID = 0 means self
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 20 07:13:28 UTC 2022
    - 4K bytes
    - Viewed (0)
  3. pkg/util/procfs/procfs_linux_test.go

    	}
    
    	re, err := regexp.Compile("(^|/)" + filepath.Base(os.Args[0]) + "$")
    	assert.Empty(b, err)
    
    	for i := 0; i < b.N; i++ {
    		pids := getPids(re)
    
    		b.StopTimer()
    		assert.NotZero(b, pids)
    		assert.Contains(b, pids, os.Getpid())
    		b.StartTimer()
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 20 07:13:28 UTC 2022
    - 3.1K bytes
    - Viewed (0)
  4. fess-crawler-es/src/test/java/org/codelibs/fess/crawler/service/impl/EsUrlQueueServiceTest.java

                    .execute().actionGet().getHits().getTotalHits().value > 0);
    
            urlQueueService.delete("sessionId");
            assertFalse(fesenClient.prepareSearch("fess_crawler.queue").setQuery(QueryBuilders.termQuery("sessionId", "sessionId")).setSize(0)
                    .execute().actionGet().getHits().getTotalHits().value > 0);
    
        }
    
        public void test_insert_update_delete_multiTx() {
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 5.1K bytes
    - Viewed (0)
  5. platforms/native/platform-native/src/test/groovy/org/gradle/nativeplatform/internal/NativeBinarySpecTest.groovy

                getLibs() >> [lib]
            }
            binary.inputs.add sourceSet
    
            1 * resolver.resolve({ NativeBinaryResolveResult result ->
                result.allResolutions*.input == [lib]
            }) >> { NativeBinaryResolveResult result ->
                result.allResolutions[0].nativeDependencySet = dependency
            }
    
            then:
            binary.getLibs(sourceSet) == [dependency]
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Nov 16 20:20:03 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  6. fess-crawler-es/src/main/java/org/codelibs/fess/crawler/service/impl/EsDataService.java

            String scrollId = response.getScrollId();
            try {
                while (scrollId != null) {
                    final SearchHits searchHits = response.getHits();
                    if (searchHits.getHits().length == 0) {
                        break;
                    }
    
                    for (final SearchHit searchHit : searchHits) {
    Registered: Wed Jun 12 15:17:51 UTC 2024
    - Last Modified: Thu Feb 22 01:36:27 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  7. testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/ScopeIdsFixture.groovy

            idsOfBuildTrees.size()
        }
    
        List<ScopeIds> getIds() {
            idsOfBuildTrees.collect { it.get(":") }
        }
    
        Map<String, ScopeIds> idsOfBuildTree(int buildNum) {
            idsOfBuildTrees.get(buildNum)
        }
    
        ScopeIds ids(int buildNum) {
            assert idsOfBuildTrees.size() > buildNum
            getIds()[buildNum]
        }
    
        UniqueId getBuildInvocationId() {
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu Apr 04 07:21:38 UTC 2024
    - 6.2K bytes
    - Viewed (0)
  8. pkg/kubelet/container/testing/mock_runtime_cache.go

    }
    
    // GetPods mocks base method.
    func (m *MockRuntimeCache) GetPods(arg0 context.Context) ([]*container.Pod, error) {
    	m.ctrl.T.Helper()
    	ret := m.ctrl.Call(m, "GetPods", arg0)
    	ret0, _ := ret[0].([]*container.Pod)
    	ret1, _ := ret[1].(error)
    	return ret0, ret1
    }
    
    // GetPods indicates an expected call of GetPods.
    func (mr *MockRuntimeCacheMockRecorder) GetPods(arg0 any) *gomock.Call {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 4K bytes
    - Viewed (0)
  9. src/internal/cpu/cpu_arm64_hwcap.go

    	// check the AUXV for the CPUID bit. The getMIDR function executes an
    	// instruction which would normally be an illegal instruction, but it's
    	// trapped by the kernel, the value sanitized and then returned.
    	// Without the CPUID bit the kernel will not trap the instruction and the
    	// process will be terminated with SIGILL.
    	if ARM64.HasCPUID {
    		midr := getMIDR()
    		part_num := uint16((midr >> 4) & 0xfff)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 22 21:17:41 UTC 2024
    - 2.4K bytes
    - Viewed (0)
  10. pkg/kubelet/cm/topologymanager/numa_info.go

    	// This should never happen, but just in case make sure we do not divide by zero.
    	if bm.Count() == 0 {
    		return 0
    	}
    
    	var count float64 = 0
    	var sum float64 = 0
    	for _, node1 := range bm.GetBits() {
    		for _, node2 := range bm.GetBits() {
    			sum += float64(d[node1][node2])
    			count++
    		}
    	}
    
    	return sum / count
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 09 16:52:14 UTC 2022
    - 2.7K bytes
    - Viewed (0)
Back to top