- Sort Score
- Num 10 results
- Language All
Results 231 - 240 of 1,298 for done (0.02 seconds)
-
cmd/data-scanner-metric.go
// Returns a function that can be used to update the current object // and a function to call to when processing finished. func (p *scannerMetrics) currentPathUpdater(disk, initial string) (update func(path string), done func()) { initialPtr := unsafe.Pointer(&initial) tracker := ¤tPathTracker{ name: &initialPtr, } p.currentPaths.Store(disk, tracker) return func(path string) {
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Oct 01 06:06:01 GMT 2025 - 9.4K bytes - Click Count (0) -
tests/associations_many2many_test.go
var wg sync.WaitGroup for i := 0; i < count; i++ { wg.Add(1) go func(user User, language Language) { err := db.Model(&user).Association("Languages").Append(&language) AssertEqual(t, err, nil) wg.Done() }(user, languages[i]) } wg.Wait() var find User err = db.Preload(clause.Associations).Where("id = ?", user.ID).First(&find).Error AssertEqual(t, err, nil)Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Sat Jun 10 13:05:19 GMT 2023 - 13.2K bytes - Click Count (0) -
tests/lru_test.go
lc := lru.NewLRU[string, string](0, nil, 0) wg := sync.WaitGroup{} wg.Add(1000) for i := 0; i < 1000; i++ { go func(i int) { lc.Add(fmt.Sprintf("key-%d", i/10), fmt.Sprintf("val-%d", i/10)) wg.Done() }(i) } wg.Wait() if lc.Len() != 100 { t.Fatalf("length differs from expected") } } func TestLRUInvalidateAndEvict(t *testing.T) { var evicted int
Created: Sun Dec 28 09:35:17 GMT 2025 - Last Modified: Mon Sep 08 09:19:22 GMT 2025 - 10.4K bytes - Click Count (0) -
internal/ioutil/ioutil.go
if pb != nil && len(*pb) == p.size { p.p.Put(pb) } } // WriteOnCloser implements io.WriteCloser and always // executes at least one write operation if it is closed. // // This can be useful within the context of HTTP. At least // one write operation must happen to send the HTTP headers // to the peer. type WriteOnCloser struct { io.Writer hasWritten bool }
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Tue Feb 18 16:25:55 GMT 2025 - 11.1K bytes - Click Count (0) -
docs/en/docs/alternatives.md
It is designed to have functions that receive two parameters, one "request" and one "response". Then you "read" parts from the request, and "write" parts to the response. Because of this design, it is not possible to declare request parameters and bodies with standard Python type hints as function parameters.
Created: Sun Dec 28 07:19:09 GMT 2025 - Last Modified: Sat Oct 11 17:48:49 GMT 2025 - 23.6K bytes - Click Count (0) -
cmd/data-scanner_test.go
Validity: 12 * time.Hour, LockEnabled: true, } expiryWorker := func(wg *sync.WaitGroup, readyCh chan<- struct{}, taskCh <-chan expiryOp, gotExpired *[]ObjectToDelete) { defer wg.Done() // signal the calling goroutine that the worker is ready tor receive tasks close(readyCh) var expired []ObjectToDelete for t := range taskCh { switch v := t.(type) { case noncurrentVersionsTask:
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Aug 29 02:39:48 GMT 2025 - 12K bytes - Click Count (0) -
docs/distributed/DESIGN.md
- Write and Read quorum are required to be satisfied only across the erasure set for an object. Healing is also done per object within the erasure set which contains the object.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Wed Feb 26 09:25:50 GMT 2025 - 8K bytes - Click Count (2) -
src/archive/tar/reader.go
if _, err := mustReadFull(tr.r, blk[:]); err != nil { return nil, err } s = blk.toSparse() continue } return spd, nil // Done } } // readGNUSparseMap1x0 reads the sparse map as stored in GNU's PAX sparse format // version 1.0. The format of the sparse map consists of a series of
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Oct 07 19:46:36 GMT 2025 - 26.9K bytes - Click Count (0) -
helm-releases/minio-4.0.11.tgz
exitCommand: "" ## List of buckets to be created after minio install ## buckets: # # Name of the bucket # - name: bucket1 # # Policy to be set on the # # bucket [none|download|upload|public] # policy: none # # Purge if bucket exists already # purge: false # # set versioning for # # bucket [true|false] # versioning: false # - name: bucket2 # policy: none # purge: false # versioning: true ## Additional Annotations for the Kubernetes Job makeBucketJob makeBucketJob: podAnnotations: annotations: securityContext:...
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Aug 07 05:41:47 GMT 2022 - 19.2K bytes - Click Count (0) -
helm-releases/minio-4.0.2.tgz
affinity: {} ## List of buckets to be created after minio install ## buckets: # # Name of the bucket # - name: bucket1 # # Policy to be set on the # # bucket [none|download|upload|public] # policy: none # # Purge if bucket exists already # purge: false # # set versioning for # # bucket [true|false] # versioning: false # - name: bucket2 # policy: none # purge: false # versioning: true ## Additional Annotations for the Kubernetes Job makeBucketJob makeBucketJob: podAnnotations: annotations: securityContext:...Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Mon May 09 04:25:47 GMT 2022 - 18K bytes - Click Count (0)