diff options
| author | chrislu <chris.lu@gmail.com> | 2022-04-06 00:28:48 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-04-06 00:28:48 -0700 |
| commit | 79b8e6a8c31d20b309f3ffe67fb37701054d6000 (patch) | |
| tree | bb1bbb1131b7ca68e5f0ece7056b5b2d2fe63699 /weed/server/filer_server_handlers_write_merge.go | |
| parent | bc888226fc89f623391b78d4f642c63b7e100967 (diff) | |
| download | seaweedfs-79b8e6a8c31d20b309f3ffe67fb37701054d6000.tar.xz seaweedfs-79b8e6a8c31d20b309f3ffe67fb37701054d6000.zip | |
add a place holder for later merge consecutive chunks
Diffstat (limited to 'weed/server/filer_server_handlers_write_merge.go')
| -rw-r--r-- | weed/server/filer_server_handlers_write_merge.go | 11 |
1 files changed, 11 insertions, 0 deletions
diff --git a/weed/server/filer_server_handlers_write_merge.go b/weed/server/filer_server_handlers_write_merge.go new file mode 100644 index 000000000..dadc6f726 --- /dev/null +++ b/weed/server/filer_server_handlers_write_merge.go @@ -0,0 +1,11 @@ +package weed_server + +import ( + "github.com/chrislusf/seaweedfs/weed/operation" + "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" +) + +func (fs *FilerServer) maybeMergeChunks(so *operation.StorageOption, inputChunks []*filer_pb.FileChunk) (mergedChunks []*filer_pb.FileChunk, err error) { + //TODO merge consecutive smaller chunks into a large chunk to reduce number of chunks + return inputChunks, nil +} |
