src/dedo.go: Inline code of db.begin()

1 files changed, 32 insertions, 26 deletions

diff --git a/tests/dedo.go b/tests/dedo.go
index b5dec6e..e2b9299 100644
--- a/tests/dedo.go
+++ b/tests/dedo.go
@@ -845,7 +845,7 @@ func TestBucket_Put_Closed(t *testing.T) {
 	defer db.MustClose()
 	defer os.Remove(db.Path())
 
-	tx, err := db.begin(true)
+	tx, err := db.beginRWTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -1221,7 +1221,7 @@ func TestBucket_Delete_Closed(t *testing.T) {
 	defer db.MustClose()
 	defer os.Remove(db.Path())
 
-	tx, err := db.begin(true)
+	tx, err := db.beginRWTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -1624,7 +1624,7 @@ func TestBucket_NextSequence_Closed(t *testing.T) {
 	defer db.MustClose()
 	defer os.Remove(db.Path())
 
-	tx, err := db.begin(true)
+	tx, err := db.beginRWTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -1770,7 +1770,7 @@ func TestBucket_ForEach_Closed(t *testing.T) {
 	defer db.MustClose()
 	defer os.Remove(db.Path())
 
-	tx, err := db.begin(true)
+	tx, err := db.beginRWTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -2580,7 +2580,7 @@ func TestCursor_Iterate_Leaf(t *testing.T) {
 		t.Fatal(err)
 	}
 
-	tx, err := db.begin(false)
+	tx, err := db.beginTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -2663,7 +2663,7 @@ func TestCursor_LeafRootReverse(t *testing.T) {
 		t.Fatal(err)
 	}
 
-	tx, err := db.begin(false)
+	tx, err := db.beginTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -2738,7 +2738,7 @@ func TestCursor_Restart(t *testing.T) {
 		t.Fatal(err)
 	}
 
-	tx, err := db.begin(false)
+	tx, err := db.beginTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -2830,7 +2830,7 @@ func TestCursor_QuickCheck(t *testing.T) {
 		defer os.Remove(db.Path())
 
 		// Bulk insert all values.
-		tx, err := db.begin(true)
+		tx, err := db.beginRWTx()
 		if err != nil {
 			t.Fatal(err)
 		}
@@ -2855,7 +2855,7 @@ func TestCursor_QuickCheck(t *testing.T) {
 
 		// Iterate over all items and check consistency.
 		index := 0
-		tx, err = db.begin(false)
+		tx, err = db.beginTx()
 		if err != nil {
 			t.Fatal(err)
 		}
@@ -2903,7 +2903,7 @@ func TestCursor_QuickCheck_Reverse(t *testing.T) {
 		defer os.Remove(db.Path())
 
 		// Bulk insert all values.
-		tx, err := db.begin(true)
+		tx, err := db.beginRWTx()
 		if err != nil {
 			t.Fatal(err)
 		}
@@ -2930,7 +2930,7 @@ func TestCursor_QuickCheck_Reverse(t *testing.T) {
 
 		// Iterate over all items and check consistency.
 		index := 0
-		tx, err = db.begin(false)
+		tx, err = db.beginTx()
 		if err != nil {
 			t.Fatal(err)
 		}
@@ -3579,13 +3579,13 @@ func TestDB_Open_InitialMmapSize(t *testing.T) {
 
 	// create a long-running read transaction
 	// that never gets closed while writing
-	rtx, err := db.begin(false)
+	rtx, err := db.beginTx()
 	if err != nil {
 		t.Fatal(err)
 	}
 
 	// create a write transaction
-	wtx, err := db.begin(true)
+	wtx, err := db.beginRWTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -3627,7 +3627,7 @@ func TestDB_Open_InitialMmapSize(t *testing.T) {
 // Ensure that a database cannot open a transaction when it's not open.
 func TestDB_Begin_ErrDatabaseNotOpen(t *testing.T) {
 	var db DB
-	_, err := db.begin(false)
+	_, err := db.beginTx()
 	if err != ErrDatabaseNotOpen {
 		t.Fatalf("unexpected error: %s", err)
 	}
@@ -3639,7 +3639,7 @@ func TestDB_BeginRW(t *testing.T) {
 	defer db.MustClose()
 	defer os.Remove(db.Path())
 
-	tx, err := db.begin(true)
+	tx, err := db.beginRWTx()
 	if err != nil {
 		t.Fatal(err)
 	} else if tx == nil {
@@ -3661,7 +3661,7 @@ func TestDB_BeginRW(t *testing.T) {
 // Ensure that opening a transaction while the DB is closed returns an error.
 func TestDB_BeginRW_Closed(t *testing.T) {
 	var db DB
-	_, err := db.begin(true)
+	_, err := db.beginRWTx()
 	if err != ErrDatabaseNotOpen {
 		t.Fatalf("unexpected error: %s", err)
 	}
@@ -3685,7 +3685,7 @@ func testDB_Close_PendingTx(t *testing.T, writable bool) {
 	defer os.Remove(db.Path())
 
 	// Start transaction.
-	tx, err := db.begin(true)
+	tx, err := db.beginRWTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -4329,7 +4329,7 @@ func ExampleDB_Begin_ReadOnly() {
 	}
 
 	// Create several keys in a transaction.
-	tx, err := db.begin(true)
+	tx, err := db.beginRWTx()
 	if err != nil {
 		log.Fatal(err)
 	}
@@ -4356,7 +4356,7 @@ func ExampleDB_Begin_ReadOnly() {
 	}
 
 	// Iterate over the values in sorted key order.
-	tx, err = db.begin(false)
+	tx, err = db.beginTx()
 	if err != nil {
 		log.Fatal(err)
 	}
@@ -5515,7 +5515,13 @@ func testSimulate(t *testing.T, threadCount, parallelism int) {
 			defer wg.Done()
 
 			// Start transaction.
-			tx, err := db.begin(writable)
+			var tx *Tx
+			var err error
+			if writable {
+				tx, err = db.beginRWTx()
+			} else {
+				tx, err = db.beginTx()
+			}
 			if err != nil {
 				t.Fatal("tx begin: ", err)
 			}
@@ -5800,7 +5806,7 @@ func TestTx_Commit_ErrTxClosed(t *testing.T) {
 	defer db.MustClose()
 	defer os.Remove(db.Path())
 
-	tx, err := db.begin(true)
+	tx, err := db.beginRWTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -5827,7 +5833,7 @@ func TestTx_Rollback_ErrTxClosed(t *testing.T) {
 	defer db.MustClose()
 	defer os.Remove(db.Path())
 
-	tx, err := db.begin(true)
+	tx, err := db.beginRWTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -5849,7 +5855,7 @@ func TestTx_Commit_ErrTxNotWritable(t *testing.T) {
 	defer db.MustClose()
 	defer os.Remove(db.Path())
 
-	tx, err := db.begin(false)
+	tx, err := db.beginTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -5932,7 +5938,7 @@ func TestTx_CreateBucket_ErrTxClosed(t *testing.T) {
 	defer db.MustClose()
 	defer os.Remove(db.Path())
 
-	tx, err := db.begin(true)
+	tx, err := db.beginRWTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -6218,7 +6224,7 @@ func TestTx_DeleteBucket_ErrTxClosed(t *testing.T) {
 	defer db.MustClose()
 	defer os.Remove(db.Path())
 
-	tx, err := db.begin(true)
+	tx, err := db.beginRWTx()
 	if err != nil {
 		t.Fatal(err)
 	}
@@ -6511,7 +6517,7 @@ func ExampleTx_Rollback() {
 	}
 
 	// Update the key but rollback the transaction so it never saves.
-	tx, err := db.begin(true)
+	tx, err := db.beginRWTx()
 	if err != nil {
 		log.Fatal(err)
 	}