- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for GetRequestCount (0.08 sec)
-
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
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jun 19 18:42:47 UTC 2024 - 6.1K bytes - Viewed (0) -
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 Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 4.6K bytes - Viewed (0) -
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) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 5.9K bytes - Viewed (0) -
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
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 03 21:59:45 UTC 2023 - 12.7K bytes - Viewed (0) -
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 Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jul 22 12:28:51 UTC 2023 - 10.2K bytes - Viewed (0) -
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()
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 13.3K bytes - Viewed (0)