- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for numRequests (0.09 sec)
-
pkg/test/loadbalancersim/mesh/client.go
func (c *Client) SendRequests(conn network.Connection, numRequests int, done func()) { go func() { wg := sync.WaitGroup{} interval := time.Duration((1.0 / float64(c.s.RPS)) * float64(time.Second)) ticker := time.NewTicker(interval) for { // Wait for to send the next request. <-ticker.C // Send a request wg.Add(1) conn.Request(wg.Done) numRequests-- if numRequests <= 0 { ticker.Stop()
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Feb 03 18:19:25 UTC 2022 - 1.5K bytes - Viewed (0) -
src/database/sql/sql.go
func (db *DB) maybeOpenNewConnections() { numRequests := db.connRequests.Len() if db.maxOpen > 0 { numCanOpen := db.maxOpen - db.numOpen if numRequests > numCanOpen { numRequests = numCanOpen } } for numRequests > 0 { db.numOpen++ // optimistically numRequests-- if db.closed { return } db.openerCh <- struct{}{} } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 01:16:53 UTC 2024 - 103.6K bytes - Viewed (0) -
tensorflow/c/experimental/filesystem/plugins/gcs/ram_file_block_cache_test.cc
const size_t block_size = 16; int num_requests = 0; Notification notification; auto fetcher = [&num_requests, ¬ification, block_size]( const string& filename, size_t offset, size_t n, char* buffer, TF_Status* status) -> int64_t { EXPECT_EQ(n, block_size); EXPECT_EQ(offset, 0); num_requests++; memset(buffer, 'x', n); notification.Notify();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Oct 15 03:16:57 UTC 2021 - 23.2K bytes - Viewed (0)