Function executeRead

concurrent_test.go:437–463

(tx *bolt.Tx, bucket []byte, key []byte, readInterval duration)

}

func executeRead(tx *bolt.Tx, bucket []byte, key []byte, readInterval duration) (historyRecord, error) {
	var rec historyRecord

	b := tx.Bucket(bucket)

	initialVal := b.Get(key)
	time.Sleep(randomDurationInRange(readInterval.min, readInterval.max))
	val := b.Get(key)

	if !bytes.Equal(initialVal, val) {
		return rec, fmt.Errorf("read different values for the same key (%q), value1: %q, value2: %q",
			string(key), formatBytes(initialVal), formatBytes(val))
	}

	clonedVal := make([]byte, len(val))
	copy(clonedVal, val)

	rec = historyRecord{
		OperationType: Read,
		Bucket:        string(bucket),
		Key:           string(key),
		Value:         clonedVal,
		Txid:          tx.ID(),
	}

	return rec, nil
}

func executeWrite(tx *bolt.Tx, bucket []byte, key []byte, writeBytes bytesRange, noopWriteRatio int) (historyRecord, error) {
	var rec historyRecord