- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for pool_id (0.15 sec)
-
cmd/erasure-server-pool.go
Maintenance: opts.Maintenance, SetID: setIdx, PoolID: poolIdx, Healthy: erasureSetUpCount[poolIdx][setIdx].online >= poolWriteQuorums[poolIdx], HealthyRead: erasureSetUpCount[poolIdx][setIdx].online >= poolReadQuorums[poolIdx], HealthyDrives: erasureSetUpCount[poolIdx][setIdx].online, HealingDrives: erasureSetUpCount[poolIdx][setIdx].healing, ReadQuorum: poolReadQuorums[poolIdx],
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/xl-storage.go
return time.Time{} } func (s *xlStorage) IsLocal() bool { return true } // Retrieve location indexes. func (s *xlStorage) GetDiskLoc() (poolIdx, setIdx, diskIdx int) { return s.endpoint.PoolIdx, s.endpoint.SetIdx, s.endpoint.DiskIdx } func (s *xlStorage) Healing() *healingTracker { healingFile := pathJoin(s.drivePath, minioMetaBucket, bucketMetaPrefix, healingTrackerFilename)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sun Apr 28 17:53:50 GMT 2024 - 84.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/http2/HttpOverHttp2Test.kt
// Second call attempts the pooled connection, and it fails. Then it retries a new route which // succeeds. val response2 = client.newCall(request).execute() assertThat(response2.body.string()).isEqualTo("abc") assertThat(server.takeRequest().sequenceNumber).isEqualTo(1) // Pooled connection. assertThat(server.takeRequest().sequenceNumber).isEqualTo(0) // New connection.
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 75.3K bytes - Viewed (0) -
cmd/test-utils_test.go
return certOut.Bytes(), keyOut.Bytes(), nil } func mustGetPoolEndpoints(poolIdx int, args ...string) EndpointServerPools { drivesPerSet := len(args) setCount := 1 if len(args) >= 16 { drivesPerSet = 16 setCount = len(args) / 16 } endpoints := mustGetNewEndpoints(poolIdx, drivesPerSet, args...) return []PoolEndpoints{{ SetCount: setCount, DrivesPerSet: drivesPerSet,
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 17:26:51 GMT 2024 - 76.2K bytes - Viewed (0) -
cmd/peer-rest-server.go
objAPI := newObjectLayerFn() if objAPI == nil { return np, grid.NewRemoteErr(errServerNotInitialized) } pools, ok := objAPI.(*erasureServerPools) if !ok { return np, grid.NewRemoteErr(errors.New("not a pooled setup")) } pools.StopRebalance() return } func (s *peerRESTServer) LoadRebalanceMetaHandler(mss *grid.MSS) (np grid.NoPayload, nerr *grid.RemoteErr) { objAPI := newObjectLayerFn()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
docs/changelogs/changelog_3x.md
new in this release. Pings are used for connections that are busy carrying calls and for idle connections in the connection pool. (Pings do not impact when pooled connections are evicted). If you have a configured ping interval, you should confirm that it is long enough for a roundtrip from client to server. If your ping interval is too
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sun Feb 06 14:55:54 GMT 2022 - 50.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
val requestBodyDelay = 250L val responseHeadersStartDelay = 250L val responseBodyStartDelay = 250L val responseBodyEndDelay = 250L // Warm up the client so the timing part of the test gets a pooled connection. server.enqueue(MockResponse()) val warmUpCall = client.newCall( Request.Builder() .url(server.url("/")) .build(), )
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Jan 20 10:30:28 GMT 2024 - 56.9K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/OkHttpClient.kt
* failure to reach any individual IP address doesn't fail the overall request. This can * increase availability of multi-homed services. * * * **Stale pooled connections.** The [ConnectionPool] reuses sockets * to decrease request latency, but these connections will occasionally time out. * * * **Unreachable proxy servers.** A [ProxySelector] can be used to
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 06 04:21:33 GMT 2024 - 52K bytes - Viewed (0) -
cmd/xl-storage_test.go
// Initialize a new storage disk. func newLocalXLStorageWithDiskIdx(path string, diskIdx int) (*xlStorage, error) { u := url.URL{Path: path} return newXLStorage(Endpoint{ URL: &u, IsLocal: true, PoolIdx: 0, SetIdx: 0, DiskIdx: diskIdx, }, true) } // creates a temp dir and sets up xlStorage layer. // returns xlStorage layer, temp dir path to be used for the purpose of tests.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 11 17:45:28 GMT 2024 - 66.7K bytes - Viewed (0)