- Sort Score
- Num 10 results
- Language All
Results 301 - 310 of 375 for LOOP (0.02 seconds)
-
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 := 15Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12.7K bytes - Click Count (0) -
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) -
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) -
android/guava/src/com/google/common/collect/Lists.java
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) -
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) -
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) -
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) -
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) -
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 deferredCreated: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Thu Feb 06 06:04:15 GMT 2020 - 328.4K bytes - Click Count (0) -
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)