diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-09-15 01:18:33 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-09-15 01:18:33 -0700 |
| commit | 10f908152682216189941f6b432ede8909c266b4 (patch) | |
| tree | e8d659d8ffb6d1f84b0f95e703ebd8512c17a3ff | |
| parent | 684a87587684da5aaa11933a5f739bca85fe8709 (diff) | |
| download | seaweedfs-10f908152682216189941f6b432ede8909c266b4.tar.xz seaweedfs-10f908152682216189941f6b432ede8909c266b4.zip | |
filer: adjust meta data events to received timestamp
if a client is already connected and start from t0. A message recieved at t+1 but with timestamp t-1 may not be processed by the client.
This commit changes to the event received time, so the replication can be ordered.
| -rw-r--r-- | weed/filer/meta_aggregator.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/filer/meta_aggregator.go b/weed/filer/meta_aggregator.go index e95b457a4..4918899ff 100644 --- a/weed/filer/meta_aggregator.go +++ b/weed/filer/meta_aggregator.go @@ -108,7 +108,7 @@ func (ma *MetaAggregator) subscribeToOneFiler(f *Filer, self string, peer string } dir := event.Directory // println("received meta change", dir, "size", len(data)) - ma.MetaLogBuffer.AddToBuffer([]byte(dir), data, event.TsNs) + ma.MetaLogBuffer.AddToBuffer([]byte(dir), data, 0) if maybeReplicateMetadataChange != nil { maybeReplicateMetadataChange(event) } |