diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-16 02:55:09 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-16 02:55:09 -0700 |
| commit | f5a748d33c52a2874dbde92746a03140ef379296 (patch) | |
| tree | 21a9bdf9c329a94249ca026e2aa04647c414beb4 /weed/util/log_buffer/log_buffer.go | |
| parent | ce4b369be25f61be0810e2bc119964b613cca121 (diff) | |
| download | seaweedfs-f5a748d33c52a2874dbde92746a03140ef379296.tar.xz seaweedfs-f5a748d33c52a2874dbde92746a03140ef379296.zip | |
refactoring
Diffstat (limited to 'weed/util/log_buffer/log_buffer.go')
| -rw-r--r-- | weed/util/log_buffer/log_buffer.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/util/log_buffer/log_buffer.go b/weed/util/log_buffer/log_buffer.go index 04fabdf8c..c7cb90549 100644 --- a/weed/util/log_buffer/log_buffer.go +++ b/weed/util/log_buffer/log_buffer.go @@ -51,7 +51,7 @@ func NewLogBuffer(flushInterval time.Duration, flushFn func(startTime, stopTime return lb } -func (m *LogBuffer) AddToBuffer(key, data []byte) { +func (m *LogBuffer) AddToBuffer(partitionKey, data []byte) { m.Lock() defer func() { @@ -65,7 +65,7 @@ func (m *LogBuffer) AddToBuffer(key, data []byte) { ts := time.Now() logEntry := &filer_pb.LogEntry{ TsNs: ts.UnixNano(), - PartitionKeyHash: util.HashToInt32(key), + PartitionKeyHash: util.HashToInt32(partitionKey), Data: data, } |