Method EncodeObject

ec/manager.go:277–308

EncodeObject generates slices using Reed-Solom algorithm: - lom - object to encode - intra - if true, it is internal request and has low priority - cb - optional callback that is called after the object is encoded

(lom *cluster.LOM, cb ...cluster.OnFinishObj)

//   - intra - if true, it is internal request and has low priority
//   - cb - optional callback that is called after the object is encoded
func (mgr *Manager) EncodeObject(lom *cluster.LOM, cb ...cluster.OnFinishObj) error {
	if !lom.Bprops().EC.Enabled {
		return ErrorECDisabled
	}
	if cs := fs.GetCapStatus(); cs.Err != nil {
		return cs.Err
	}
	isECCopy := IsECCopy(lom.SizeBytes(), &lom.Bprops().EC)
	targetCnt := mgr.targetCnt.Load()

	// tradeoff: encoding small object might require just 1 additional target available
	// we will start xaction to satisfy this request
	if required := lom.Bprops().EC.RequiredEncodeTargets(); !isECCopy && int(targetCnt) < required {
		glog.Warningf("not enough targets to encode the object; actual: %v, required: %v", targetCnt, required)
		return cmn.ErrNotEnoughTargets
	}
	spec, _ := fs.CSM.FileSpec(lom.FQN)
	if spec != nil && !spec.PermToProcess() {
		return errSkipped
	}

	req := allocateReq(ActSplit, lom.LIF())
	req.IsCopy = IsECCopy(lom.SizeBytes(), &lom.Bprops().EC)
	if len(cb) != 0 {
		req.rebuild = true
		req.Callback = cb[0]
	}

	mgr.RestoreBckPutXact(lom.Bck()).encode(req, lom)

	return nil
}

func (mgr *Manager) CleanupObject(lom *cluster.LOM) {
	if !lom.Bprops().EC.Enabled {