diff options
| author | Chris Lu <chris.lu@gmail.com> | 2018-05-16 00:54:44 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2018-05-16 00:54:44 -0700 |
| commit | e31c514b00b97c2db20232812899d542e37ea931 (patch) | |
| tree | 2198600b0f337c7575f9b0422edc9b084b9114f6 /weed/server | |
| parent | 6bf31467c7918b16440be80495a024b877587363 (diff) | |
| download | seaweedfs-e31c514b00b97c2db20232812899d542e37ea931.tar.xz seaweedfs-e31c514b00b97c2db20232812899d542e37ea931.zip | |
adding modified time to file chunk
Diffstat (limited to 'weed/server')
| -rw-r--r-- | weed/server/filer_server_handlers_admin.go | 2 | ||||
| -rw-r--r-- | weed/server/filer_server_handlers_write.go | 3 |
2 files changed, 5 insertions, 0 deletions
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(), }, ) |