diff options
| author | Chris Lu <chris.lu@gmail.com> | 2020-04-05 12:38:29 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2020-04-05 12:38:29 -0700 |
| commit | 2cb1700ecba037ffd83e329e098cf342bb1e6063 (patch) | |
| tree | f67077856ffd163d4da1a2d31f9258ab4d051e43 /weed | |
| parent | e78ee087e9f93373882cab286ad4aa20de67836d (diff) | |
| download | seaweedfs-2cb1700ecba037ffd83e329e098cf342bb1e6063.tar.xz seaweedfs-2cb1700ecba037ffd83e329e098cf342bb1e6063.zip | |
set to 4MB meta log buffer size
Diffstat (limited to 'weed')
| -rw-r--r-- | weed/queue/log_buffer.go | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/weed/queue/log_buffer.go b/weed/queue/log_buffer.go index 6ed2a719c..325fcbf48 100644 --- a/weed/queue/log_buffer.go +++ b/weed/queue/log_buffer.go @@ -27,7 +27,7 @@ type LogBuffer struct { func NewLogBuffer(flushInterval time.Duration, flushFn func(startTime, stopTime time.Time, buf []byte), notifyFn func()) *LogBuffer { lb := &LogBuffer{ - buf: make([]byte, 4*0124*1024), + buf: make([]byte, 4*1024*1024), sizeBuf: make([]byte, 4), flushInterval: flushInterval, flushFn: flushFn, @@ -97,7 +97,9 @@ func (m *LogBuffer) loopFlush() { } func (m *LogBuffer) flush() { + if m.flushFn != nil && m.pos > 0 { + // fmt.Printf("flush buffer %d pos %d empty space %d\n", len(m.buf), m.pos, len(m.buf)-m.pos) m.flushFn(m.startTime, m.stopTime, m.buf[:m.pos]) m.pos = 0 m.idx = m.idx[:0] |