Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for getRequestCount (0.26 sec)

  1. internal/http/server.go

    	inShutdown      uint32        // indicates whether the server is in shutdown or not
    	requestCount    int32         // counter holds no. of request in progress.
    }
    
    // GetRequestCount - returns number of request in progress.
    func (srv *Server) GetRequestCount() int {
    	return int(atomic.LoadInt32(&srv.requestCount))
    }
    
    // Init - init HTTP server
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Feb 09 21:25:16 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  2. mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/MockWebServer.kt

      }
    
      @JvmName("-deprecated_requestCount")
      @Deprecated(
        message = "moved to val",
        replaceWith = ReplaceWith(expression = "requestCount"),
        level = DeprecationLevel.ERROR,
      )
      fun getRequestCount(): Int = delegate.requestCount
    
      fun enqueue(response: MockResponse) {
        delegate.enqueue(response.wrap())
      }
    
      @Throws(IOException::class)
      @JvmOverloads
      fun start(port: Int = 0) {
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Tue Jan 23 14:31:42 GMT 2024
    - 5.9K bytes
    - Viewed (0)
  3. 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)
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 4.6K bytes
    - Viewed (0)
  4. 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
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Sat Jul 22 12:28:51 GMT 2023
    - 10.2K bytes
    - Viewed (0)
  5. okhttp/src/test/java/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()
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 13.3K bytes
    - Viewed (0)
  6. mockwebserver/api/mockwebserver3.api

    	public final fun getInetSocketAddress ()Ljava/net/InetSocketAddress;
    	public final fun getPort ()I
    	public final fun getProtocolNegotiationEnabled ()Z
    	public final fun getProtocols ()Ljava/util/List;
    	public final fun getRequestCount ()I
    	public final fun getServerSocketFactory ()Ljavax/net/ServerSocketFactory;
    	public final fun getStarted ()Z
    	public final fun noClientAuth ()V
    	public final fun requestClientAuth ()V
    Plain Text
    - Registered: Fri Apr 26 11:42:10 GMT 2024
    - Last Modified: Tue Jan 03 21:59:45 GMT 2023
    - 12.7K bytes
    - Viewed (0)
Back to top