Function TestTx_Rollback

tx_test.go:27–66

todo to check is there any deadlock here?

(t *testing.T)

// todo to check is there any deadlock here?
func TestTx_Rollback(t *testing.T) {

	withDefaultDB(t, func(t *testing.T, db *DB) {
		bucket := "bucket_rollback_test"
		txCreateBucket(t, db, DataStructureBTree, bucket, nil)
		tx, err := db.Begin(true)
		assert.NoError(t, err)

		for i := 0; i < 10; i++ {
			key := []byte("key_" + fmt.Sprintf("%03d", i))
			val := []byte("val_" + fmt.Sprintf("%03d", i))
			if i == 7 {
				key = []byte("") // set error key to make tx rollback
			}
			if err = tx.Put(bucket, key, val, Persistent); err != nil {
				// tx rollback
				_ = tx.Rollback()

				if i < 7 {
					t.Fatal("err TestTx_Rollback")
				}
			}
		}

		// no one found
		for i := 0; i <= 10; i++ {
			tx, err = db.Begin(false)
			assert.NoError(t, err)

			key := []byte("key_" + fmt.Sprintf("%03d", i))
			if _, err := tx.Get(bucket, key); err != nil {
				// tx rollback
				_ = tx.Rollback()
			} else {
				t.Fatal("err TestTx_Rollback")
			}
		}

	})
}

func TestTx_Begin(t *testing.T) {
	t.Run("Begin with default options, with only read", func(t *testing.T) {