Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 25 of 25 for concurrent (0.23 sec)

  1. cmd/metacache-walk.go

    				if s.walkReadMu != nil {
    					s.walkReadMu.Unlock()
    				}
    				diskHealthCheckOK(ctx, err)
    				if err != nil {
    					// It is totally possible that xl.meta was overwritten
    					// while being concurrently listed at the same time in
    					// such scenarios the 'xl.meta' might get truncated
    					if !IsErrIgnored(err, io.EOF, io.ErrUnexpectedEOF) {
    						internalLogOnceIf(ctx, err, "metacache-walk-read-metadata")
    					}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 12.4K bytes
    - Viewed (0)
  2. docs/bucket/versioning/README.md

    non-versioned bucket and you want to maintain the same permanent delete behavior when on versioning-enabled bucket, you must add a noncurrent expiration policy. The noncurrent expiration lifecycle policy will manage the deletes of the noncurrent object versions in the versioning-enabled bucket. (A version-enabled bucket maintains one current and zero or more noncurrent object versions.)
    
    Versioning must be explicitly enabled on a bucket, versioning is not enabled by default. Object locking enabled...
    Plain Text
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 04 21:43:52 GMT 2023
    - 11.9K bytes
    - Viewed (1)
  3. cmd/bucket-metadata-sys.go

    	if objAPI == nil {
    		return errServerNotInitialized
    	}
    
    	sys.objAPI = objAPI
    
    	// Load bucket metadata sys.
    	sys.init(ctx, buckets)
    	return nil
    }
    
    // concurrently load bucket metadata to speed up loading bucket metadata.
    func (sys *BucketMetadataSys) concurrentLoad(ctx context.Context, buckets []BucketInfo, failedBuckets map[string]struct{}) {
    	g := errgroup.WithNErrs(len(buckets))
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Apr 22 17:49:30 GMT 2024
    - 19.8K bytes
    - Viewed (0)
  4. cmd/notification.go

    		}
    		results[len(results)-1] = r
    		results[len(results)-1].Endpoint = u.String()
    	}()
    	wg.Wait()
    
    	return results
    }
    
    // SpeedTest run GET/PUT tests at input concurrency for requested object size,
    // optionally you can extend the tests longer with time.Duration.
    func (sys *NotificationSys) SpeedTest(ctx context.Context, sopts speedTestOpts) []SpeedTestResult {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri Apr 12 18:13:36 GMT 2024
    - 44.5K bytes
    - Viewed (0)
  5. cmd/data-scanner.go

    	if lim == 0 || len(fivs) <= lim+1 { // fewer than lim _noncurrent_ versions
    		for _, fi := range fivs {
    			objectInfos = append(objectInfos, fi.ToObjectInfo(i.bucket, i.objectPath(), versioned))
    		}
    		return objectInfos, nil
    	}
    
    	overflowVersions := fivs[lim+1:]
    	// Retain the current version + most recent lim noncurrent versions
    	for _, fi := range fivs[:lim+1] {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 11:18:58 GMT 2024
    - 47.6K bytes
    - Viewed (0)
Back to top