Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 2 of 2 for simultaneously (0.05 seconds)

  1. cmd/erasure-server-pool.go

    	case <-ctx.Done():
    		mu.Lock()
    		if firstErr == nil {
    			firstErr = ctx.Err()
    		}
    		defer mu.Unlock()
    	}
    	return firstErr
    }
    
    // MakeBucket - creates a new bucket across all serverPools simultaneously
    // even if one of the sets fail to create buckets, we proceed all the successful
    // operations.
    func (z *erasureServerPools) MakeBucket(ctx context.Context, bucket string, opts MakeBucketOptions) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 89.2K bytes
    - Click Count (0)
  2. src/archive/zip/reader_test.go

    	}
    
    	// test read of each file
    	for i, ft := range zt.File {
    		readTestFile(t, zt, ft, z.File[i], raw)
    	}
    	if t.Failed() {
    		return
    	}
    
    	// test simultaneous reads
    	n := 0
    	done := make(chan bool)
    	for i := 0; i < 5; i++ {
    		for j, ft := range zt.File {
    			go func(j int, ft ZipTestFile) {
    				readTestFile(t, zt, ft, z.File[j], raw)
    				done <- true
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Fri Oct 17 20:10:27 GMT 2025
    - 56.5K bytes
    - Click Count (0)
Back to Top