Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 50 for fillReq (0.05 sec)

  1. internal/s3select/jstream/scanner.go

    	buf       [chunk + 1]byte // internal buffer (with a lookback size of 1)
    	nbuf      [chunk]byte     // next internal buffer
    	fillReq   chan struct{}
    	fillReady chan int64
    	readerErr error // underlying reader error, if any
    }
    
    func newScanner(r io.Reader) *scanner {
    	sr := &scanner{
    		end:       maxInt,
    		fillReq:   make(chan struct{}),
    		fillReady: make(chan int64),
    	}
    
    	go func() {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  2. docs/debugging/xl-meta/main.go

    					fmt.Printf("Data overlaps (%d bytes). Combining with %q.\n", ok, otherKey)
    					for i := range otherM.filled {
    						if otherM.filled[i] == 1 {
    							m.filled[i] = 1
    							m.mapped[i] = otherM.mapped[i]
    						}
    					}
    				}
    
    				lastValid := 0
    				missing := 0
    				for i := range m.filled {
    					if m.filled[i] == 1 {
    						lastValid = i
    					} else {
    						missing++
    					}
    				}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 40.4K bytes
    - Viewed (0)
  3. cmd/storage-rest-server.go

    				// concurrently, check for it before we
    				// write the filler byte.
    				select {
    				case err := <-doneCh:
    					if err != nil {
    						write([]byte{1})
    						write([]byte(err.Error()))
    					} else {
    						write([]byte{0})
    					}
    					return
    				default:
    				}
    
    				// Response not ready, write a filler byte.
    				write([]byte{32})
    				if canWrite {
    					xhttp.Flush(w)
    				}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 45.7K bytes
    - Viewed (0)
  4. ISSUES.md

    1.  It must be a bug/performance issue or a feature request or a build issue or
        a documentation issue (for small doc fixes please send a PR instead).
    1.  Make sure the Issue Template is filled out.
    1.  The issue should be related to the repo it is created in.
    
    **Here's why we have this policy:** We want to focus on the work that benefits
    the whole community, e.g., fixing bugs and adding features. Individual support
    Registered: Tue Dec 30 12:39:10 UTC 2025
    - Last Modified: Thu Feb 11 22:37:27 UTC 2021
    - 606 bytes
    - Viewed (0)
  5. internal/logger/message/audit/entry.go

    	xhttp "github.com/minio/minio/internal/http"
    )
    
    // Version - represents the current version of audit log structure.
    const Version = "1"
    
    // NewEntry - constructs an audit entry object with some fields filled
    func NewEntry(deploymentID string) audit.Entry {
    	return audit.Entry{
    		Version:      Version,
    		DeploymentID: deploymentID,
    		Time:         time.Now().UTC(),
    	}
    }
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 2.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/collect/RegularImmutableBiMap.java

        @Nullable ImmutableMapEntry<K, V>[] keyTable = createEntryArray(tableSize);
        @Nullable ImmutableMapEntry<K, V>[] valueTable = createEntryArray(tableSize);
        /*
         * The cast is safe: n==entryArray.length means that we have filled the whole array with Entry
         * instances, in which case it is safe to cast it from an array of nullable entries to an array
         * of non-null entries.
         */
        @SuppressWarnings("nullness")
        Entry<K, V>[] entries =
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 21:07:18 UTC 2025
    - 11K bytes
    - Viewed (0)
  7. cmd/admin-server-info.go

    	gcStats := debug.GCStats{
    		// If stats.PauseQuantiles is non-empty, ReadGCStats fills
    		// it with quantiles summarizing the distribution of pause time.
    		// For example, if len(stats.PauseQuantiles) is 5, it will be
    		// filled with the minimum, 25%, 50%, 75%, and maximum pause times.
    		PauseQuantiles: make([]time.Duration, 5),
    	}
    	debug.ReadGCStats(&gcStats)
    	// Truncate GC stats to max 5 entries.
    	if len(gcStats.PauseEnd) > 5 {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (1)
  8. tests/non_std_test.go

    		t.Error("RowsAffected should be correct when do batch update")
    	}
    
    	animal = Animal{From: "somewhere"}              // No name fields, should be filled with the default value (galeone)
    	DB.Save(&animal).Update("From", "a nice place") // The name field should be untouched
    	DB.First(&animal, animal.Counter)
    	if animal.Name != "galeone" {
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Wed May 08 04:07:58 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/ImmutableSortedMap.java

                    // requireNonNull is safe because the first `size` elements have been filled in.
                    requireNonNull(e1);
                    requireNonNull(e2);
                    return comparator.compare(e1.getKey(), e2.getKey());
                  });
              // requireNonNull is safe because the first `size` elements have been filled in.
              Entry<K, V> firstEntry = requireNonNull(entryArray[0]);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 21:07:18 UTC 2025
    - 52.9K bytes
    - Viewed (0)
  10. fess-crawler/src/test/java/org/codelibs/fess/crawler/exception/CrawlerSystemExceptionTest.java

            assertNotNull(originalStackTrace);
            assertTrue(originalStackTrace.length > 0);
    
            // Fill in stack trace again
            Throwable filled = exception.fillInStackTrace();
            assertSame(exception, filled);
    
            StackTraceElement[] newStackTrace = exception.getStackTrace();
            assertNotNull(newStackTrace);
            assertTrue(newStackTrace.length > 0);
        }
    
        /**
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Wed Sep 03 14:42:53 UTC 2025
    - 20K bytes
    - Viewed (0)
Back to top