Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 31 - 40 of 300 for brokers (0.05 seconds)

  1. build-logic-commons/code-quality-rules/src/main/resources/checkstyle/suppressions.xml

        <!-- These packages are duplicated in workers and daemon-server-worker, don't require a package-info.java in each place -->
        <suppress checks="JavadocPackage"
                  files=".*[/\\]platforms[/\\]core-execution[/\\]daemon-server-worker[/\\]src[/\\]main[/\\]java[/\\]org[/\\]gradle[/\\]workers[/\\][^/\\]+"/>
    
        <!-- These packages are duplicated in code-quality and code-quality-workers, don't require a package-info.java in each place -->
    Created: Wed Apr 01 11:36:16 GMT 2026
    - Last Modified: Thu Mar 19 16:48:15 GMT 2026
    - 13.5K bytes
    - Click Count (0)
  2. cmd/data-scanner_test.go

    		t.Run(fmt.Sprintf("TestApplyNewerNoncurrentVersionsLimit-%d", i), func(t *testing.T) {
    			workers := []chan expiryOp{make(chan expiryOp)}
    			es.workers.Store(&workers)
    			workerReady := make(chan struct{})
    			var wg sync.WaitGroup
    			wg.Add(1)
    			var gotExpired []ObjectToDelete
    			go expiryWorker(&wg, workerReady, workers[0], &gotExpired)
    			<-workerReady
    
    			item := scannerItem{
    				Path:        obj,
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12K bytes
    - Click Count (0)
  3. okhttp/src/jvmTest/kotlin/okhttp3/FormBodyTest.kt

        assertThat(formEncode(8)).isEqualTo("%08")
        assertThat(formEncode(9)).isEqualTo("%09")
        // Browsers convert '\n' to '\r\n'
        assertThat(formEncode(10)).isEqualTo("%0A")
        assertThat(formEncode(11)).isEqualTo("%0B")
        assertThat(formEncode(12)).isEqualTo("%0C")
        // Browsers convert '\r' to '\r\n'
        assertThat(formEncode(13)).isEqualTo("%0D")
        assertThat(formEncode(14)).isEqualTo("%0E")
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Mar 19 19:25:20 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  4. docs/en/docs/deployment/docker.md

    So, in this case, you **would not** want to have a multiple workers in the container, for example with the `--workers` command line option. You would want to have just a **single Uvicorn process** per container (but probably multiple containers).
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 05 18:13:19 GMT 2026
    - 28.3K bytes
    - Click Count (1)
  5. .ci/scripts/run-gradle.sh

       else
          echo "Unsupported OS Type: $OSTYPE"
          exit 1
       fi
    fi
    if pwd | grep -v -q ^/dev/shm ; then
       echo "Not running on a ramdisk, reducing number of workers"
       MAX_WORKERS=$(($MAX_WORKERS*2/3))
    fi
    set -e
    Created: Wed Apr 08 16:19:15 GMT 2026
    - Last Modified: Thu May 13 19:08:52 GMT 2021
    - 824 bytes
    - Click Count (0)
  6. .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)
  7. docs/fr/docs/deployment/docker.md

    Donc, dans ce cas, vous **ne voudrez pas** avoir plusieurs workers dans le conteneur, par exemple avec l'option de ligne de commande `--workers`. Vous voudrez avoir **un seul processus Uvicorn** par conteneur (mais probablement plusieurs conteneurs).
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:37:13 GMT 2026
    - 32.3K bytes
    - Click Count (0)
  8. tests/test_dependency_after_yield_streaming.py

        def iter_data():
            yield from session
    
        return StreamingResponse(iter_data())
    
    
    @app.get("/broken-session-data")
    def get_broken_session_data(session: BrokenSessionDep) -> Any:
        return list(session)
    
    
    @app.get("/broken-session-stream")
    def get_broken_session_stream(session: BrokenSessionDep) -> Any:
        def iter_data():
            yield from session
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Wed Dec 17 21:25:59 GMT 2025
    - 3.2K bytes
    - Click Count (0)
  9. docs/config/README.md

    replication_max_workers         (number)    set the maximum number of replication workers (default: '500')
    replication_max_lrg_workers     (number)    set the maximum number of replication workers MinIO uses to replicate large objects between sites. (default: '10')
    transition_workers              (number)    set the number of transition workers (default: '100')
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Tue Aug 12 18:20:36 GMT 2025
    - 18.1K bytes
    - Click Count (1)
  10. guava-tests/test/com/google/common/collect/AbstractSequentialIteratorTest.java

      }
    
      public void testBroken() {
        Iterator<Object> broken = new BrokenAbstractSequentialIterator();
        assertTrue(broken.hasNext());
        // We can't retrieve even the known first element:
        assertThrows(SomeUncheckedException.class, broken::next);
        assertThrows(SomeUncheckedException.class, broken::next);
      }
    
      private static Iterator<Integer> newDoubler(int first, int last) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 4.7K bytes
    - Click Count (0)
Back to Top