github/kubernetes
4
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Fix potential mutex usage bug

Browse Source 
Signed-off-by: mantuliu <240951888@qq.com>
This commit is contained in:
mantuliu 2023-04-21 23:50:33 +08:00
parent 065428befa
commit 17db22d055
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
pkg/kubelet/pleg/evented.go
View File

@ -46,16 +46,16 @@ var (
// e.g. Streaming data issues from the runtime or the runtime does not implement the // e.g. Streaming data issues from the runtime or the runtime does not implement the
// container events stream. // container events stream.
func isEventedPLEGInUse() bool { func isEventedPLEGInUse() bool {
eventedPLEGUsageMu.Lock() eventedPLEGUsageMu.RLock()
defer eventedPLEGUsageMu.Unlock() defer eventedPLEGUsageMu.RUnlock()
return eventedPLEGUsage return eventedPLEGUsage
} }
// setEventedPLEGUsage should only be accessed from // setEventedPLEGUsage should only be accessed from
// Start/Stop of Evented PLEG. // Start/Stop of Evented PLEG.
func setEventedPLEGUsage(enable bool) { func setEventedPLEGUsage(enable bool) {
eventedPLEGUsageMu.RLock() eventedPLEGUsageMu.Lock()
defer eventedPLEGUsageMu.RUnlock() defer eventedPLEGUsageMu.Unlock()
eventedPLEGUsage = enable eventedPLEGUsage = enable
} }