aboutsummaryrefslogtreecommitdiff
path: root/weed/server/filer_grpc_server.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-01-22 11:42:40 -0800
committerChris Lu <chris.lu@gmail.com>2020-01-22 11:42:40 -0800
commitd4e75a0d183b57180b2ff0be2531db540c0c9aa6 (patch)
tree828a5d3a31592c0edfeb224e1f80874d6f83001d /weed/server/filer_grpc_server.go
parent9b01a99d9a93b2502746fe6870945823be48cc5f (diff)
downloadseaweedfs-d4e75a0d183b57180b2ff0be2531db540c0c9aa6.tar.xz
seaweedfs-d4e75a0d183b57180b2ff0be2531db540c0c9aa6.zip
filer: option to create file only if it is new, O_EXCL
Diffstat (limited to 'weed/server/filer_grpc_server.go')
-rw-r--r--weed/server/filer_grpc_server.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/server/filer_grpc_server.go b/weed/server/filer_grpc_server.go
index a84feec2d..d82ef9782 100644
--- a/weed/server/filer_grpc_server.go
+++ b/weed/server/filer_grpc_server.go
@@ -139,7 +139,7 @@ func (fs *FilerServer) CreateEntry(ctx context.Context, req *filer_pb.CreateEntr
FullPath: fullpath,
Attr: filer2.PbToEntryAttribute(req.Entry.Attributes),
Chunks: chunks,
- })
+ }, req.OExcl)
if err == nil {
fs.filer.DeleteChunks(garbages)