We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5945758 commit 426df23Copy full SHA for 426df23
db/db.go
@@ -454,8 +454,11 @@ func (l *Loader) HasTable(tableName string) bool {
454
}
455
456
// GetActiveFlushesNum returns the current number of in-flight async flushes.
457
-// This value is approximate and may be racy; it is intended for metrics only.
458
-func (l *Loader) GetActiveFlushesNum() int { return l.activeFlushes }
+func (l *Loader) GetActiveFlushesNum() int {
+ l.cond.L.Lock()
459
+ defer l.cond.L.Unlock()
460
+ return l.activeFlushes
461
+}
462
463
func (l *Loader) MarshalLogObject(encoder zapcore.ObjectEncoder) error {
464
encoder.AddUint64("entries_count", l.entriesCount)
0 commit comments