Fix a race in daemon/logger.TestCopier
Update #22963 Signed-off-by: Akihiro Suda <suda.akihiro@lab.ntt.co.jp> Upstream-commit: ab533f06510a14a023c056604f9520741073acd3 Component: engine
This commit is contained in:
@ -4,12 +4,14 @@ import (
|
||||
"bytes"
|
||||
"encoding/json"
|
||||
"io"
|
||||
"sync"
|
||||
"testing"
|
||||
"time"
|
||||
)
|
||||
|
||||
type TestLoggerJSON struct {
|
||||
*json.Encoder
|
||||
mu sync.Mutex
|
||||
delay time.Duration
|
||||
}
|
||||
|
||||
@ -17,6 +19,8 @@ func (l *TestLoggerJSON) Log(m *Message) error {
|
||||
if l.delay > 0 {
|
||||
time.Sleep(l.delay)
|
||||
}
|
||||
l.mu.Lock()
|
||||
defer l.mu.Unlock()
|
||||
return l.Encode(m)
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user