*: introduce failpoint beforeBucketPut

Signed-off-by: Wei Fu <[email protected]>

bucket.go

@@ -336,6 +336,8 @@ func (b *Bucket) Put(key []byte, value []byte) error {
 		return errors.ErrIncompatibleValue
 	}
 
+	// gofail: var beforeBucketPut struct{}
+
 	// Insert into node.
 	// Tip: Use a new variable `newKey` instead of reusing the existing `key` to prevent
 	// it from being marked as leaking, and accordingly cannot be allocated on stack.

tests/failpoint/db_failpoint_test.go

@@ -6,6 +6,7 @@ import (
 	"testing"
 	"time"
 
+	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 
 	bolt "go.etcd.io/bbolt"
@@ -155,3 +156,23 @@ func TestFailpoint_LackOfDiskSpace(t *testing.T) {
 	require.Error(t, err)
 	require.ErrorIs(t, err, errors.ErrTxClosed)
 }
+
+func TestFailpoint_BeforeBucketPut(t *testing.T) {
+	db := btesting.MustCreateDB(t)
+
+	err := gofail.Enable("beforeBucketPut", `sleep(3000)`)
+	require.NoError(t, err)
+
+	tx, err := db.Begin(true)
+	require.NoError(t, err)
+
+	b, err := tx.CreateBucket([]byte(t.Name()))
+	require.NoError(t, err)
+
+	start := time.Now()
+	require.NoError(t, b.Put([]byte("1"), []byte("1")))
+	assert.True(t, time.Since(start) >= 5*time.Second)
+
+	require.NoError(t, gofail.Disable("beforeBucketPut"))
+	require.NoError(t, tx.Commit())
+}