Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for getTook (0.06 sec)

  1. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchDataService.java

            final TotalHits totalHits = hits.getTotalHits();
            final long totalHitsValue = totalHits != null ? totalHits.value() : 0;
            targetList.setTotalHits(totalHitsValue);
            targetList.setTookInMillis(response.getTook().getMillis());
            if (totalHitsValue != 0) {
                try {
                    for (final SearchHit searchHit : hits.getHits()) {
                        final OpenSearchAccessResult target = new OpenSearchAccessResult();
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 10.9K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/rank/fusion/DefaultSearcher.java

                builder.allRecordCount(searchHits.getTotalHits().value());
                builder.allRecordCountRelation(searchHits.getTotalHits().relation().toString());
                builder.queryTime(searchResponse.getTook().millis());
    
                if (searchResponse.getTotalShards() != searchResponse.getSuccessfulShards()) {
                    builder.partialResults(true);
                }
    
                // build highlighting fields
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 12.6K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/suggest/request/popularwords/PopularWordsRequest.java

                words.add(text);
    
                if (detail) {
                    items.add(SuggestItem.parseSource(source));
                }
            }
    
            return new PopularWordsResponse(index, searchResponse.getTook().getMillis(), words, searchResponse.getHits().getTotalHits().value(),
                    items);
        }
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/suggest/request/suggest/SuggestRequest.java

                    }
                }
            }
            firstWords.addAll(secondWords);
            firstItems.addAll(secondItems);
            return new SuggestResponse(index, searchResponse.getTook().getMillis(), firstWords, searchResponse.getHits().getTotalHits().value(),
                    firstItems);
        }
    
        /**
         * Checks if the first word matches.
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Thu Aug 07 02:41:28 UTC 2025
    - 17.8K bytes
    - Viewed (0)
  5. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/AbstractCrawlerService.java

            final TotalHits totalHits = hits.getTotalHits();
            final long totalHitsValue = totalHits != null ? totalHits.value() : 0;
            targetList.setTotalHits(totalHitsValue);
            targetList.setTookInMillis(response.getTook().getMillis());
            if (totalHitsValue != 0) {
                try {
                    for (final SearchHit searchHit : hits.getHits()) {
                        final Map<String, Object> source = searchHit.getSourceAsMap();
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 34.2K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool.go

    			return BucketNameInvalid{Bucket: bucket}
    		}
    
    		if !opts.NoLock {
    			// Lock the bucket name before creating.
    			lk := z.NewNSLock(minioMetaTmpBucket, bucket+".lck")
    			lkctx, err := lk.GetLock(ctx, globalOperationTimeout)
    			if err != nil {
    				return err
    			}
    
    			ctx = lkctx.Context()
    			defer lk.Unlock(lkctx)
    		}
    	}
    
    	if err := z.s3Peer.MakeBucket(ctx, bucket, opts); err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  7. cmd/callhome.go

    }
    
    func runCallhome(ctx context.Context, objAPI ObjectLayer) bool {
    	// Make sure only 1 callhome is running on the cluster.
    	locker := objAPI.NewNSLock(minioMetaBucket, "callhome/runCallhome.lock")
    	lkctx, err := locker.GetLock(ctx, callhomeLeaderLockTimeout)
    	if err != nil {
    		// lock timedout means some other node is the leader,
    		// cycle back return 'true'
    		return true
    	}
    
    	ctx = lkctx.Context()
    	defer locker.Unlock(lkctx)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.3K bytes
    - Viewed (0)
  8. cmd/erasure-multipart.go

    	if opts.CheckPrecondFn != nil {
    		if !opts.NoLock {
    			ns := er.NewNSLock(bucket, object)
    			lkctx, err := ns.GetLock(ctx, globalOperationTimeout)
    			if err != nil {
    				return nil, err
    			}
    			ctx = lkctx.Context()
    			defer ns.Unlock(lkctx)
    			opts.NoLock = true
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  9. cmd/erasure-object.go

    	if !srcInfo.metadataOnly {
    		return oi, NotImplemented{}
    	}
    
    	if !dstOpts.NoLock {
    		lk := er.NewNSLock(dstBucket, dstObject)
    		lkctx, err := lk.GetLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return oi, err
    		}
    		ctx = lkctx.Context()
    		defer lk.Unlock(lkctx)
    	}
    	// Read metadata associated with the object from all disks.
    	storageDisks := er.getDisks()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  10. cmd/admin-handlers.go

    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrNotImplemented), r.URL)
    		return
    	}
    
    	nsLock := objectAPI.NewNSLock(minioMetaBucket, "site-net-perf")
    	lkctx, err := nsLock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(toAPIErrorCode(ctx, err)), r.URL)
    		return
    	}
    	ctx = lkctx.Context()
    	defer nsLock.Unlock(lkctx)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
Back to top