Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 9 of 9 for poolId (0.23 seconds)

  1. 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,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 133.6K bytes
    - Click Count (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

          expected.assertSuppressed { throwables: List<Throwable>? ->
            assertThat(throwables!!.size).isEqualTo(1)
          }
        }
      }
    
      /**
       * When a pooled connection fails, don't blame the route. Otherwise pooled connection failures can
       * cause unnecessary SSL fallbacks.
       *
       * https://github.com/square/okhttp/issues/515
       */
      @Test
      fun sslFallbackNotUsedWhenRecycledConnectionFails() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 133.3K bytes
    - Click Count (0)
  3. cmd/admin-handlers.go

    			// No ellipses pattern. Anonymize host name from every pool arg
    			pools := strings.Fields(poolsArgs)
    			anonPools = make([]string, len(pools))
    			for index, arg := range pools {
    				anonPools[index] = anonAddr(arg)
    			}
    			return cmdLineWithoutPools + strings.Join(anonPools, " ")
    		}
    
    		// Ellipses pattern in pool args. Regex groups:
    		// 1 - server prefix
    		// 2 - number sequence for servers
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 99.7K bytes
    - Click Count (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt

            ).build()
        assertThat(client.retryOnConnectionFailure).isTrue()
        executeSynchronously("/").assertBody("seed connection pool")
        executeSynchronously("/").assertBody("retry success")
    
        // The call that seeds the connection pool.
        eventRecorder.removeUpToEvent(CallEnd::class.java)
    
        // The ResponseFailed event is not necessarily fatal!
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Mar 15 09:02:18 GMT 2026
    - 146.5K bytes
    - Click Count (0)
  5. src/main/java/jcifs/smb/SmbFile.java

                    // for scenarios where the same file or directory is accessed multiple times
                    log.trace("Tree handle released to connection pool for reuse");
                    // The connection pool will handle cleanup based on its own timeout settings
                }
            }
    
            // Clear attribute cache only if we're doing strict cleanup
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 103.2K bytes
    - Click Count (0)
  6. api/go1.3.txt

    pkg regexp/syntax, method (InstOp) String() string
    pkg runtime/debug, func SetPanicOnFault(bool) bool
    pkg runtime/debug, func WriteHeapDump(uintptr)
    pkg sync, method (*Pool) Get() interface{}
    pkg sync, method (*Pool) Put(interface{})
    pkg sync, type Pool struct
    pkg sync, type Pool struct, New func() interface{}
    pkg syscall (darwin-386), func FcntlFlock(uintptr, int, *Flock_t) error
    pkg syscall (darwin-386), func Mlock([]uint8) error
    Created: Tue Apr 07 11:13:11 GMT 2026
    - Last Modified: Mon Jun 02 02:45:00 GMT 2014
    - 117K bytes
    - Click Count (0)
  7. okhttp/src/jvmTest/kotlin/okhttp3/CacheTest.kt

        assertThat(recordedRequest2.connectionIndex).isEqualTo(0)
        assertThat(recordedRequest2.exchangeIndex).isEqualTo(1)
    
        // an unrelated request should reuse the pooled connection
        val request3 = Request.Builder().url(server.url("/baz")).build()
        val response3 = client.newCall(request3).execute()
        assertThat(response3.body.string()).isEqualTo("DEF")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Fri Mar 20 09:13:37 GMT 2026
    - 121K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

            }
            throw new SearchEngineClientException("client is not HttpClient.");
        }
    
        //
        // Fesen Client
        //
    
        /**
         * Gets the thread pool used by the client.
         *
         * @return the thread pool
         */
        @Override
        public ThreadPool threadPool() {
            return client.threadPool();
        }
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 14:36:23 GMT 2026
    - 138.6K bytes
    - Click Count (1)
  9. CHANGELOG/CHANGELOG-1.36.md

    - Introduce index-based naming in ResourceSlice controller and ensure ResourceSlices and pools are sorted lexicographically before allocation, allowing users to control allocation priority. ([#136641](https://github.com/kubernetes/kubernetes/pull/136641), [@troychiu](https://github.com/troychiu)) [SIG Node and Testing]
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Mar 19 23:38:00 GMT 2026
    - 142.1K bytes
    - Click Count (0)
Back to Top