Add nested buckets.

This commit adds the ability to create buckets inside of other buckets.
It also replaces the buckets page with a root bucket.

Fixes #56.

1 files changed, 0 insertions, 144 deletions

diff --git a/functional_test.go b/functional_test.go
deleted file mode 100644
index fdaecbb..0000000
--- a/functional_test.go
+++ /dev/null
@@ -1,144 +0,0 @@
-package bolt
-
-import (
-	"fmt"
-	"os"
-	"sync"
-	"testing"
-	"testing/quick"
-	"time"
-
-	"github.com/stretchr/testify/assert"
-)
-
-// Ensure that multiple threads can use the DB without race detector errors.
-func TestParallelTxs(t *testing.T) {
-	if testing.Short() {
-		t.Skip("skipping test in short mode.")
-	}
-
-	var mutex sync.RWMutex
-
-	err := quick.Check(func(numReaders, batchSize uint, items testdata) bool {
-		// Limit the readers & writers to something reasonable.
-		numReaders = (numReaders % 10) + 1
-		batchSize = (batchSize % 50) + 1
-
-		// warn("")
-		// warn("================================================================")
-		// warn("numReaders:", numReaders, "batchSize", batchSize)
-
-		// Maintain the current dataset.
-		var current testdata
-
-		withOpenDB(func(db *DB, path string) {
-			db.Update(func(tx *Tx) error {
-				return tx.CreateBucket("widgets")
-			})
-
-			// Maintain a set of concurrent readers.
-			var wg sync.WaitGroup
-			var c = make(chan bool, 0)
-			go func() {
-				var readers = make(chan int, numReaders)
-				for {
-					wg.Add(1)
-
-					// Attempt to start a new reader unless we're stopped.
-					select {
-					case readers <- 0:
-					case <-c:
-						wg.Done()
-						return
-					}
-
-					go func() {
-						mutex.RLock()
-						local := make(map[string][]byte)
-						for _, item := range current {
-							local[string(item.Key)] = item.Value
-						}
-						tx, err := db.Begin(false)
-						mutex.RUnlock()
-						if err == ErrDatabaseNotOpen {
-							wg.Done()
-							return
-						} else if !assert.NoError(t, err) {
-							t.FailNow()
-						}
-
-						// Verify all data is in for local data list.
-						for k, v := range local {
-							value := tx.Bucket("widgets").Get([]byte(k))
-							if !assert.NoError(t, err) || !assert.Equal(t, value, v, fmt.Sprintf("reader (%p)", tx)) {
-								tx.Rollback()
-								wg.Done()
-								t.FailNow()
-							}
-						}
-
-						tx.Rollback()
-						wg.Done()
-						<-readers
-					}()
-				}
-			}()
-
-			// Batch insert items.
-			pending := items
-			for {
-				// Determine next batch.
-				currentBatchSize := int(batchSize)
-				if currentBatchSize > len(pending) {
-					currentBatchSize = len(pending)
-				}
-				batchItems := pending[0:currentBatchSize]
-				pending = pending[currentBatchSize:]
-
-				// Start write transaction.
-				tx, err := db.Begin(true)
-				if !assert.NoError(t, err) {
-					t.FailNow()
-				}
-
-				// warnf("[writer] BEGIN (%d)", currentBatchSize)
-
-				// Insert whole batch.
-				b := tx.Bucket("widgets")
-				for _, item := range batchItems {
-					// warnf("[writer] PUT %x: %x", trunc(item.Key, 3), trunc(item.Value, 3))
-					err := b.Put(item.Key, item.Value)
-					if !assert.NoError(t, err) {
-						t.FailNow()
-					}
-				}
-
-				// Commit and update the current list.
-				mutex.Lock()
-				// warnf("[writer] COMMIT\n\n")
-				err = tx.Commit()
-				current = append(current, batchItems...)
-				mutex.Unlock()
-				if !assert.NoError(t, err) {
-					t.FailNow()
-				}
-
-				// If there are no more left then exit.
-				if len(pending) == 0 {
-					break
-				}
-
-				time.Sleep(1 * time.Millisecond)
-			}
-
-			// Notify readers to stop.
-			close(c)
-
-			// Wait for readers to finish.
-			wg.Wait()
-		})
-		return true
-	}, qconfig())
-	assert.NoError(t, err)
-	fmt.Fprint(os.Stderr, "\n")
-}