aboutsummaryrefslogtreecommitdiff
path: root/weed/filer2/filer.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-05-16 00:08:44 -0700
committerChris Lu <chris.lu@gmail.com>2018-05-16 00:08:44 -0700
commitb303a02461a009298e27f7b9b4f8ae68c8f44f21 (patch)
treebc6a6e6415311c0fd31626fc7abe64d807c15f00 /weed/filer2/filer.go
parentc7a71d35b0f4c94361f227396e12412e4333a2ba (diff)
downloadseaweedfs-b303a02461a009298e27f7b9b4f8ae68c8f44f21.tar.xz
seaweedfs-b303a02461a009298e27f7b9b4f8ae68c8f44f21.zip
cp file can work
1. consolidate to filer_pb.FileChunk 2. dir add file, mkdir 3. file flush, write updates having issue
Diffstat (limited to 'weed/filer2/filer.go')
-rw-r--r--weed/filer2/filer.go5
1 files changed, 3 insertions, 2 deletions
diff --git a/weed/filer2/filer.go b/weed/filer2/filer.go
index 5f76d6fb0..4ee6f4e50 100644
--- a/weed/filer2/filer.go
+++ b/weed/filer2/filer.go
@@ -8,6 +8,7 @@ import (
"path/filepath"
"time"
"os"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
)
type Filer struct {
@@ -105,8 +106,8 @@ func (f *Filer) CreateEntry(entry *Entry) (error) {
return nil
}
-func (f *Filer) AppendFileChunk(p FullPath, c FileChunk) (err error) {
- return f.store.AppendFileChunk(p, c)
+func (f *Filer) AppendFileChunk(p FullPath, chunks []*filer_pb.FileChunk) (err error) {
+ return f.store.AppendFileChunk(p, chunks)
}
func (f *Filer) FindEntry(p FullPath) (found bool, entry *Entry, err error) {