diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-09-22 22:11:37 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-09-22 22:11:37 -0700 |
| commit | 13d6a74eb29bcb8bd1348baecb379ecd408688b3 (patch) | |
| tree | 78b109810f75e2162d37ab8f6a10f29ed5d72778 | |
| parent | fdc8a267de346462446d251bb845fd241a4d1d27 (diff) | |
| download | seaweedfs-13d6a74eb29bcb8bd1348baecb379ecd408688b3.tar.xz seaweedfs-13d6a74eb29bcb8bd1348baecb379ecd408688b3.zip | |
consolidate file chunks during create
| -rw-r--r-- | weed/server/filer_grpc_server.go | 13 |
1 files changed, 11 insertions, 2 deletions
diff --git a/weed/server/filer_grpc_server.go b/weed/server/filer_grpc_server.go index 6c3390a26..da506c70a 100644 --- a/weed/server/filer_grpc_server.go +++ b/weed/server/filer_grpc_server.go @@ -125,10 +125,19 @@ func (fs *FilerServer) LookupVolume(ctx context.Context, req *filer_pb.LookupVol } func (fs *FilerServer) CreateEntry(ctx context.Context, req *filer_pb.CreateEntryRequest) (resp *filer_pb.CreateEntryResponse, err error) { + + fullpath := filer2.FullPath(filepath.Join(req.Directory, req.Entry.Name)) + chunks, garbages := filer2.CompactFileChunks(req.Entry.Chunks) + + for _, garbage := range garbages { + glog.V(0).Infof("deleting %s garbage chunk: %v, [%d, %d)", fullpath, garbage.FileId, garbage.Offset, garbage.Offset+int64(garbage.Size)) + fs.filer.DeleteFileByFileId(garbage.FileId) + } + err = fs.filer.CreateEntry(&filer2.Entry{ - FullPath: filer2.FullPath(filepath.Join(req.Directory, req.Entry.Name)), + FullPath: fullpath, Attr: filer2.PbToEntryAttribute(req.Entry.Attributes), - Chunks: req.Entry.Chunks, + Chunks: chunks, }) if err == nil { |