- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for fillReq (0.12 sec)
-
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) -
docs/debugging/xl-meta/main.go
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Thu Sep 05 11:57:44 UTC 2024 - 40.3K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
fastapi/security/oauth2.py
Registered: Sun Oct 27 07:19:11 UTC 2024 - Last Modified: Wed Oct 23 18:30:18 UTC 2024 - 21.1K bytes - Viewed (0) -
cmd/background-newdisks-heal-ops.go
ResumeItemsSkipped uint64 `json:"-"` ResumeBytesDone uint64 `json:"-"` ResumeBytesFailed uint64 `json:"-"` ResumeBytesSkipped uint64 `json:"-"` // Filled on startup/restarts. QueuedBuckets []string // Filled during heal. HealedBuckets []string // ID of the current healing operation HealID string ItemsSkipped uint64 BytesSkipped uint64 RetryAttempts uint64
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Sat Oct 26 09:58:27 UTC 2024 - 16.6K bytes - Viewed (0) -
ci/official/README.md
TensorFlow's official CI jobs run the scripts in this folder. Our internal CI system, Kokoro, schedules our CI jobs by combining a build script with a file from the `envs` directory that is filled with configuration options: - Nightly jobs (Run nightly on the `nightly` branch) - Uses `wheel.sh`, `libtensorflow.sh`, `code_check_full.sh` - Continuous jobs (Run on every GitHub commit) - Uses `pycpp.sh`
Registered: Tue Oct 29 12:39:09 UTC 2024 - Last Modified: Thu Feb 01 03:21:19 UTC 2024 - 8K bytes - Viewed (0)