Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 55 for pool_id (0.3 sec)

  1. cmd/erasure-multipart.go

    	result.Delimiter = delimiter
    
    	var uploadIDs []string
    	var disk StorageAPI
    	disks := er.getOnlineLocalDisks()
    	if len(disks) == 0 {
    		// using er.getOnlineLocalDisks() has one side-affect where
    		// on a pooled setup all disks are remote, add a fallback
    		disks = er.getOnlineDisks()
    	}
    	for _, disk = range disks {
    		if disk == nil {
    			continue
    		}
    		if !disk.IsOnline() {
    			continue
    		}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  2. internal/grid/handlers.go

    func (h *SingleHandler[Req, Resp]) PutResponse(r Resp) {
    	h.recycleResp(r)
    }
    
    // AllowCallRequestPool indicates it is safe to reuse the request
    // on the client side, meaning the request is recycled/pooled when a request is sent.
    // CAREFUL: This should only be used when there are no pointers, slices that aren't freshly constructed.
    func (h *SingleHandler[Req, Resp]) AllowCallRequestPool(b bool) *SingleHandler[Req, Resp] {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 27.1K bytes
    - Viewed (0)
  3. cmd/xl-storage-disk-id-check.go

    	}
    
    	weSleep := func() bool {
    		return scannerIdleMode.Load() == 0
    	}
    
    	return p.storage.NSScanner(ctx, cache, updates, scanMode, weSleep)
    }
    
    func (p *xlStorageDiskIDCheck) GetDiskLoc() (poolIdx, setIdx, diskIdx int) {
    	return p.storage.GetDiskLoc()
    }
    
    func (p *xlStorageDiskIDCheck) Close() error {
    	p.diskCancel()
    	return p.storage.Close()
    }
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  4. 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)
  5. okhttp/src/test/java/okhttp3/CallTest.kt

        assertThat(server.takeRequest().sequenceNumber).isEqualTo(2)
      }
    
      /**
       * Each OkHttpClient used to get its own instance of NullProxySelector, and because these weren't
       * equal their connections weren't pooled. That's a nasty performance bug!
       *
       * https://github.com/square/okhttp/issues/5519
       */
      @Test
      fun connectionPoolingWithFreshClientSamePool() {
        server.enqueue(MockResponse(body = "abc"))
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Wed Apr 10 19:46:48 GMT 2024
    - 142.5K bytes
    - Viewed (0)
  6. cmd/notification.go

    			if offlineHost == "" && ep.IsLocal || offlineHost == ep.Host {
    				offlineDisks = append(offlineDisks, madmin.Disk{
    					Endpoint:  ep.String(),
    					State:     string(madmin.ItemOffline),
    					PoolIndex: ep.PoolIdx,
    					SetIndex:  ep.SetIdx,
    					DiskIndex: ep.DiskIdx,
    				})
    			}
    		}
    	}
    	return offlineDisks
    }
    
    // StorageInfo returns disk information across all peers
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  7. cmd/admin-handlers.go

    	hostAnonymizer := map[string]string{}
    	hosts := set.NewStringSet()
    	srvrIdx := 0
    
    	for poolIdx, pool := range globalEndpoints {
    		for _, endpoint := range pool.Endpoints {
    			if !hosts.Contains(endpoint.Host) {
    				hosts.Add(endpoint.Host)
    				srvrIdx++
    			}
    			anonymizeHost(hostAnonymizer, endpoint, poolIdx+1, srvrIdx)
    		}
    	}
    	return hostAnonymizer
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 29 17:39:04 GMT 2024
    - 97.8K bytes
    - Viewed (2)
  8. 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)
  9. 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)
  10. cmd/metrics-v2.go

    			Description: getClusterHealthStatusMD(),
    			Value:       float64(health),
    		})
    
    		for _, h := range result.ESHealth {
    			labels := map[string]string{
    				"pool": strconv.Itoa(h.PoolID),
    				"set":  strconv.Itoa(h.SetID),
    			}
    			metrics = append(metrics, MetricV2{
    				Description:    getClusterErasureSetReadQuorumMD(),
    				VariableLabels: labels,
    				Value:          float64(h.ReadQuorum),
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 25 22:01:31 GMT 2024
    - 132.6K bytes
    - Viewed (0)
Back to top