From e31c514b00b97c2db20232812899d542e37ea931 Mon Sep 17 00:00:00 2001 From: Chris Lu Date: Wed, 16 May 2018 00:54:44 -0700 Subject: adding modified time to file chunk --- weed/server/filer_server_handlers_admin.go | 2 ++ weed/server/filer_server_handlers_write.go | 3 +++ 2 files changed, 5 insertions(+) (limited to 'weed/server') diff --git a/weed/server/filer_server_handlers_admin.go b/weed/server/filer_server_handlers_admin.go index 9872dcbd1..2c5c1bc21 100644 --- a/weed/server/filer_server_handlers_admin.go +++ b/weed/server/filer_server_handlers_admin.go @@ -7,6 +7,7 @@ import ( "github.com/chrislusf/seaweedfs/weed/filer2" "strconv" "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" + "time" ) func (fs *FilerServer) registerHandler(w http.ResponseWriter, r *http.Request) { @@ -26,6 +27,7 @@ func (fs *FilerServer) registerHandler(w http.ResponseWriter, r *http.Request) { Chunks: []*filer_pb.FileChunk{{ FileId: fileId, Size: fileSize, + Mtime: time.Now().UnixNano(), }}, } err = fs.filer.CreateEntry(entry) diff --git a/weed/server/filer_server_handlers_write.go b/weed/server/filer_server_handlers_write.go index 4d988e6a2..c6e735cf5 100644 --- a/weed/server/filer_server_handlers_write.go +++ b/weed/server/filer_server_handlers_write.go @@ -24,6 +24,7 @@ import ( "github.com/chrislusf/seaweedfs/weed/util" "github.com/chrislusf/seaweedfs/weed/filer2" "github.com/chrislusf/seaweedfs/weed/pb/filer_pb" + "time" ) type FilerPostResult struct { @@ -335,6 +336,7 @@ func (fs *FilerServer) PostHandler(w http.ResponseWriter, r *http.Request) { Chunks: []*filer_pb.FileChunk{{ FileId: fileId, Size: uint64(r.ContentLength), + Mtime: time.Now().UnixNano(), }}, } if db_err := fs.filer.CreateEntry(entry); db_err != nil { @@ -460,6 +462,7 @@ func (fs *FilerServer) doAutoChunk(w http.ResponseWriter, r *http.Request, conte FileId: fileId, Offset: chunkOffset, Size: uint64(chunkBufOffset), + Mtime: time.Now().UnixNano(), }, ) -- cgit v1.2.3