- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for GetRequestCount (0.06 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 serverRegistered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 6.5K 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 Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 4.6K bytes - Viewed (0) -
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 Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Jun 18 00:19:42 UTC 2025 - 4.6K bytes - Viewed (0)