Method Read

hintfile.go:238–330

Read reads a hint entry from the file

()

// Read reads a hint entry from the file
func (r *HintFileReader) Read() (*HintEntry, error) {
	if r.reader == nil {
		return nil, ErrHintFileEntryInvalid
	}

	entry := &HintEntry{}
	fieldsRead := 0

	readUvarint := func() (uint64, error) {
		val, err := binary.ReadUvarint(r.reader)
		if err != nil {
			if err == io.EOF {
				if fieldsRead == 0 {
					return 0, io.EOF
				}
				return 0, ErrHintFileCorrupted
			}
			if err == io.ErrUnexpectedEOF {
				return 0, ErrHintFileCorrupted
			}
			return 0, err
		}
		fieldsRead++
		return val, nil
	}

	var err error
	if entry.BucketId, err = readUvarint(); err != nil {
		return nil, err
	}

	keySize, err := readUvarint()
	if err != nil {
		return nil, err
	}
	entry.KeySize = uint32(keySize)

	valueSize, err := readUvarint()
	if err != nil {
		return nil, err
	}
	entry.ValueSize = uint32(valueSize)

	if entry.Timestamp, err = readUvarint(); err != nil {
		return nil, err
	}

	ttl, err := readUvarint()
	if err != nil {
		return nil, err
	}
	entry.TTL = uint32(ttl)

	flag, err := readUvarint()
	if err != nil {
		return nil, err
	}
	entry.Flag = uint16(flag)