|
@ -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)
|
|
|