- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 86 for adjusted (0.08 sec)
-
cmd/dynamic-timeouts_test.go
timeout.LogSuccess(20 * time.Second) } adjusted := timeout.Timeout() for i := 0; i < dynamicTimeoutLogSize; i++ { timeout.LogSuccess(20 * time.Second) } adjustedAgain := timeout.Timeout() if initial <= adjusted || adjusted <= adjustedAgain { t.Errorf("Failure to decrease timeout multiple times, initial: %v, adjusted: %v, again: %v", initial, adjusted, adjustedAgain) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Oct 14 10:08:40 UTC 2022 - 5.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/RealInterceptorChain.kt
check(exchange == null) { "Timeouts can't be adjusted in a network interceptor" } return copy(connectTimeoutMillis = checkDuration("connectTimeout", timeout.toLong(), unit)) } override fun readTimeoutMillis(): Int = readTimeoutMillis override fun withReadTimeout( timeout: Int, unit: TimeUnit, ): Interceptor.Chain { check(exchange == null) { "Timeouts can't be adjusted in a network interceptor" }
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.2K bytes - Viewed (0) -
src/test/java/jcifs/tests/ContextConfigTest.java
PropertyConfiguration p3 = new PropertyConfiguration(prop3); assertEquals(DialectVersion.SMB202, p3.getMinimumVersion()); // needs to be adjusted when default changes assertEquals(DialectVersion.SMB210, p3.getMaximumVersion()); } @Test // #226 public void testLegacyConfig () throws CIFSException {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Mon Mar 13 12:00:57 UTC 2023 - 9.9K bytes - Viewed (0) -
src/main/java/jcifs/SmbWatchHandle.java
* implementations. * * Changes in between these calls (as long as the file is open) are buffered by the server, so iteratively calling * this method should provide all changes (size of that buffer can be adjusted through * {@link jcifs.Configuration#getNotifyBufferSize()}). * If the server cannot fulfill the request because the changes did not fit the buffer * it will return an empty list of changes. *
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 2.3K bytes - Viewed (0) -
docs/config/README.md
settings allow for more staggered delay in terms of usage calculation. The scanner adapts to the system speed and completely pauses when the system is under load. It is possible to adjust the speed of the scanner and thereby the latency of updates being reflected. The delays between each operation of the scanner can be adjusted by the `mc admin config set alias/ delay=15.0`. By default the value is `10.0`. This means the scanner will sleep *10x* the time each operation takes. In most setups...
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Aug 16 08:43:49 UTC 2024 - 17.9K bytes - Viewed (1) -
okhttp/src/test/java/okhttp3/InterceptorTest.kt
val call = client.newCall(request1) assertFailsWith<IllegalStateException> { call.execute() }.also { expected -> assertThat(expected.message) .isEqualTo("Timeouts can't be adjusted in a network interceptor") } } @Test fun networkInterceptorCannotChangeWriteTimeout() { addInterceptor(true) { chain: Interceptor.Chain -> chain.withWriteTimeout( 100,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sun Jan 14 10:20:09 UTC 2024 - 27.8K bytes - Viewed (0) -
common-protos/k8s.io/apimachinery/pkg/api/resource/generated.proto
// it had, and will use the same type again when it is serialized. // // Before serializing, Quantity will be put in "canonical form". // This means that Exponent/suffix will be adjusted up or down (with a // corresponding increase or decrease in Mantissa) such that: // // - No precision is lost // - No fractional digits will be emitted // - The exponent (or suffix) is as large as possible. //
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 3.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AtomicLongMap.java
// only remove after setting to zero, to avoid concurrent updates map.remove(key, atomic); // succeed even if the remove fails, since the value was already adjusted return oldValue; } } } /** * If {@code (key, value)} is currently in the map, this method removes it and returns true; * otherwise, this method returns false. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Apr 01 16:15:01 UTC 2024 - 14.1K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbResourceLocatorImpl.java
* - canonical URL path: path component of the URL: this is used to reconstruct URLs to resources and is not adjusted by * DFS referrals. (E.g. a resource with a DFS root's parent will still point to the DFS root not the share it's actually * located in). * - share + uncpath within it: This is the relevant information for most SMB requests. Both are adjusted by DFS * referrals. Nested resources will inherit the information already resolved by the parent resource.
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sat Jul 20 08:24:53 UTC 2019 - 23.9K bytes - Viewed (0) -
internal/logger/target/http/http.go
buf := bytebufferpool.Get() enc := jsoniter.ConfigCompatibleWithStandardLibrary.NewEncoder(buf) defer bytebufferpool.Put(buf) isDirQueue := h.config.QueueDir != "" // globalBuffer is always created or adjusted // before this method is launched. logChLock.Lock() globalBuffer := logChBuffers[name] logChLock.Unlock() ticker := time.NewTicker(time.Second) defer ticker.Stop() var count int for {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Sep 11 22:20:42 UTC 2024 - 15.6K bytes - Viewed (0)