- Sort Score
- Result 10 results
- Languages All
Results 81 - 90 of 802 for srcset (0.38 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/MockHttp2Peer.kt
private fun readAndWriteFrames() { check(socket == null) val socket = serverSocket!!.accept()!! this.socket = socket // Bail out now if this instance was closed while waiting for the socket to accept. synchronized(this) { if (executor.isShutdown) { socket.close() return } } val outputStream = socket.getOutputStream()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 8.7K bytes - Viewed (0) -
mockwebserver/src/main/kotlin/mockwebserver3/SocketHandler.kt
*/ package mockwebserver3 import okio.Socket /** * Handles a call's request and response streams directly. Use this instead of [MockResponseBody] to * begin sending response data before all request data has been received. * * See [okhttp3.RequestBody.isDuplex]. */ public interface SocketHandler { public fun handle(socket: Socket)
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sat Jun 14 16:09:26 UTC 2025 - 940 bytes - Viewed (0) -
docs/docker/README.md
``` ### MinIO Custom Access and Secret Keys using Docker secrets To override MinIO's auto-generated keys, you may pass secret and access keys explicitly by creating access and secret keys as [Docker secrets](https://docs.docker.com/engine/swarm/secrets/). MinIO server also allows regular strings as access and secret keys. ``` echo "AKIAIOSFODNN7EXAMPLE" | docker secret create access_key -
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Aug 12 18:20:36 UTC 2025 - 8.2K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/ConnectionSpec.kt
import okhttp3.internal.intersect /** * Specifies configuration for the socket connection that HTTP traffic travels through. For `https:` * URLs, this includes the TLS version and cipher suites to use when negotiating a secure * connection. * * The TLS versions configured in a connection spec are only be used if they are also enabled in the * SSL socket. For example, if an SSL socket does not have TLS 1.3 enabled, it will not be used even
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 13.4K bytes - Viewed (0) -
src/bufio/net_test.go
// TestCopyUnixpacket tests that we can use bufio when copying // across a unixpacket socket. This used to fail due to an unnecessary // empty Write call that was interpreted as an EOF. func TestCopyUnixpacket(t *testing.T) { tmpDir := t.TempDir() socket := filepath.Join(tmpDir, "unixsock") // Start a unixpacket server. addr := &net.UnixAddr{ Name: socket, Net: "unixpacket", } server, err := net.ListenUnix("unixpacket", addr)
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Fri Feb 07 19:37:07 UTC 2025 - 1.9K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt
assertThat(c1.socket().isClosed).isFalse() assertThat(c2.socket().isClosed).isFalse() // Add a third connection val c3 = factory.newConnection(pool, routeC1, 75L) // The third connection bounces the first. assertThat(pool.closeConnections(100L)).isEqualTo(0L) assertThat(pool.connectionCount()).isEqualTo(2) assertThat(c1.socket().isClosed).isTrue()
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 12.9K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerContextTest.java
*/ public void test_robotsTxtUrlSet() { Set<String> urlSet = crawlerContext.getRobotsTxtUrlSet(); assertNotNull(urlSet); assertTrue(urlSet instanceof LruHashSet); assertTrue(urlSet.isEmpty()); // Add URLs to default set urlSet.add("http://example.com/robots.txt"); urlSet.add("http://test.com/robots.txt");
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sat Sep 06 04:15:37 UTC 2025 - 25.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/SetsTest.java
assertEquals(ImmutableSortedSet.of(4, 6, 8, 10), Sets.subSet(set, Range.atLeast(4))); assertEquals(ImmutableSortedSet.of(8, 10), Sets.subSet(set, Range.atLeast(7))); assertEquals(empty, Sets.subSet(set, Range.atLeast(20))); assertEquals(set, Sets.subSet(set, Range.greaterThan(0))); assertEquals(ImmutableSortedSet.of(6, 8, 10), Sets.subSet(set, Range.greaterThan(4)));
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 45.3K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/Http2ConnectionTest.kt
val longString = repeat('a', Http2.INITIAL_MAX_FRAME_SIZE + 1) val socket = peer.openSocket() val connection = Http2Connection .Builder(true, TaskRunner.INSTANCE) .socket(socket.asBufferedSocket(), "peer") .pushObserver(IGNORE) .build() connection.start(sendConnectionPreface = false) socket.shutdownOutput() assertFailsWith<IOException> {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 75.5K bytes - Viewed (0) -
src/main/java/jcifs/netbios/NameServiceClientImpl.java
this.closeTimeout = Math.max(this.transportContext.getConfig().getNetbiosSoTimeout(), timeout); } // If socket is still good, the new closeTimeout will // be ignored; see tryClose comment. if (this.socket == null) { this.socket = new DatagramSocket(this.lport, this.laddr); this.thread = new Thread(this, "JCIFS-NameServiceClient");
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 38.5K bytes - Viewed (0)