- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 61 for Relay (0.04 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
src/main/java/jcifs/internal/smb2/rdma/RdmaErrorHandler.java
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 10.5K bytes - Viewed (0) -
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)