- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for GetRequestCount (0.76 seconds)
-
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 serverCreated: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 6.5K bytes - Click Count (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) {
Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Wed Jun 18 00:19:42 GMT 2025 - 4.6K bytes - Click Count (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) }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue May 27 15:19:03 GMT 2025 - 4.6K bytes - Click Count (0)