Method asyncPutOnBackup

internal/dmap/put.go:133–151

(e *env, data []byte, owner discovery.Member)

}

func (dm *DMap) asyncPutOnBackup(e *env, data []byte, owner discovery.Member) {
	defer dm.s.wg.Done()

	rc := dm.s.client.Get(owner.String())
	cmd := protocol.NewPutEntry(e.dmap, e.key, data).Command(dm.s.ctx)
	err := rc.Process(dm.s.ctx, cmd)
	if err != nil {
		if dm.s.log.V(3).Ok() {
			dm.s.log.V(3).Printf("[ERROR] Failed to create replica in async mode: %v", err)
		}
		return
	}
	err = cmd.Err()
	if err != nil {
		if dm.s.log.V(3).Ok() {
			dm.s.log.V(3).Printf("[ERROR] Failed to create replica in async mode: %v", err)
		}
	}
}

func (dm *DMap) asyncPutOnCluster(e *env, nt storage.Entry) error {
	err := dm.putEntryOnFragment(e, nt)