Method expire

sqlchain/ackindex.go:113–142

()

}

func (i *multiAckIndex) expire() {
	i.RLock()
	defer i.RUnlock()
	// TODO(leventeliu): need further processing.
	for _, v := range i.respIndex {
		log.WithFields(log.Fields{
			"request_hash":  v.GetRequestHash(),
			"request_time":  v.GetRequestTimestamp(),
			"request_type":  v.Request.QueryType,
			"request_node":  v.Request.NodeID,
			"response_hash": v.Hash(),
			"response_node": v.NodeID,
			"response_time": v.Timestamp,
		}).Warn("query expires without acknowledgement")
	}
	for _, v := range i.ackIndex {
		log.WithFields(log.Fields{
			"request_hash":  v.GetRequestHash(),
			"request_time":  v.GetRequestTimestamp(),
			"request_type":  v.Response.Request.QueryType,
			"request_node":  v.Response.Request.NodeID,
			"response_hash": v.GetResponseHash(),
			"response_node": v.Response.NodeID,
			"response_time": v.GetResponseTimestamp(),
			"ack_hash":      v.Hash(),
			"ack_node":      v.NodeID,
			"ack_time":      v.Timestamp,
		}).Warn("query expires without block producing")
	}
}

type ackIndex struct {
	hi map[int32]*multiAckIndex