- Sort Score
- Result 10 results
- Languages All
Results 181 - 190 of 277 for flow (0.03 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/http/CancelTest.kt
import org.junit.jupiter.api.Timeout import org.junit.jupiter.api.extension.RegisterExtension import org.junit.jupiter.params.ParameterizedTest import org.junit.jupiter.params.provider.ArgumentsSource @Timeout(30) @Tag("Slow") class CancelTest { @JvmField @RegisterExtension val platform = PlatformRule() lateinit var cancelMode: CancelMode lateinit var connectionType: ConnectionType private var threadToCancel: Thread? = null
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 9.8K bytes - Viewed (0) -
doc/asm.html
specific to each architecture. The sections below list these. </p> <p> One detail evident in the examples from the previous sections is that data in the instructions flows from left to right: <code>MOVQ</code> <code>$0,</code> <code>CX</code> clears <code>CX</code>. This rule applies even on architectures where the conventional notation uses the opposite direction. </p> <p>
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Tue Nov 28 19:15:27 UTC 2023 - 36.3K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/ContiguousSetTest.java
assertTrue(enormous instanceof RegularContiguousSet); // We can't use reserializeAndAssert because it calls hashCode, which is enormously slow. ContiguousSet<Integer> enormousReserialized = reserialize(enormous); assertEquals(enormous, enormousReserialized); } private static final DiscreteDomain<Integer> UNBOUNDED_THROWING_DOMAIN =
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.6K bytes - Viewed (0) -
src/test/java/jcifs/util/SmbCircuitBreakerTest.java
}); cbWithMetrics.executeWithCircuitBreaker(() -> { try { Thread.sleep(300); } catch (InterruptedException e) {} return "slow"; }); // Check metrics assertTrue(cbWithMetrics.getAverageResponseTime() > 0, "Average response time should be tracked");
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 23.2K bytes - Viewed (0) -
src/test/java/jcifs/internal/smb1/AndXServerMessageBlockTest.java
}; byte[] buffer = new byte[1024]; // Setup buffer after header buffer[33] = 4; // wordCount buffer[34] = (byte) 0xFF; // andxCommand buffer[36] = 0; // andxOffset low buffer[37] = 0; // andxOffset high SMBUtil.writeInt2(20, buffer, 42); // byteCount int length = testBlock.decode(buffer, 0); assertTrue(length > 0);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 19.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/primitives/UnsignedLongsTest.java
assertThat(UnsignedLongs.remainder(0xfffffffffffffffeL, 2)).isEqualTo(0); assertThat(UnsignedLongs.remainder(0xfffffffffffffffeL, 5)).isEqualTo(4); } @GwtIncompatible // Too slow in GWT (~3min fully optimized) public void testDivideRemainderEuclideanProperty() { // Use a seed so that the test is deterministic: Random r = new Random(0L); for (int i = 0; i < 1000000; i++) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 12.8K bytes - Viewed (0) -
ci/official/utilities/extract_resultstore_links.py
f'Log fragment:\n' f'```\n{log_fragment}\n```\n' f'{"=" * 140}') break k -= 1 # A low-effort attempt to find the bazel command that triggered the # invocation. bazel_comm_min_line_i = (previous_end_line if previous_end_line is not None else 0)
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Wed Nov 08 17:50:27 UTC 2023 - 10.9K bytes - Viewed (0) -
cmd/bucket-replication.go
// WorkerMinLimit min number of workers per node for "slow" mode WorkerMinLimit = 50 // WorkerAutoDefault is default number of workers for "auto" mode WorkerAutoDefault = 100 // MRFWorkerMaxLimit max number of mrf workers per node for "fast" mode MRFWorkerMaxLimit = 8 // MRFWorkerMinLimit min number of mrf workers per node for "slow" mode MRFWorkerMinLimit = 2
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
* problems can exist with methods like FutureTask.done(), not to mention slow calls to * Thread.interrupt() (as discussed in InterruptibleTask). At the end of the day, it's * unlikely that cancel() will be slow, so we can probably get away with calling it while * holding a lock. Still, it would be nice to avoid somehow. */
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Utf8.java
import static java.lang.Character.MAX_SURROGATE; import static java.lang.Character.MIN_SURROGATE; import com.google.common.annotations.GwtCompatible; /** * Low-level, high-performance utility methods related to the {@linkplain Charsets#UTF_8 UTF-8} * character encoding. UTF-8 is defined in section D92 of <a * href="http://www.unicode.org/versions/Unicode6.2.0/ch03.pdf">The Unicode Standard Core
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Aug 11 19:31:30 UTC 2025 - 7K bytes - Viewed (0)