diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-02-27 00:07:13 -0800 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-02-27 00:07:13 -0800 |
| commit | 555413d9fc4837302ef1c5b2b921b406c9de6777 (patch) | |
| tree | dfd0f67586df0320fd9a77288651475d2ccdcc6c /weed/filer2 | |
| parent | 430b5a49e2abd9e3751e8c5840a690541ddc66ca (diff) | |
| download | seaweedfs-555413d9fc4837302ef1c5b2b921b406c9de6777.tar.xz seaweedfs-555413d9fc4837302ef1c5b2b921b406c9de6777.zip | |
weed queue starts
Diffstat (limited to 'weed/filer2')
| -rw-r--r-- | weed/filer2/filer.go | 3 | ||||
| -rw-r--r-- | weed/filer2/leveldb/leveldb_store_test.go | 4 | ||||
| -rw-r--r-- | weed/filer2/leveldb2/leveldb2_store_test.go | 4 |
3 files changed, 6 insertions, 5 deletions
diff --git a/weed/filer2/filer.go b/weed/filer2/filer.go index 181a250f2..e70e013ae 100644 --- a/weed/filer2/filer.go +++ b/weed/filer2/filer.go @@ -31,10 +31,11 @@ type Filer struct { fileIdDeletionQueue *util.UnboundedQueue GrpcDialOption grpc.DialOption DirBucketsPath string + DirQueuesPath string buckets *FilerBuckets } -func NewFiler(masters []string, grpcDialOption grpc.DialOption, bucketFolder string) *Filer { +func NewFiler(masters []string, grpcDialOption grpc.DialOption) *Filer { f := &Filer{ directoryCache: ccache.New(ccache.Configure().MaxSize(1000).ItemsToPrune(100)), MasterClient: wdclient.NewMasterClient(grpcDialOption, "filer", masters), diff --git a/weed/filer2/leveldb/leveldb_store_test.go b/weed/filer2/leveldb/leveldb_store_test.go index aaed5a8ae..983e1cbe9 100644 --- a/weed/filer2/leveldb/leveldb_store_test.go +++ b/weed/filer2/leveldb/leveldb_store_test.go @@ -9,7 +9,7 @@ import ( ) func TestCreateAndFind(t *testing.T) { - filer := filer2.NewFiler(nil, nil, "") + filer := filer2.NewFiler(nil, nil) dir, _ := ioutil.TempDir("", "seaweedfs_filer_test") defer os.RemoveAll(dir) store := &LevelDBStore{} @@ -64,7 +64,7 @@ func TestCreateAndFind(t *testing.T) { } func TestEmptyRoot(t *testing.T) { - filer := filer2.NewFiler(nil, nil, "") + filer := filer2.NewFiler(nil, nil) dir, _ := ioutil.TempDir("", "seaweedfs_filer_test2") defer os.RemoveAll(dir) store := &LevelDBStore{} diff --git a/weed/filer2/leveldb2/leveldb2_store_test.go b/weed/filer2/leveldb2/leveldb2_store_test.go index e5146e8bd..58637b7b6 100644 --- a/weed/filer2/leveldb2/leveldb2_store_test.go +++ b/weed/filer2/leveldb2/leveldb2_store_test.go @@ -9,7 +9,7 @@ import ( ) func TestCreateAndFind(t *testing.T) { - filer := filer2.NewFiler(nil, nil, "") + filer := filer2.NewFiler(nil, nil) dir, _ := ioutil.TempDir("", "seaweedfs_filer_test") defer os.RemoveAll(dir) store := &LevelDB2Store{} @@ -64,7 +64,7 @@ func TestCreateAndFind(t *testing.T) { } func TestEmptyRoot(t *testing.T) { - filer := filer2.NewFiler(nil, nil, "") + filer := filer2.NewFiler(nil, nil) dir, _ := ioutil.TempDir("", "seaweedfs_filer_test2") defer os.RemoveAll(dir) store := &LevelDB2Store{} |