gitlab-com-seaweedfs/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2024-01-19 02:48:24 +00:00
Code Issues Projects Releases Wiki Activity

rename

Browse source
This commit is contained in:
Chris Lu 2020-08-26 22:40:15 -07:00
parent 50f7e2e89f
commit 0be6863c87
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
weed/util/log_buffer/log_buffer.go
View file

@ -249,7 +249,7 @@ func (m *LogBuffer) ReadFromBuffer(lastReadTime time.Time) (bufferCopy *bytes.Bu
return nil return nil
} }
func (m *LogBuffer) ReleaseMeory(b *bytes.Buffer) { func (m *LogBuffer) ReleaseMemory(b *bytes.Buffer) {
bufferPool.Put(b) bufferPool.Put(b)
} }

4
weed/util/log_buffer/log_read.go
View file

@ -20,14 +20,14 @@ func (logBuffer *LogBuffer) LoopProcessLogData(
lastReadTime := startTreadTime lastReadTime := startTreadTime
defer func() { defer func() {
if bytesBuf != nil { if bytesBuf != nil {
logBuffer.ReleaseMeory(bytesBuf) logBuffer.ReleaseMemory(bytesBuf)
} }
}() }()
for { for {
if bytesBuf != nil { if bytesBuf != nil {
logBuffer.ReleaseMeory(bytesBuf) logBuffer.ReleaseMemory(bytesBuf)
} }
bytesBuf = logBuffer.ReadFromBuffer(lastReadTime) bytesBuf = logBuffer.ReadFromBuffer(lastReadTime)
// fmt.Printf("ReadFromBuffer by %v\n", lastReadTime) // fmt.Printf("ReadFromBuffer by %v\n", lastReadTime)