Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 27 for fillReq (0.13 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 Oct 27 19:28:09 UTC 2024
    - 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K 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 {
    					w.(http.Flusher).Flush()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  4. 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 2.2K bytes
    - Viewed (0)
  5. 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 Oct 29 12:39:09 UTC 2024
    - Last Modified: Thu Feb 11 22:37:27 UTC 2021
    - 606 bytes
    - Viewed (0)
  6. 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 Oct 27 09:35:08 UTC 2024
    - Last Modified: Wed May 08 04:07:58 UTC 2024
    - 1.9K 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 Oct 27 19:28:09 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  8. tensorflow/c/eager/parallel_device/parallel_device.h

    // `underlying_devices` and `b` on the second. Running `a_unpacked, b_unpacked =
    // TPUReplicatedOutput(input=x, num_replicas=2)` un-packs the parallel tensor
    // into its components.
    //
    // The filled `device` struct and the allocated `device_info` struct may be
    // passed to TFE_RegisterCustomDevice. The `device_name` arguments must match.
    void AllocateParallelDevice(const char* device_name,
    Registered: Tue Oct 29 12:39:09 UTC 2024
    - Last Modified: Thu Jun 04 21:49:16 UTC 2020
    - 2.9K bytes
    - Viewed (0)
  9. cmd/globals.go

    	// Maximum size of default bucket encryption configuration allowed
    	maxBucketSSEConfigSize = 1 * humanize.MiByte
    
    	// diskFillFraction is the fraction of a disk we allow to be filled.
    	diskFillFraction = 0.99
    
    	// diskReserveFraction is the fraction of a disk where we will fill other server pools first.
    	// If all pools reach this, we will use all pools with regular placement.
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  10. fastapi/security/oauth2.py

        """
    
        def __init__(
            self,
            scopes: Annotated[
                Optional[List[str]],
                Doc(
                    """
                    This will be filled by FastAPI.
                    """
                ),
            ] = None,
        ):
            self.scopes: Annotated[
                List[str],
                Doc(
                    """
    Registered: Sun Oct 27 07:19:11 UTC 2024
    - Last Modified: Wed Oct 23 18:30:18 UTC 2024
    - 21.1K bytes
    - Viewed (0)
Back to top