|
@ -52,7 +52,7 @@ func (ma *MetaAggregator) subscribeToOneFiler(filer string, lastTsNs int64) { |
|
|
return err |
|
|
return err |
|
|
} |
|
|
} |
|
|
dir := event.Directory |
|
|
dir := event.Directory |
|
|
println("received meta change", dir, "size", len(data)) |
|
|
|
|
|
|
|
|
// println("received meta change", dir, "size", len(data))
|
|
|
ma.MetaLogBuffer.AddToBuffer([]byte(dir), data) |
|
|
ma.MetaLogBuffer.AddToBuffer([]byte(dir), data) |
|
|
return nil |
|
|
return nil |
|
|
} |
|
|
} |
|
|