diff options
| author | chrislu <chris.lu@gmail.com> | 2022-06-06 00:15:37 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-06-06 00:15:37 -0700 |
| commit | 8402af0882ea33d840d3bb4b386b3bf665cdf615 (patch) | |
| tree | e8beb0f95acac76ca69ecdb9bd520804ef227edb | |
| parent | 4a046e4de7a40730895f8149120ce8d6e95f961d (diff) | |
| download | seaweedfs-8402af0882ea33d840d3bb4b386b3bf665cdf615.tar.xz seaweedfs-8402af0882ea33d840d3bb4b386b3bf665cdf615.zip | |
filer: detect ttl based on fs configure setting
| -rw-r--r-- | weed/server/filer_grpc_server.go | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/weed/server/filer_grpc_server.go b/weed/server/filer_grpc_server.go index 67d4aaaaf..d56d36c38 100644 --- a/weed/server/filer_grpc_server.go +++ b/weed/server/filer_grpc_server.go @@ -144,8 +144,15 @@ func (fs *FilerServer) CreateEntry(ctx context.Context, req *filer_pb.CreateEntr return &filer_pb.CreateEntryResponse{}, fmt.Errorf("CreateEntry cleanupChunks %s %s: %v", req.Directory, req.Entry.Name, err2) } + so, err := fs.detectStorageOption(string(util.NewFullPath(req.Directory, req.Entry.Name)), "", "", 0, "", "", "", "") + if err != nil { + return nil, err + } newEntry := filer.FromPbEntry(req.Directory, req.Entry) newEntry.Chunks = chunks + newEntry.TtlSec = so.TtlSeconds + newEntry.Collection = so.Collection + newEntry.DiskType = so.DiskType createErr := fs.filer.CreateEntry(ctx, newEntry, req.OExcl, req.IsFromOtherCluster, req.Signatures, req.SkipCheckParentDirectory) |