Method replyStatusToClient

cmd/proxy/proc/processor.go:357–370

(st proto.OpStatus)

}

func (p *TwoPhaseProcessor) replyStatusToClient(st proto.OpStatus) {
	if st == proto.OpStatusInconsistent && p.commit.getNumSuccessResponse() > 0 && p.commit.noErrResponse.ssRequest != nil {
		p.commit.noErrResponse.ssRequest.ssRespOpMsg.SetAsResponse()
		p.commit.noErrResponse.ssRequest.ssRespOpMsg.SetOpStatus(proto.OpStatusInconsistent)
		payload := p.commit.noErrResponse.ssRequest.ssRespOpMsg.GetPayload()
		// follow the sendRepairs
		if payload != nil {
			p.commit.noErrResponse.ssRequest.ssRespOpMsg.SetPayload(p.clientRequest.GetPayload())
		}
		p.replyToClient(&p.commit.noErrResponse)
	} else {
		p.ProcessorBase.replyStatusToClient(st)
	}
}

func recordMostUpdatedThan(m1, m2 *proto.OperationalMessage) bool {
	lmt1 := m1.GetLastModificationTime()