- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 69 for getPids (0.12 sec)
-
src/main/java/org/codelibs/fess/es/user/allcommon/EsAbstractBehavior.java
final SearchHit[] hits = searchHits.getHits(); if (hits.length == 0) { break; } final BulkRequestBuilder bulkRequest = client.prepareBulk(); for (final SearchHit hit : hits) { bulkRequest.add(client.prepareDelete().setIndex(asEsIndex()).setId(hit.getId())); } count += hits.length;
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 26.4K bytes - Viewed (0) -
platforms/ide/ide-plugins/src/main/java/org/gradle/plugins/ide/idea/IdeaPlugin.java
// Dependencies ideaModule.dependsOn((Callable<FileCollection>) () -> mainFeature.getSourceSet().getOutput().getDirs().plus(defaultTestSuite.getSources().getOutput().getDirs()) ); }); // Defaults setupScopes(mainFeature, defaultTestSuite); // Convention
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Dec 12 14:00:13 UTC 2023 - 25.2K bytes - Viewed (0) -
pkg/kubelet/pod/pod_manager.go
// the pod can be found, return it and true for wasMirror. GetPodAndMirrorPod(*v1.Pod) (pod, mirrorPod *v1.Pod, wasMirror bool) // GetPods returns the regular pods bound to the kubelet and their spec. GetPods() []*v1.Pod // GetPodsAndMirrorPods returns the set of pods, the set of mirror pods, and // the pod fullnames of any orphaned mirror pods.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:00 UTC 2024 - 11.9K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbRandomAccessFile.java
throw e; } } } else { SmbComReadAndX request = new SmbComReadAndX(th.getConfig(), fh.getFid(), this.fp, r, null); if ( this.largeReadX ) { request.setMaxCount(r & 0xFFFF); request.setOpenTimeout( ( r >> 16 ) & 0xFFFF); }
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Wed Jan 08 12:01:33 UTC 2020 - 18.5K bytes - Viewed (1) -
pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux.go
logger klog.Logger recorder record.EventRecorder nodeRef *v1.ObjectReference probeManager prober.Manager shutdownGracePeriodByPodPriority []kubeletconfig.ShutdownGracePeriodByPodPriority getPods eviction.ActivePodsFunc killPodFunc eviction.KillPodFunc syncNodeStatus func() dbusCon dbusInhibiter inhibitLock systemd.InhibitLock nodeShuttingDownMutex sync.Mutex
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Nov 09 08:02:40 UTC 2022 - 15.5K bytes - Viewed (0) -
platforms/ide/ide-native/src/main/java/org/gradle/ide/visualstudio/internal/NativeSpecVisualStudioTargetBinary.java
includes.addAll(((HeaderExportingSourceSet) sourceSet).getExportedHeaders().getSrcDirs()); } } for (NativeDependencySet lib : binary.getLibs()) { includes.addAll(lib.getIncludeRoots().getFiles()); } return includes; } @Override public boolean equals(Object o) { if (this == o) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 11.4K bytes - Viewed (0) -
pkg/controller/controller_utils.go
// ControllerExpectationsInterface. uidStore cache.Store } // GetUIDs is a convenience method to avoid exposing the set of expected uids. // The returned set is not thread safe, all modifications must be made holding // the uidStoreLock. func (u *UIDTrackingControllerExpectations) GetUIDs(controllerKey string) sets.String { if uid, exists, err := u.uidStore.GetByKey(controllerKey); err == nil && exists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 12 15:34:44 UTC 2024 - 47.6K bytes - Viewed (0) -
pkg/kubelet/cm/memorymanager/policy_static.go
for _, hint := range hints[string(v1.ResourceMemory)] { affinityBits := hint.NUMANodeAffinity.GetBits() // filter all hints that does not include currentHint if isHintInGroup(mask.GetBits(), affinityBits) { filteredHints = append(filteredHints, hint) } } if len(filteredHints) < 1 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Nov 12 07:34:55 UTC 2023 - 34K bytes - Viewed (0) -
fess-crawler-es/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java
String scrollId = response.getScrollId(); int count = 0; try { while (scrollId != null) { final SearchHit[] hits = response.getHits().getHits(); if (hits.length == 0) { break; } count += hits.length; final BulkResponse bulkResponse = get(c -> {
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 19.8K bytes - Viewed (0) -
platforms/ide/ide-plugins/src/main/java/org/gradle/plugins/ide/eclipse/EclipsePlugin.java
for (SourceSet sourceSet : project.getExtensions().getByType(JavaPluginExtension.class).getSourceSets()) { result.addAll(sourceSet.getOutput().getDirs().getFiles()); } return result; } }); task.configure(new Action<GenerateEclipseClasspath>() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 23.5K bytes - Viewed (0)