Search Options

Results per page
Sort
Preferred Languages
Advance

Results 451 - 460 of 503 for sublist (0.15 sec)

  1. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/client/FesenClient.java

            final String[] hosts =
                    split(address, ",").get(stream -> stream.map(String::trim).filter(StringUtil::isNotEmpty).toArray(n -> new String[n]));
            final Settings settings = Settings.builder().putList("http.hosts", hosts).build();
            return new HttpClient(settings, null);
        }
    
        /**
         * Executes an OpenSearch operation with retry logic.
         *
         * @param <T> The response type.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Aug 31 05:32:52 UTC 2025
    - 25.3K bytes
    - Viewed (0)
  2. src/main/resources/fess_message_ko.properties

    errors.app.db.already.deleted = 다른 프로세스에 의해 삭제되었을 수 있습니다. 다시 시도하십시오.
    errors.app.db.already.updated = 다른 프로세스에 의해 업데이트되었을 수 있습니다. 다시 시도하십시오.
    errors.app.db.already.exists = 데이터가 이미 존재합니다. 다시 시도하십시오.
    errors.app.double.submit.request = 이 요청 전에 처리되었을 수 있습니다. 다시 시도하십시오.
    # _/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/_/
    # you can define your messages here:
    # e.g.
    # errors.xxx = ...
    # info.xxx = ...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 05 02:36:47 UTC 2025
    - 14.1K bytes
    - Viewed (0)
  3. fess-crawler/src/test/java/org/codelibs/fess/crawler/transformer/TransformerTest.java

            ExecutorService executor = Executors.newFixedThreadPool(threadCount);
    
            for (int i = 0; i < threadCount; i++) {
                final int threadId = i;
                executor.submit(new Runnable() {
                    @Override
                    public void run() {
                        try {
                            startLatch.await();
                            for (int j = 0; j < operationsPerThread; j++) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sat Sep 06 04:15:37 UTC 2025
    - 28K bytes
    - Viewed (0)
  4. android-test/src/androidTest/java/okhttp/android/test/OkHttpTest.kt

      fun testLoggingLevels() {
        enableTls()
    
        val testHandler =
          object : Handler() {
            val calls = mutableMapOf<String, AtomicInteger>()
    
            override fun publish(record: LogRecord) {
              calls
                .getOrPut(record.loggerName) { AtomicInteger(0) }
                .incrementAndGet()
            }
    
            override fun flush() {
            }
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 02 14:12:28 UTC 2025
    - 29K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-rebalance.go

    	startTime := time.Now()
    	return func(sz int64, err error) {
    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceRebalance) > 0 {
    			globalTrace.Publish(rebalanceTrace(r, poolIdx, startTime, duration, err, strings.Join(paths, " "), sz))
    		}
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  6. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache/DiskLruCache.kt

       *     CLEAN or REMOVE indicate that temporary files may need to be deleted.
       *
       *   o CLEAN lines track a cache entry that has been successfully published and may be read. A
       *     publish line is followed by the lengths of each of its values.
       *
       *   o READ lines track accesses for LRU.
       *
       *   o REMOVE lines track entries that have been deleted.
       *
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 23:28:25 UTC 2025
    - 34.7K bytes
    - Viewed (0)
  7. compat/maven-compat/src/main/java/org/apache/maven/repository/legacy/LegacyRepositorySystem.java

                throw new ArtifactDoesNotExistException(getMessage(e, "Requested artifact does not exist."), e);
            }
        }
    
        @Override
        public void publish(
                ArtifactRepository repository, File source, String remotePath, ArtifactTransferListener transferListener)
                throws ArtifactTransferFailedException {
            try {
                wagonManager.putRemoteFile(
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Fri Jun 06 14:28:57 UTC 2025
    - 31.2K bytes
    - Viewed (0)
  8. docs/en/docs/help-fastapi.md

        * Read other ideas, articles, and read about tools I have created.
        * Follow me to read when I publish something new.
    
    ## Tweet about **FastAPI** { #tweet-about-fastapi }
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Sun Aug 31 10:49:48 UTC 2025
    - 14K bytes
    - Viewed (0)
  9. src/main/java/jcifs/audit/SecurityAuditLogger.java

            startAsyncProcessor();
    
            // Register shutdown hook
            Runtime.getRuntime().addShutdownHook(new Thread(this::shutdown));
        }
    
        private void startAsyncProcessor() {
            logExecutor.submit(() -> {
                while (!shutdown) {
                    try {
                        AuditEntry entry = logQueue.take();
                        if (entry != null) {
                            processLogEntry(entry);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  10. cmd/bucket-lifecycle.go

    		duration := time.Since(startTime)
    		if globalTrace.NumSubscribers(madmin.TraceILM) > 0 {
    			e := ""
    			if err != nil {
    				e = err.Error()
    			}
    			globalTrace.Publish(ilmTrace(startTime, duration, oi, event, metadata, e))
    		}
    	}
    }
    
    type expiryTask struct {
    	objInfo ObjectInfo
    	event   lifecycle.Event
    	src     lcEventSrc
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
Back to top