Method GetRaftEntry

raftwal/log.go:157–183

GetRaftEntry gets the entry at the index idx, reads the data from the appropriate offset and converts it to a raftpb.Entry object.

(idx int)

// GetRaftEntry gets the entry at the index idx, reads the data from the appropriate
// offset and converts it to a raftpb.Entry object.
func (lf *logFile) GetRaftEntry(idx int) raftpb.Entry {
	entry := lf.getEntry(idx)
	re := raftpb.Entry{
		Term:  entry.Term(),
		Index: entry.Index(),
		Type:  raftpb.EntryType(int32(entry.Type())),
	}
	if entry.DataOffset() > 0 {
		x.AssertTrue(entry.DataOffset() < uint64(len(lf.Data)))
		data := lf.Slice(int(entry.DataOffset()))
		if len(data) > 0 {
			// Copy the data over to allow the mmaped file to be deleted later.
			re.Data = append(re.Data, data...)
		}
	}
	// Decrypt the data if encryption is enabled.
	if lf.dataKey != nil && len(re.Data) > 0 {
		// No need to worry about mmap. Because, XORBlock allocates a byte array to do the
		// XOR. So, the given slice is not being mutated.
		// NOTE: We can potentially use allocator for this allocation.
		decoded, err := y.XORBlockAllocate(
			re.Data, lf.dataKey.Data, lf.generateIV(entry.DataOffset()))
		x.Check(err)
		re.Data = decoded
	}
	return re
}

// firstIndex returns the first index in the file.
func (lf *logFile) firstIndex() uint64 {