VOL-3383 - concurrent data access issues
Change-Id: I0050a179dda293e62756e75c01328390ed1ca38c
diff --git a/rw_core/utils/request_queue.go b/rw_core/utils/request_queue.go
index 2c95e23..c96a6a0 100644
--- a/rw_core/utils/request_queue.go
+++ b/rw_core/utils/request_queue.go
@@ -88,7 +88,12 @@
return ctx.Err()
case <-waitingOn:
- // lock is acquired
+ // Previous request has signaled that it is complete.
+ // This request now can proceed as the active
+ // request
+
+ rq.mutex.Lock()
+ defer rq.mutex.Unlock()
rq.current = r
return nil
}