Function executeWrite

concurrent_test.go:465–502

(tx *bolt.Tx, bucket []byte, key []byte, writeBytes bytesRange, noopWriteRatio int)

}

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

	if mrand.Intn(100) < noopWriteRatio {
		// A no-op write transaction has two consequences:
		//    1. The txid increases by 1;
		//    2. Two meta pages point to the same root page.
		rec = historyRecord{
			OperationType: Write,
			Bucket:        string(bucket),
			Key:           noopTxKey,
			Value:         nil,
			Txid:          tx.ID(),
		}
		return rec, nil
	}

	b := tx.Bucket(bucket)

	valueBytes := randomIntInRange(writeBytes.min, writeBytes.max)
	v := make([]byte, valueBytes)
	if _, cErr := crand.Read(v); cErr != nil {
		return rec, cErr
	}

	putErr := b.Put(key, v)
	if putErr == nil {
		rec = historyRecord{
			OperationType: Write,
			Bucket:        string(bucket),
			Key:           string(key),
			Value:         v,
			Txid:          tx.ID(),
		}
	}

	return rec, putErr
}

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