Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 61 - 70 of 156 for getlist (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/ftp/FtpClientTest.java

            ftpInfo = new FtpClient.FtpInfo(value, Constants.UTF_8);
            assertEquals(value, ftpInfo.toUrl());
            assertEquals("123.123.123.123:9999", ftpInfo.getCacheKey());
            assertEquals("123.123.123.123", ftpInfo.getHost());
            assertEquals(9999, ftpInfo.getPort());
            assertEquals("/", ftpInfo.getParent());
            assertNull(ftpInfo.getName());
    
            value = "ftp://123.123.123.123/test.txt";
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Mon Nov 24 03:59:47 GMT 2025
    - 21.5K bytes
    - Click Count (0)
  2. guava/src/com/google/common/collect/FluentIterable.java

       *
       * @throws NullPointerException if the last element is null; if this is a possibility, use {@link
       *     Iterables#getLast} instead.
       */
      @SuppressWarnings("nullness") // Unsafe, but we can't do much about it now.
      public final Optional<@NonNull E> last() {
        // Iterables#getLast was inlined here so we don't have to throw/catch a NSEE
    
        // TODO(kevinb): Support a concurrently modified collection?
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 18:35:44 GMT 2025
    - 34.7K bytes
    - Click Count (0)
  3. fess-crawler-opensearch/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 -> {
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Nov 23 02:01:26 GMT 2025
    - 26.2K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/suggest/index/contents/document/ESSourceReader.java

                            SuggestUtil.deleteScrollContext(client, scrollId);
                        }
                    }
                    scrollId = response.getScrollId();
                    final SearchHit[] hits = response.getHits().getHits();
                    if (scrollId == null || hits.length == 0) {
                        SuggestUtil.deleteScrollContext(client, scrollId);
                        isFinished.set(true);
                    }
    
    Created: Sat Dec 20 13:04:59 GMT 2025
    - Last Modified: Mon Nov 24 03:40:05 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  5. src/main/java/jcifs/smb/SmbResourceLocatorImpl.java

                    i--;
                }
                return urlpath.substring(i + 1);
            }
            if (shr != null) {
                return shr + '/';
            }
            if (this.url.getHost().length() > 0) {
                return this.url.getHost() + '/';
            }
            return "smb://";
        }
    
        /**
         * {@inheritDoc}
         *
         * @see jcifs.SmbResourceLocator#getParent()
         */
        @Override
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 23.6K bytes
    - Click Count (0)
  6. cmd/warm-backend-gcs.go

    }
    
    func (gcs *warmBackendGCS) getDest(object string) string {
    	destObj := object
    	if gcs.Prefix != "" {
    		destObj = fmt.Sprintf("%s/%s", gcs.Prefix, object)
    	}
    	return destObj
    }
    
    func (gcs *warmBackendGCS) PutWithMeta(ctx context.Context, key string, data io.Reader, length int64, meta map[string]string) (remoteVersionID, error) {
    	object := gcs.client.Bucket(gcs.Bucket).Object(gcs.getDest(key))
    	w := object.NewWriter(ctx)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Mar 30 00:56:02 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  7. src/main/java/jcifs/smb/NetServerEnumIterator.java

            this.workgroup = locator.getType() == SmbConstants.TYPE_WORKGROUP;
            if (locator.getURL().getHost().isEmpty()) {
                this.request = new NetServerEnum2(th.getConfig(), th.getOEMDomainName(), NetServerEnum2.SV_TYPE_DOMAIN_ENUM);
            } else if (this.workgroup) {
                this.request = new NetServerEnum2(th.getConfig(), locator.getURL().getHost(), NetServerEnum2.SV_TYPE_ALL);
            } else {
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6.5K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/helper/CrawlingInfoHelper.java

         */
        public synchronized void store(final String sessionId, final boolean create) {
            CrawlingInfo crawlingInfo = create ? null : getCrawlingInfoService().getLast(sessionId);
            if (crawlingInfo == null) {
                crawlingInfo = new CrawlingInfo(sessionId);
                try {
                    getCrawlingInfoService().store(crawlingInfo);
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 15.2K bytes
    - Click Count (0)
  9. src/main/java/org/codelibs/fess/rank/fusion/DefaultSearcher.java

            final SearchResultBuilder builder = SearchResult.create();
            searchResponseOpt.ifPresent(searchResponse -> {
                final SearchHits searchHits = searchResponse.getHits();
                builder.allRecordCount(searchHits.getTotalHits().value());
                builder.allRecordCountRelation(searchHits.getTotalHits().relation().toString());
                builder.queryTime(searchResponse.getTook().millis());
    Created: Sat Dec 20 09:19:18 GMT 2025
    - Last Modified: Thu Nov 20 09:24:04 GMT 2025
    - 12.6K bytes
    - Click Count (0)
  10. build-logic/documentation/src/main/groovy/gradlebuild/docs/dsl/docbook/BasicJavadocLexer.java

                        parseHtmlEncodedChar(text);
                    } else if (scanner.lookingAt(HTML_ENTITY)) {
                        parseHtmlEntity(text);
                    } else {
                        text.append(scanner.getFirst());
                        scanner.next();
                    }
                }
    
                visitor.onText(text.toString());
            }
            visitor.onEnd();
        }
    
        private void skipComment() {
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Mon Aug 19 15:07:24 GMT 2024
    - 7.1K bytes
    - Click Count (0)
Back to Top