Merge branch 'master' into mq-subscribe
This commit is contained in:
@@ -166,7 +166,7 @@ func (logBuffer *LogBuffer) loopInterval() {
|
|||||||
toFlush := logBuffer.copyToFlush()
|
toFlush := logBuffer.copyToFlush()
|
||||||
logBuffer.Unlock()
|
logBuffer.Unlock()
|
||||||
if toFlush != nil {
|
if toFlush != nil {
|
||||||
glog.V(0).Infof("%s flush [%v, %v] size %d", logBuffer.name, toFlush.startTime, toFlush.stopTime, len(toFlush.data.Bytes()))
|
glog.V(4).Infof("%s flush [%v, %v] size %d", logBuffer.name, toFlush.startTime, toFlush.stopTime, len(toFlush.data.Bytes()))
|
||||||
logBuffer.flushChan <- toFlush
|
logBuffer.flushChan <- toFlush
|
||||||
} else {
|
} else {
|
||||||
// glog.V(0).Infof("%s no flush", m.name)
|
// glog.V(0).Infof("%s no flush", m.name)
|
||||||
|
|||||||
Reference in New Issue
Block a user