fix ut

Signed-off-by: jiefenghuang <[email protected]>

Author: jiefenghuang

cmd/object.go

@@ -395,14 +395,15 @@ func (j *juiceFS) Readlink(name string) (string, error) {
 
 func getDefaultChunkConf(format *meta.Format) *chunk.Config {
 	chunkConf := &chunk.Config{
-		BlockSize:  format.BlockSize * 1024,
-		Compress:   format.Compression,
-		HashPrefix: format.HashPrefix,
-		GetTimeout: time.Minute,
-		PutTimeout: time.Minute,
-		MaxUpload:  50,
-		MaxRetries: 10,
-		BufferSize: 300 << 20,
+		BlockSize:   format.BlockSize * 1024,
+		Compress:    format.Compression,
+		HashPrefix:  format.HashPrefix,
+		GetTimeout:  time.Minute,
+		PutTimeout:  time.Minute,
+		MaxUpload:   50,
+		MaxDownload: 200,
+		MaxRetries:  10,
+		BufferSize:  300 << 20,
 	}
 	chunkConf.SelfCheck(format.UUID)
 	return chunkConf

cmd/object_test.go

@@ -178,9 +178,10 @@ func TestJFS(t *testing.T) {
 	var conf = vfs.Config{
 		Meta: meta.DefaultConf(),
 		Chunk: &chunk.Config{
-			BlockSize:  format.BlockSize << 10,
-			MaxUpload:  1,
-			BufferSize: 100 << 20,
+			BlockSize:   format.BlockSize << 10,
+			MaxUpload:   1,
+			MaxDownload: 200,
+			BufferSize:  100 << 20,
 		},
 		DirEntryTimeout: time.Millisecond * 100,
 		EntryTimeout:    time.Millisecond * 100,

pkg/fuse/fuse_test.go

@@ -73,12 +73,13 @@ func mount(url, mp string) {
 	}
 
 	chunkConf := chunk.Config{
-		BlockSize:  format.BlockSize * 1024,
-		Compress:   format.Compression,
-		MaxUpload:  20,
-		BufferSize: 300 << 20,
-		CacheSize:  1024,
-		CacheDir:   "memory",
+		BlockSize:   format.BlockSize * 1024,
+		Compress:    format.Compression,
+		MaxUpload:   20,
+		MaxDownload: 200,
+		BufferSize:  300 << 20,
+		CacheSize:   1024,
+		CacheDir:    "memory",
 	}
 
 	blob, err := object.CreateStorage(strings.ToLower(format.Storage), format.Bucket, format.AccessKey, format.SecretKey, format.SessionToken)

pkg/gateway/gateway_test.go

@@ -19,15 +19,16 @@ package gateway
 import (
 	"context"
 	"errors"
+	"os"
+	"testing"
+	"time"
+
 	"github.com/juicedata/juicefs/pkg/chunk"
 	"github.com/juicedata/juicefs/pkg/fs"
 	"github.com/juicedata/juicefs/pkg/meta"
 	"github.com/juicedata/juicefs/pkg/object"
 	"github.com/juicedata/juicefs/pkg/vfs"
 	minio "github.com/minio/minio/cmd"
-	"os"
-	"testing"
-	"time"
 )
 
 func TestGatewayLock(t *testing.T) {
@@ -42,9 +43,10 @@ func TestGatewayLock(t *testing.T) {
 	var conf = vfs.Config{
 		Meta: meta.DefaultConf(),
 		Chunk: &chunk.Config{
-			BlockSize:  format.BlockSize << 10,
-			MaxUpload:  1,
-			BufferSize: 100 << 20,
+			BlockSize:   format.BlockSize << 10,
+			MaxUpload:   1,
+			MaxDownload: 200,
+			BufferSize:  100 << 20,
 		},
 		DirEntryTimeout: time.Millisecond * 100,
 		EntryTimeout:    time.Millisecond * 100,

pkg/vfs/?_journal=WAL&_timeout=5000&cache=shared

@@ -69,12 +69,13 @@ func createTestVFS(applyMetaConfOption func(metaConfig *meta.Config), metaUri st
 		Format:  *format,
 		Version: "Juicefs",
 		Chunk: &chunk.Config{
-			BlockSize:  format.BlockSize * 1024,
-			Compress:   format.Compression,
-			MaxUpload:  2,
-			BufferSize: 30 << 20,
-			CacheSize:  10 << 20,
-			CacheDir:   "memory",
+			BlockSize:   format.BlockSize * 1024,
+			Compress:    format.Compression,
+			MaxUpload:   2,
+			MaxDownload: 200,
+			BufferSize:  30 << 20,
+			CacheSize:   10 << 20,
+			CacheDir:    "memory",
 		},
 		FuseOpts: &FuseOptions{},
 	}