}
	}()

	return nil
}

func (p *ReplicationPool) initialized() bool {
	return p != nil && p.objLayer != nil
}

// getMRF returns MRF entries for this node.
func (p *ReplicationPool) getMRF(ctx context.Context, bucket string) (ch <-chan madmin.ReplicationMRF, err error) {
	mrfRec, err := p.loadMRF()
	if err != nil {
		return nil, err
	}