Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 61 for Relay (0.04 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/cache2/Relay.kt

        file!!.channel.force(false)
    
        // This file is complete.
        synchronized(this@Relay) {
          complete = true
        }
    
        upstream?.closeQuietly()
        upstream = null
      }
    
      fun metadata(): ByteString = metadata
    
      /**
       * Returns a new source that returns the same bytes as upstream. Returns null if this relay has
       * been closed and no further sources are possible. In that case callers should retry after
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed May 28 17:15:47 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  2. src/test/java/org/codelibs/fess/mylasta/direction/FessEnvTest.java

                    props.setProperty(FessEnv.MAIL_SMTP_SERVER_MAIN_HOST_AND_PORT, "smtp-relay.example.com:465");
                    props.setProperty(FessEnv.MAIL_SUBJECT_TEST_PREFIX, "[テスト環境]");
                    props.setProperty(FessEnv.MAIL_RETURN_PATH, "******@****.***");
                    return props;
                }
            };
    
            assertEquals("smtp-relay.example.com:465", specialMailEnv.getMailSmtpServerMainHostAndPort());
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 15.5K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/helper/IntervalControlHelper.java

            }
        }
    
        /**
         * Applies delay based on the configured interval rules.
         * This method calculates the appropriate delay for the current time
         * and applies it by sleeping the current thread.
         */
        public void delayByRules() {
            final long delay = getDelay();
            if (delay > 0) {
                ThreadUtil.sleep(delay);
            }
        }
    
        /**
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            this.delay = delay;
            this.unit = checkNotNull(unit);
          }
    
          /**
           * @param delay the time from now to delay execution
           * @since 33.4.0 (but since 31.1 in the JRE flavor)
           */
          @IgnoreJRERequirement // Users will use this only if they're already using Duration
          public Schedule(Duration delay) {
            this(toNanosSaturated(delay), NANOSECONDS);
          }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  5. src/test/java/jcifs/smb1/smb1/TestLockingTest.java

            t.numThreads = 5;
            t.numIter = 10;
            t.delay = 250L;
            t.url = "smb://custom/path/file.txt";
    
            // Verify values are set
            assertEquals(5, t.numThreads, "numThreads should be configurable");
            assertEquals(10, t.numIter, "numIter should be configurable");
            assertEquals(250L, t.delay, "delay should be configurable");
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

            this.delay = delay;
            this.unit = checkNotNull(unit);
          }
    
          /**
           * @param delay the time from now to delay execution
           * @since 31.1 (but only since 33.4.0 in the Android flavor)
           */
          public Schedule(Duration delay) {
            this(toNanosSaturated(delay), NANOSECONDS);
          }
        }
    
        /**
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  7. cmd/batch-rotate.go

    	lastObject := ri.Object
    
    	retryAttempts := job.KeyRotate.Flags.Retry.Attempts
    	if retryAttempts <= 0 {
    		retryAttempts = batchKeyRotateJobDefaultRetries
    	}
    	delay := job.KeyRotate.Flags.Retry.Delay
    	if delay <= 0 {
    		delay = batchKeyRotateJobDefaultRetryDelay
    	}
    
    	rnd := rand.New(rand.NewSource(time.Now().UnixNano()))
    
    	selectObj := func(info FileInfo) (ok bool) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 14.7K bytes
    - Viewed (0)
  8. fess-crawler/src/main/java/org/codelibs/fess/crawler/entity/RobotsTxt.java

        }
    
        /**
         * Gets the crawl delay value for the specified user agent from robots.txt.
         * The crawl delay specifies the time (in seconds) to wait between successive requests.
         *
         * @param userAgent The user agent string to match against robots.txt directives
         * @return The crawl delay value in seconds. Returns 0 if no matching directive is found
         *         or no crawl delay is specified for the matching directive.
         */
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 10K bytes
    - Viewed (0)
  9. src/main/java/jcifs/internal/smb2/rdma/RdmaErrorHandler.java

                        // Check for potential overflow before multiplication
                        long delay = (retryDelayMs > Long.MAX_VALUE / multiplier) ? MAX_RETRY_DELAY
                                : Math.min(MAX_RETRY_DELAY, retryDelayMs * multiplier);
                        Thread.sleep(delay);
                    }
    
                    // Attempt to reset the connection
                    connection.reset();
    
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  10. mockwebserver/src/main/kotlin/mockwebserver3/MockResponse.kt

          }
    
        public fun headersDelay(
          delay: Long,
          unit: TimeUnit,
        ): Builder =
          apply {
            headersDelayNanos = unit.toNanos(delay)
          }
    
        /**
         * Set the delayed time of the response body to [delay]. This applies to the response body
         * only; response headers are not affected.
         */
        public fun bodyDelay(
          delay: Long,
          unit: TimeUnit,
        ): Builder =
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 17.8K bytes
    - Viewed (0)
Back to top