Mirroristas/planetmint-go
2
0
Fork 0
mirror of https://github.com/planetmint/planetmint-go.git synced 2025-11-24 06:25:47 +00:00
Code Issues Packages Projects Releases Wiki Activity

termintationMutex became a sync.RWMutex

Browse Source 
Signed-off-by: Jürgen Eckel <juergen@riddleandcode.com>
This commit is contained in:
Jürgen Eckel 2024-05-16 15:28:03 +02:00
parent a92fc79cd2
commit 8f379980e9
No known key found for this signature in database
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
monitor/mqtt_monitor.go
View File

@ -28,7 +28,7 @@ type MqttMonitor struct {
sdkContext *sdk.Context sdkContext *sdk.Context
contextMutex sync.Mutex contextMutex sync.Mutex
isTerminated bool isTerminated bool
terminationMutex sync.Mutex terminationMutex sync.RWMutex
maxRetries time.Duration maxRetries time.Duration
lostConnection bool lostConnection bool
lostConnectionMutex sync.Mutex lostConnectionMutex sync.Mutex
@ -43,9 +43,9 @@ func (mms *MqttMonitor) Terminate() {
} }
func (mms *MqttMonitor) IsTerminated() (isTerminated bool) { func (mms *MqttMonitor) IsTerminated() (isTerminated bool) {
mms.terminationMutex.Lock() mms.terminationMutex.RLock()
isTerminated = mms.isTerminated isTerminated = mms.isTerminated
mms.terminationMutex.Unlock() mms.terminationMutex.RUnlock()
return return
} }