bucket.go

@@ -379,7 +379,7 @@ func (b *Bucket) MoveBucket(key []byte, dstBucket *Bucket) (err error) {
 	return
 }
 
-// MoveBucket moves a sub-bucket from the source bucket to the destination bucket.
+// moveBucket moves a sub-bucket from the source bucket to the destination bucket.
 // Returns an error if
 //  1. the sub-bucket cannot be found in the source bucket;
 //  2. or the key already exists in the destination bucket;

tx.go

@@ -177,8 +177,17 @@ func (tx *Tx) deleteBucket(name []byte) error {
 // MoveBucket moves a sub-bucket from the source bucket to the destination bucket with slave.
 func (tx *Tx) MoveBucket(child []byte, src *Bucket, dst *Bucket) error {
 	err := tx.moveBucket(child, src, dst)
-	if err == nil && src.slave != nil && src.slave != nil && tx.slave != nil {
-		err = tx.slave.moveBucket(child, src.slave, dst.slave)
+
+	if err == nil && tx.slave != nil {
+		if src != nil {
+			src = src.slave
+		}
+
+		if dst != nil {
+			dst = dst.slave
+		}
+
+		err = tx.slave.moveBucket(child, src, dst)
 	}
 
 	return err