- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 137 for getPids (0.15 sec)
-
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) -
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) -
pkg/util/procfs/procfs_linux_test.go
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/kubelet/cm/container_manager_linux.go
cont.ensureStateFunc = func(_ cgroups.Manager) error { return ensureProcessInContainerWithOOMScore(os.Getpid(), int(cm.KubeletOOMScoreAdj), cont.manager) } systemContainers = append(systemContainers, cont) } else { cm.periodicTasks = append(cm.periodicTasks, func() { if err := ensureProcessInContainerWithOOMScore(os.Getpid(), int(cm.KubeletOOMScoreAdj), nil); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/index/SuggestIndexer.java
final SearchHit[] hits = response.getHits().getHits(); if (hits.length == 0) { break; } for (final SearchHit hit : hits) { final SuggestItem item = SuggestItem.parseSource(hit.getSourceAsMap()); item.setDocFreq(0); item.setKinds(Stream.of(item.getKinds()).filter(kind -> kind != SuggestItem.Kind.DOCUMENT)
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 26.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/util/SuggestUtil.java
while (scrollId != null) { final SearchHit[] hits = response.getHits().getHits(); if (hits.length == 0) { break; } final BulkRequestBuilder bulkRequestBuiler = client.prepareBulk(); Stream.of(hits).map(SearchHit::getId).forEach(id -> bulkRequestBuiler.add(new DeleteRequest(index, id)));
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Thu Feb 22 01:36:54 UTC 2024 - 11.7K bytes - Viewed (0) -
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) -
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) -
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) -
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)