aboutsummaryrefslogtreecommitdiff
path: root/weed/filer2/memdb/memdb_store.go
diff options
context:
space:
mode:
Diffstat (limited to 'weed/filer2/memdb/memdb_store.go')
-rw-r--r--weed/filer2/memdb/memdb_store.go7
1 files changed, 5 insertions, 2 deletions
diff --git a/weed/filer2/memdb/memdb_store.go b/weed/filer2/memdb/memdb_store.go
index edddcca96..0276e9a7f 100644
--- a/weed/filer2/memdb/memdb_store.go
+++ b/weed/filer2/memdb/memdb_store.go
@@ -6,6 +6,7 @@ import (
"strings"
"fmt"
"time"
+ "github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
)
type MemDbStore struct {
@@ -32,13 +33,15 @@ func (filer *MemDbStore) InsertEntry(entry *filer2.Entry) (err error) {
return nil
}
-func (filer *MemDbStore) AppendFileChunk(fullpath filer2.FullPath, fileChunk filer2.FileChunk) (err error) {
+func (filer *MemDbStore) AppendFileChunk(fullpath filer2.FullPath, fileChunks []*filer_pb.FileChunk) (err error) {
found, entry, err := filer.FindEntry(fullpath)
if !found {
return fmt.Errorf("No such file: %s", fullpath)
}
- entry.Chunks = append(entry.Chunks, fileChunk)
+ entry.Chunks = append(entry.Chunks, fileChunks...)
entry.Mtime = time.Now()
+ println("appending to entry", entry.Name(), len(entry.Chunks))
+ filer.tree.ReplaceOrInsert(Entry{entry})
return nil
}