Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for GetRequestCount (0.08 sec)

  1. cmd/background-heal-ops.go

    		}
    		if tmpMaxWait <= 0 {
    			return
    		}
    	}
    }
    
    func currentHTTPIO() int {
    	httpServer := newHTTPServerFn()
    	if httpServer == nil {
    		return 0
    	}
    
    	return httpServer.GetRequestCount() - activeListeners()
    }
    
    func waitForLowHTTPReq() {
    	maxIO, maxWait, _ := globalHealConfig.Clone()
    	waitForLowIO(maxIO, maxWait, currentHTTPIO)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/KotlinDeprecationErrorTest.kt

        mockWebServer.setBodyLimit(0L)
        mockWebServer.setProtocolNegotiationEnabled(false)
        mockWebServer.setProtocols(listOf(Protocol.HTTP_1_1))
        var requestCount: Int = mockWebServer.getRequestCount()
      }
    
      @Test @Disabled
      fun multipartBody() {
        val multipartBody: MultipartBody = MultipartBody.Builder().build()
        val type: MediaType = multipartBody.type()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  3. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt

      fun takeRequest(
        timeout: Long,
        unit: TimeUnit,
      ): RecordedRequest? = delegate.takeRequest(timeout, unit)?.unwrap()
    
      @JvmName("-deprecated_requestCount")
      fun getRequestCount(): Int = delegate.requestCount
    
      fun enqueue(response: MockResponse) {
        delegate.enqueue(response.wrap())
      }
    
      @Throws(IOException::class)
      @JvmOverloads
      fun start(port: Int = 0) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Jun 18 00:19:42 UTC 2025
    - 4.6K bytes
    - Viewed (0)
  4. mockwebserver/api/mockwebserver3.api

    	public final fun getPort ()I
    	public final fun getProtocolNegotiationEnabled ()Z
    	public final fun getProtocols ()Ljava/util/List;
    	public final fun getProxyAddress ()Ljava/net/Proxy;
    	public final fun getRequestCount ()I
    	public final fun getServerSocketFactory ()Ljavax/net/ServerSocketFactory;
    	public final fun getSocketAddress ()Ljava/net/InetSocketAddress;
    	public final fun getStarted ()Z
    	public final fun noClientAuth ()V
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  5. src/main/java/jcifs/util/SmbCircuitBreaker.java

                long maxResponseTime = 0;
    
                for (WindowBucket bucket : buckets) {
                    if (bucket.getLastUpdateTime() >= windowStartTime) {
                        totalRequests += bucket.getRequestCount();
                        totalFailures += bucket.getFailureCount();
                        totalResponseTime += bucket.getTotalResponseTime();
    
                        if (bucket.getMinResponseTime() < minResponseTime) {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 33.4K bytes
    - Viewed (0)
  6. mockwebserver-deprecated/api/mockwebserver.api

    	public final fun getDispatcher ()Lokhttp3/mockwebserver/Dispatcher;
    	public final fun getHostName ()Ljava/lang/String;
    	public final fun getPort ()I
    	public final fun getProtocolNegotiationEnabled ()Z
    	public final fun getRequestCount ()I
    	public final fun getServerSocketFactory ()Ljavax/net/ServerSocketFactory;
    	public final fun noClientAuth ()V
    	public final fun protocols ()Ljava/util/List;
    	public final fun requestClientAuth ()V
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Jul 22 12:28:51 UTC 2023
    - 10.2K bytes
    - Viewed (0)
Back to top