Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for coroutines (0.19 sec)

  1. cmd/erasure-server-pool.go

    		g.Go(func() error {
    			// Get the set where it would be placed.
    			storageInfos[index] = getDiskInfos(ctx, pool.getHashedSet(object).getDisks()...)
    			return nil
    		}, index)
    	}
    
    	// Wait for the go routines.
    	g.Wait()
    
    	for i, zinfo := range storageInfos {
    		if zinfo == nil {
    			serverPools[i] = poolAvailableSpace{Index: i}
    			continue
    		}
    		var available uint64
    		if !isMinioMetaBucketName(bucket) {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  2. cmd/iam-store.go

    	}
    	c.updatedAt = time.Now()
    	return nil
    }
    
    // IAMStorageAPI defines an interface for the IAM persistence layer
    type IAMStorageAPI interface {
    	// The role of the read-write lock is to prevent go routines from
    	// concurrently reading and writing the IAM storage. The (r)lock()
    	// functions return the iamCache. The cache can be safely written to
    	// only when returned by `lock()`.
    	lock() *iamCache
    	unlock()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sat Apr 27 10:04:10 GMT 2024
    - 75.2K bytes
    - Viewed (2)
  3. cmd/erasure-object.go

    			if onlineDisks[index] == nil {
    				return errDiskNotFound
    			}
    			return onlineDisks[index].UpdateMetadata(ctx, bucket, object, fi, opts)
    		}, index)
    	}
    
    	// Wait for all the routines.
    	mErrs := g.Wait()
    
    	return reduceWriteQuorumErrs(ctx, mErrs, objectOpIgnoredErrs, fi.WriteQuorum(er.defaultWQuorum()))
    }
    
    // updateObjectMeta will update the metadata of a file.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
Back to top