diff options
| author | Chris Lu <chris.lu@gmail.com> | 2021-09-08 15:54:55 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2021-09-08 15:54:55 -0700 |
| commit | 0207f5fe9b9339575a266d1db566ad8589f86318 (patch) | |
| tree | a4c085f788e73bea334b682323b414fc512a748d /weed/server/volume_grpc_remote.go | |
| parent | 00edcf71fcaae223eacf5677b768422b7a4dda11 (diff) | |
| download | seaweedfs-0207f5fe9b9339575a266d1db566ad8589f86318.tar.xz seaweedfs-0207f5fe9b9339575a266d1db566ad8589f86318.zip | |
replicated remote.cache
Diffstat (limited to 'weed/server/volume_grpc_remote.go')
| -rw-r--r-- | weed/server/volume_grpc_remote.go | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/weed/server/volume_grpc_remote.go b/weed/server/volume_grpc_remote.go index de7f2d594..aff57e52b 100644 --- a/weed/server/volume_grpc_remote.go +++ b/weed/server/volume_grpc_remote.go @@ -10,6 +10,7 @@ import ( "github.com/chrislusf/seaweedfs/weed/storage/needle" "github.com/chrislusf/seaweedfs/weed/storage/types" "sync" + "time" ) func (vs *VolumeServer) FetchAndWriteNeedle(ctx context.Context, req *volume_server_pb.FetchAndWriteNeedleRequest) (resp *volume_server_pb.FetchAndWriteNeedleResponse, err error) { @@ -44,6 +45,8 @@ func (vs *VolumeServer) FetchAndWriteNeedle(ctx context.Context, req *volume_ser // copied from *Needle.prepareWriteBuffer() n.Size = 4 + types.Size(n.DataSize) + 1 n.Checksum = needle.NewCRC(n.Data) + n.LastModified = uint64(time.Now().Unix()) + n.SetHasLastModifiedDate() if _, localWriteErr := vs.store.WriteVolumeNeedle(v.Id, n, true, false); localWriteErr != nil { if err == nil { err = fmt.Errorf("local write needle %d size %d: %v", req.NeedleId, req.Size, err) |