Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 69 for getPids (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top