Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 301 - 310 of 375 for LOOP (0.02 seconds)

  1. cmd/format-erasure_test.go

    		for j := range setDriveCount {
    			newFormat := format.Clone()
    			newFormat.Erasure.This = format.Erasure.Sets[i][j]
    			formats[i*setDriveCount+j] = newFormat
    		}
    	}
    
    	b.ReportAllocs()
    
    	for b.Loop() {
    		_, _ = getFormatErasureInQuorumOld(formats)
    	}
    }
    
    func BenchmarkGetFormatErasureInQuorum(b *testing.B) {
    	setCount := 200
    	setDriveCount := 15
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 12.7K bytes
    - Click Count (0)
  2. internal/s3select/json/preader_test.go

    			f, err := os.ReadFile(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				b.Fatal(err)
    			}
    			b.SetBytes(int64(len(f)))
    			b.ReportAllocs()
    			b.ResetTimer()
    			var record sql.Record
    			for b.Loop() {
    				r := NewPReader(io.NopCloser(bytes.NewBuffer(f)), &ReaderArgs{})
    				for {
    					record, err = r.Read(record)
    					if err != nil {
    						break
    					}
    				}
    				r.Close()
    				if err != io.EOF {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.5K bytes
    - Click Count (0)
  3. internal/s3select/json/reader_test.go

    			f, err := os.ReadFile(filepath.Join("testdata", file.Name()))
    			if err != nil {
    				b.Fatal(err)
    			}
    			b.SetBytes(int64(len(f)))
    			b.ReportAllocs()
    			b.ResetTimer()
    			var record sql.Record
    			for b.Loop() {
    				r := NewReader(io.NopCloser(bytes.NewBuffer(f)), &ReaderArgs{})
    				for {
    					record, err = r.Read(record)
    					if err != nil {
    						break
    					}
    				}
    				r.Close()
    				if err != io.EOF {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 2.4K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/collect/Lists.java

        if (size != otherList.size()) {
          return false;
        }
        if (thisList instanceof RandomAccess && otherList instanceof RandomAccess) {
          // avoid allocation and use the faster loop
          for (int i = 0; i < size; i++) {
            if (!Objects.equals(thisList.get(i), otherList.get(i))) {
              return false;
            }
          }
          return true;
        } else {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 16:38:09 GMT 2026
    - 42.1K bytes
    - Click Count (0)
  5. docs/de/docs/tutorial/server-sent-events.md

    Sie können auch normale `def`-Funktionen (ohne `async`) verwenden und `yield` genauso einsetzen.
    
    FastAPI stellt sicher, dass sie korrekt ausgeführt wird, sodass sie die Event Loop nicht blockiert.
    
    Da die Funktion in diesem Fall nicht async ist, wäre der passende Rückgabetyp `Iterable[Item]`:
    
    {* ../../docs_src/server_sent_events/tutorial001_py310.py ln[28:31] hl[29] *}
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 17:48:21 GMT 2026
    - 5.1K bytes
    - Click Count (0)
  6. docs/pt/docs/tutorial/server-sent-events.md

    Você também pode usar funções `def` normais (sem `async`) e usar `yield` da mesma forma.
    
    O FastAPI garantirá a execução correta para não bloquear o event loop.
    
    Como, neste caso, a função não é assíncrona, o tipo de retorno adequado seria `Iterable[Item]`:
    
    {* ../../docs_src/server_sent_events/tutorial001_py310.py ln[28:31] hl[29] *}
    
    ### Sem tipo de retorno { #no-return-type }
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Thu Mar 19 18:20:13 GMT 2026
    - 4.9K bytes
    - Click Count (0)
  7. cmd/benchmark-utils_test.go

    	sha256hex := ""
    
    	// benchmark utility which helps obtain number of allocations and bytes allocated per ops.
    	b.ReportAllocs()
    	// the actual benchmark for PutObject starts here. Reset the benchmark timer.
    
    	for i := 0; b.Loop(); i++ {
    		// insert the object.
    		objInfo, err := obj.PutObject(b.Context(), bucket, "object"+strconv.Itoa(i),
    			mustGetPutObjReader(b, bytes.NewReader(textData), int64(len(textData)), md5hex, sha256hex), ObjectOptions{})
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 8.1K bytes
    - Click Count (0)
  8. CHANGELOG.md

     *  Fix: Don't crash after a web socket fails its connection upgrade. We incorrectly released
        the web socket's connections back to the pool before their resources were cleaned up.
    
     *  Fix: Don't infinite loop when a received web socket message has self-terminating compressed
        data.
    
     *  Fix: Don't fail the call when the response code is ‘HTTP 102 Processing’ or ‘HTTP 103 Early
        Hints’.
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Sun Feb 15 11:57:47 GMT 2026
    - 36.2K bytes
    - Click Count (2)
  9. CHANGELOG/CHANGELOG-1.11.md

        * The vSphere cloud provider has a cleanup function with a loop,
        * inside of which a write lock was intended to prevent races against
        * VM creation, but the usage of the sync.RWMutex type is incorrect,
        * plus is placed in a defer call so the locking is effectively
        * nonexistent.  This patch adds an anonymous function call inside
        * the loop to correctly handle acquiring the write lock with deferred
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Feb 06 06:04:15 GMT 2020
    - 328.4K bytes
    - Click Count (0)
  10. android/guava-tests/test/com/google/common/util/concurrent/FuturesTest.java

        assertTrue(future1.wasInterrupted());
      }
    
      /**
       * Test the case where the futures are fulfilled prior to constructing the ListFuture. There was a
       * bug where the loop that connects a Listener to each of the futures would die on the last
       * loop-check as done() on ListFuture nulled out the variable being looped over (the list of
       * futures).
       */
      public void testAllAsList_doneFutures() throws Exception {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 134K bytes
    - Click Count (0)
Back to Top