Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for getHealReplicateObjectInfo (0.28 sec)

  1. cmd/bucket-replication-utils.go

    			return Failed
    		case Complete:
    			completed++
    		}
    	}
    	if completed == len(m) {
    		return Complete
    	}
    	return Pending
    }
    
    // getHealReplicateObjectInfo returns info needed by heal replication in ReplicateObjectInfo
    func getHealReplicateObjectInfo(oi ObjectInfo, rcfg replicationConfig) ReplicateObjectInfo {
    	userDefined := cloneMSS(oi.UserDefined)
    	if rcfg.Config != nil && rcfg.Config.RoleArn != "" {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  2. cmd/bucket-replication.go

    			return
    		case <-ctx.Done():
    			return
    		default:
    		}
    		if heal && lastCheckpoint != "" && lastCheckpoint != res.Item.Name {
    			continue
    		}
    		lastCheckpoint = ""
    		roi := getHealReplicateObjectInfo(res.Item, rcfg)
    		if !roi.ExistingObjResync.mustResync() {
    			continue
    		}
    		select {
    		case <-s.resyncCancelCh:
    			return
    		case <-ctx.Done():
    			return
    		default:
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 06:56:12 UTC 2024
    - 114.4K bytes
    - Viewed (0)
Back to top