- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for flow (0.02 sec)
-
docs/changelogs/changelog_3x.md
## Version 3.14.3 _2019-09-10_ * Fix: Don't lose HTTP/2 flow control bytes when incoming data races with a stream close. If this happened enough then eventually the connection would stall. * Fix: Acknowledge and apply inbound HTTP/2 settings atomically. Previously we had a race where we could use new flow control capacity before acknowledging it, causing strict HTTP/2 servers to fail the call.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 14:55:54 UTC 2022 - 50.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt
// transmitted until the flow-control window is updated from the first request. val call2 = client.newCall(Request(server.url("/"))) val response2 = call2.execute() assertThat(response2.code).isEqualTo(200) // Close the response body. This should discard the buffered data and update the connection // flow-control window. response1.close()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 73.4K bytes - Viewed (0) -
tensorflow/c/c_api.h
// the corresponding function's output will equal to this input, // instead of the original node's output. // // Callers must also satisfy the following constraints: // - `inputs` cannot refer to TF_Outputs within a control flow context. For // example, one cannot use the output of "switch" node as input. // - `inputs` and `outputs` cannot have reference types. Reference types are
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Thu Oct 26 21:08:15 UTC 2023 - 82.3K bytes - Viewed (0) -
cmd/bucket-handlers.go
xMinIOErrDescHeader = "x-minio-error-desc" postPolicyBucketTagging = "tagging" ) // Check if there are buckets on server without corresponding entry in etcd backend and // make entries. Here is the general flow // - Range over all the available buckets // - Check if a bucket has an entry in etcd backend // -- If no, make an entry // -- If yes, check if the entry matches local IP check if we //
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 63.9K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/IteratorsTest.java
} }.test(); } @GwtIncompatible // slow (~5s) public void testConcatNoIteratorsYieldsEmpty() { new EmptyIteratorTester() { @Override protected Iterator<Integer> newTargetIterator() { return Iterators.concat(); } }.test(); } @GwtIncompatible // slow (~5s) public void testConcatOneEmptyIteratorYieldsEmpty() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 54.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/IteratorsTest.java
} }.test(); } @GwtIncompatible // slow (~5s) public void testConcatNoIteratorsYieldsEmpty() { new EmptyIteratorTester() { @Override protected Iterator<Integer> newTargetIterator() { return Iterators.concat(); } }.test(); } @GwtIncompatible // slow (~5s) public void testConcatOneEmptyIteratorYieldsEmpty() {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 54.4K bytes - Viewed (0) -
src/cmd/asm/internal/asm/testdata/riscv64.s
AMOMIND X5, (X6), X7 // af335386 AMOMINUW X5, (X6), X7 // af2353c6 AMOMINUD X5, (X6), X7 // af3353c6 // 20.5: Single-Precision Load and Store Instructions FLW (X5), F0 // 07a00200 FLW 4(X5), F0 // 07a04200 FSW F0, (X5) // 27a00200 FSW F0, 4(X5) // 27a20200 // 20.6: Single-Precision Floating-Point Computational Instructions FADDS F1, F0, F2 // 53011000
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Wed May 21 14:19:19 UTC 2025 - 49.1K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/EventListenerTest.kt
import org.junit.jupiter.api.Tag import org.junit.jupiter.api.Test import org.junit.jupiter.api.Timeout import org.junit.jupiter.api.extension.RegisterExtension @Flaky // STDOUT logging enabled for test @Timeout(30) @Tag("Slow") class EventListenerTest { @RegisterExtension val platform = PlatformRule() @RegisterExtension val clientTestRule = OkHttpClientTestRule() @StartStop private val server = MockWebServer()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Jun 20 11:46:46 UTC 2025 - 60.4K bytes - Viewed (0) -
.bazelrc
# LINUX ARM64 PYCPP # In Linux Arm64 presubmit/continuous build, we cross-compile the binaries on # Linux x86 so that we can use RBE. Since tests still need to run on the single # host Arm64 machine, the build becomes too slow (~30 min) to be a presubmit. # For testing purposes, we want to see the runtime performance of an # experimental job that is build-only, i.e, we only build the test targets and
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Fri Aug 22 21:03:34 UTC 2025 - 56K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Futures.java
* Exception.) */ throw new UncheckedExecutionException(wrapper.getCause()); } } /* * Arguably we don't need a timed getUnchecked because any operation slow enough to require a * timeout is heavyweight enough to throw a checked exception and therefore be inappropriate to * use with getUnchecked. Further, it's not clear that converting the checked TimeoutException to
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 64.3K bytes - Viewed (0)