- Sort Score
- Result 10 results
- Languages All
Results 841 - 850 of 1,379 for pread (0.03 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt
condition.signalAll() return stream } } internal fun updateConnectionFlowControl(read: Long) { this.withLock { readBytes.update(total = read) val readBytesToAcknowledge = readBytes.unacknowledged if (readBytesToAcknowledge >= okHttpSettings.initialWindowSize / 2) { writeWindowUpdateLater(0, readBytesToAcknowledge)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 32.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/io/BaseEncodingTest.java
try (InputStream decodingStream = encoding.decodingStream(new StringReader(encoded))) { for (int i = 0; i < bytes.length; i++) { assertThat(decodingStream.read()).isEqualTo(bytes[i] & 0xFF); } assertThat(decodingStream.read()).isEqualTo(-1); } } public void testToString() { assertThat(base64().toString()).isEqualTo("BaseEncoding.base64().withPadChar('=')");
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Oct 21 16:27:30 UTC 2024 - 24.6K bytes - Viewed (0) -
docs/distributed/DECOMMISSION.md
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jul 11 14:59:49 UTC 2022 - 8.3K bytes - Viewed (0) -
internal/http/server.go
return nil } // UseIdleTimeout configure idle connection timeout func (srv *Server) UseIdleTimeout(d time.Duration) *Server { srv.IdleTimeout = d return srv } // UseReadHeaderTimeout configure read header timeout func (srv *Server) UseReadHeaderTimeout(d time.Duration) *Server { srv.ReadHeaderTimeout = d return srv } // UseHandler configure final handler for this HTTP *Server
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 19 18:42:47 UTC 2024 - 6.1K bytes - Viewed (0) -
build-logic/dependency-modules/src/main/kotlin/gradlebuild.dependency-modules.gradle.kts
// We don't need the extra annotations provided by j2objc withLibraryDependencies<DependencyRemovalByNameRule>(libs.googleHttpClient, setOf("j2objc-annotations")) // Read capabilities declared in capabilities.json readCapabilitiesFromJson() withModule<ReplaceCglibNodepWithCglibRule>("org.spockframework:spock-core")
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Jun 05 20:15:18 UTC 2024 - 9.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/SessionServicePacket.java
} static int readn( InputStream in, byte[] b, int off, int len ) throws IOException { int i = 0, n; while (i < len) { n = in.read( b, off + i, len - i ); if (n <= 0) { break; } i += n; } return i; } static int readPacketType( InputStream in,
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 4.8K bytes - Viewed (0) -
api/maven-api-core/src/main/java/org/apache/maven/api/services/BuilderProblem.java
* track the problem back to its origin. A concrete example for such a source hint can be the file path or URL from * which the settings were read. * * @return the hint about the source of the problem or an empty string if unknown, never {@code null} */ @Nonnull String getSource(); /**
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Thu Mar 23 05:29:39 UTC 2023 - 3.6K bytes - Viewed (0) -
regression-test/src/androidTest/java/okhttp/regression/LetsEncryptTest.java
import javax.net.ssl.SSLHandshakeException; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; /** * Let's Encrypt expiring root test. * * Read https://community.letsencrypt.org/t/mobile-client-workarounds-for-isrg-issue/137807 * for background. */ @RunWith(AndroidJUnit4.class) public class LetsEncryptTest {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Nov 17 07:40:31 UTC 2020 - 6.1K bytes - Viewed (0) -
cmd/erasure-server-pool.go
derrs := make([]error, len(poolIndices)) dobjects := make([]ObjectInfo, len(poolIndices)) // Delete concurrently in all server pools that reported no error or read quorum error // where the read quorum issue is from metadata inconsistency. var wg sync.WaitGroup for idx, pe := range poolIndices { if v, ok := pe.Err.(InsufficientReadQuorum); ok && v.Type != RQInconsistentMeta {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 89.8K bytes - Viewed (0) -
tests/test_tutorial/test_header_param_models/test_tutorial002.py
"openapi": "3.1.0", "info": {"title": "FastAPI", "version": "0.1.0"}, "paths": { "/items/": { "get": { "summary": "Read Items", "operationId": "read_items_items__get", "parameters": [ { "name": "host",
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Sep 17 18:54:10 UTC 2024 - 9.5K bytes - Viewed (0)