- Sort Score
- Result 10 results
- Languages All
Results 571 - 580 of 724 for Bucket (0.1 sec)
-
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
} else { eventListener.callEnd(this) } return result } /** * Remove this call from the connection's list of allocations. Returns a socket that the caller * should close. */ internal fun releaseConnectionNoEvents(): Socket? { val connection = this.connection!! connection.lock.assertHeld() val calls = connection.calls
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt
RecordedRequest( "", headersOf(), listOf(), 0L, Buffer(), 0, Socket(), ) recordedRequest = RecordedRequest("", headersOf(), listOf(), 0L, Buffer(), 0, Socket()) var requestUrl: HttpUrl? = recordedRequest.requestUrl var requestLine: String = recordedRequest.requestLine var method: String? = recordedRequest.method
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.3K bytes - Viewed (0) -
cmd/object-api-common.go
// requests based on RAM size for existing content. blockSizeV1 = 10 * humanize.MiByte // Block size used in erasure coding version 2. blockSizeV2 = 1 * humanize.MiByte // Buckets meta prefix. bucketMetaPrefix = "buckets" // Deleted Buckets prefix. deletedBucketsPrefix = ".deleted" // ETag (hex encoded md5sum) of empty string. emptyETag = "d41d8cd98f00b204e9800998ecf8427e" )
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 2.1K bytes - Viewed (0) -
cni/pkg/iptables/testdata/hostprobe_ipv6.golden
* nat -N ISTIO_POSTRT -A POSTROUTING -j ISTIO_POSTRT -A ISTIO_POSTRT -m owner --socket-exists -p tcp -m set --match-set istio-inpod-probes-v4 dst -j SNAT --to-source 169.254.7.127 COMMIT * nat -N ISTIO_POSTRT -A POSTROUTING -j ISTIO_POSTRT -A ISTIO_POSTRT -m owner --socket-exists -p tcp -m set --match-set istio-inpod-probes-v6 dst -j SNAT --to-source fd16:9254:7127:1337:ffff:ffff:ffff:ffff
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Sep 25 20:54:34 UTC 2024 - 399 bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/platform/Platform.kt
return session.requestedServerNames.mapNotNull { (it as? SNIHostName)?.asciiName } } @Throws(IOException::class) open fun connectSocket( socket: Socket, address: InetSocketAddress, connectTimeout: Int, ) { socket.connect(address, connectTimeout) } open fun log( message: String, level: Int = INFO, t: Throwable? = null, ) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.8K bytes - Viewed (0) -
samples/unixdomainsockets/src/main/java/okhttp3/unixdomainsockets/UnixDomainServerSocketFactory.java
serverSocketChannel.configureBlocking(true); serverSocketChannel.socket().bind(address); } @Override public int getLocalPort() { return 1; // A white lie. There is no local port. } @Override public SocketAddress getLocalSocketAddress() { return endpoint; } @Override public Socket accept() throws IOException { try {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Feb 12 16:33:52 UTC 2019 - 3.1K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/ServerTruncatesRequestTest.kt
val eventListener = object : EventListener() { var socket: SSLSocket? = null var closed = false override fun connectionAcquired( call: Call, connection: Connection, ) { socket = connection.socket() as SSLSocket } override fun requestHeadersStart(call: Call) { if (closed) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 9.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/RateLimiter.java
* permits per second: * * <pre>{@code * final RateLimiter rateLimiter = RateLimiter.create(5000.0); // rate = 5000 permits per second * void submitPacket(byte[] packet) { * rateLimiter.acquire(packet.length); * networkService.send(packet); * } * }</pre> * * <p>It is important to note that the number of permits requested <i>never</i> affects the
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:51:36 UTC 2024 - 21.9K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestValueFactory.kt
): RealConnection { val result = RealConnection.newTestConnection( taskRunner = taskRunner, connectionPool = pool, route = route, socket = Socket(), idleAtNs = idleAtNanos, ) result.withLock { pool.put(result) } return result } fun newConnectionPool( taskRunner: TaskRunner = this.taskRunner,
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 7.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/NbtSocket.java
*/ package jcifs.smb1.netbios; import java.net.Socket; import jcifs.smb1.Config; import jcifs.smb1.util.LogStream; import java.net.InetAddress; import java.io.InputStream; import java.io.OutputStream; import java.io.IOException; /** Do not use this class. Writing to the OutputStream of this type of socket requires leaving a 4 byte prefix for the NBT header. IOW you must call
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 4.8K bytes - Viewed (0)