Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 16 for brokers (0.07 seconds)

  1. cmd/bucket-replication.go

    	if (checkOld > 0 && len(p.workers) != checkOld) || n == len(p.workers) || n < 1 {
    		// Either already satisfied or worker count changed while we waited for the lock.
    		return
    	}
    	for len(p.workers) < n {
    		input := make(chan ReplicationWorkerOperation, 10000)
    		p.workers = append(p.workers, input)
    
    		go p.AddWorker(input, &p.activeWorkers)
    	}
    	for len(p.workers) > n {
    		worker := p.workers[len(p.workers)-1]
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 118.2K bytes
    - Click Count (0)
  2. .teamcity/test-buckets.json

              "platform-native",
              "plugin-development",
              "plugins-groovy",
              "plugins-java",
              "samples",
              "testing-native",
              "version-control",
              "workers"
            ],
            "parallelizationMethod": {
              "name": "TestDistribution"
            }
          }
        ]
      },
      {
        "testCoverageUuid": 2,
        "buckets": [
          {
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Mon Mar 23 18:38:15 GMT 2026
    - 118.6K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

      It did so indeed, and much sooner than she had expected:
    before she had drunk half the bottle, she found her head pressing
    against the ceiling, and had to stoop to save her neck from being
    broken.  She hastily put down the bottle, saying to herself
    `That's quite enough--I hope I shan't grow any more--As it is, I
    can't get out at the door--I do wish I hadn't drunk quite so
    much!'
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Apr 21 02:27:51 GMT 2017
    - 145.2K bytes
    - Click Count (0)
  4. okhttp/src/jvmMain/resources/okhttp3/internal/publicsuffix/PublicSuffixDatabase.list

    bozen.it
    bplaced.com
    bplaced.de
    bplaced.net
    br
    br.com
    br.it
    bradesco
    brand.se
    brasilia.me
    bremanger.no
    brescia.it
    bridgestone
    brindisi.it
    broadway
    broke-it.net
    broker
    broker.aero
    bronnoy.no
    bronnoysund.no
    brother
    browsersafetymark.io
    brumunddal.no
    brussels
    bryansk.su
    bryne.no
    brønnøy.no
    brønnøysund.no
    bs
    bs.it
    bsb.br
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue May 27 22:00:49 GMT 2025
    - 129.6K bytes
    - Click Count (3)
  5. src/main/webapp/js/admin/popper.min.js.map

    modifier;\n  rect.left += scrollLeft * modifier;\n  rect.right += scrollLeft * modifier;\n  return rect;\n}\n","/*\n * Helper to detect borders of a given element\n * @method\n * @memberof Popper.Utils\n * @param {CSSStyleDeclaration} styles\n * Result of `getStyleComputedProperty` on the given element\n * @param {String} axis - `x` or `y`\n * @return {number} borders - The borders size of the given axis\n */\n\nexport default function getBordersSize(styles, axis) {\n  const sideA = axis === 'x' ? 'Left' :...
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Oct 26 01:49:09 GMT 2024
    - 120.9K bytes
    - Click Count (0)
  6. cmd/metrics-v2.go

    		Help:      "Total number of active replication workers",
    		Type:      gaugeMetric,
    	}
    }
    
    func getClusterReplAvgActiveWorkersCountMD() MetricDescription {
    	return MetricDescription{
    		Namespace: nodeMetricNamespace,
    		Subsystem: replicationSubsystem,
    		Name:      avgActiveWorkers,
    		Help:      "Average number of active replication workers",
    		Type:      gaugeMetric,
    	}
    }
    
    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)
  7. guava-tests/test/com/google/common/io/testdata/alice_in_wonderland.txt

      It did so indeed, and much sooner than she had expected:
    before she had drunk half the bottle, she found her head pressing
    against the ceiling, and had to stoop to save her neck from being
    broken.  She hastily put down the bottle, saying to herself
    `That's quite enough--I hope I shan't grow any more--As it is, I
    can't get out at the door--I do wish I hadn't drunk quite so
    much!'
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Oct 29 21:35:03 GMT 2012
    - 145.2K bytes
    - Click Count (0)
  8. okhttp/src/androidMain/assets/PublicSuffixDatabase.list

    bozen.it
    bplaced.com
    bplaced.de
    bplaced.net
    br
    br.com
    br.it
    bradesco
    brand.se
    brasilia.me
    bremanger.no
    brescia.it
    bridgestone
    brindisi.it
    broadway
    broke-it.net
    broker
    broker.aero
    bronnoy.no
    bronnoysund.no
    brother
    browsersafetymark.io
    brumunddal.no
    brussels
    bryansk.su
    bryne.no
    brønnøy.no
    brønnøysund.no
    bs
    bs.it
    bsb.br
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Dec 31 14:50:53 GMT 2024
    - 129.6K bytes
    - Click Count (2)
  9. CHANGELOG/CHANGELOG-1.36.md

    - Added the metric terminated_containers_total to track the number of containers failed or succeeded broken down by exit code ([#137453](https://github.com/kubernetes/kubernetes/pull/137453), [@rawsocket](https://github.com/rawsocket)) [SIG Instrumentation, 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)
  10. okhttp/src/jvmTest/kotlin/okhttp3/URLConnectionTest.kt

        server.enqueue(mockResponse)
        val responseAfter = MockResponse(body = "This comes after a busted connection")
        server.enqueue(responseAfter)
        server.enqueue(responseAfter) // Enqueue 2x because the broken connection may be reused.
        val response1 = getResponse(newRequest("/a"))
        response1.body
          .source()
          .timeout()
          .timeout(100, TimeUnit.MILLISECONDS)
    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)
Back to Top