[#598 ] Hold mode mutex when setting mode

Signed-off-by: Alejandro Lopez <a.lopez@yadro.com>
2023-08-11 16:43:23 +03:00
2 changed files with 6 additions and 0 deletions
--- a/pkg/local_object_storage/writecache/writecachebadger/mode.go
+++ b/pkg/local_object_storage/writecache/writecachebadger/mode.go
@ -22,6 +22,9 @@ func (c *cache) SetMode(m mode.Mode) error {
 		))
 	defer span.End()

+	c.modeMtx.Lock()
+	defer c.modeMtx.Unlock()
+
 	err := c.setMode(ctx, m)
 	if err == nil {
 		c.metrics.SetMode(m)
--- a/pkg/local_object_storage/writecache/writecachebbolt/mode.go
+++ b/pkg/local_object_storage/writecache/writecachebbolt/mode.go
@ -22,6 +22,9 @@ func (c *cache) SetMode(m mode.Mode) error {
 		))
 	defer span.End()

+	c.modeMtx.Lock()
+	defer c.modeMtx.Unlock()
+
 	err := c.setMode(ctx, m)
 	if err == nil {
 		c.metrics.SetMode(m)