Search Options

Results per page
Sort
Preferred Languages
Advance

Results 571 - 580 of 724 for Bucket (0.1 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top