Pending count must be atomic, read and written from different threads

1 files changed, 3 insertions, 1 deletions

diff --git a/storage/src/tests/storageserver/testvisitormessagesession.h b/storage/src/tests/storageserver/testvisitormessagesession.h
index dc3bbef373c..a9d83ca6c1a 100644
--- a/storage/src/tests/storageserver/testvisitormessagesession.h
+++ b/storage/src/tests/storageserver/testvisitormessagesession.h
@@ -7,6 +7,8 @@
 #include <vespa/documentapi/messagebus/messages/documentmessage.h>
 #include <vespa/storage/storageserver/priorityconverter.h>
 #include <vespa/config/subscription/configuri.h>
+
+#include <atomic>
 #include <deque>
 
 namespace storage {
@@ -23,7 +25,7 @@ public:
 
     VisitorThread& thread;
     Visitor& visitor;
-    uint32_t pendingCount;
+    std::atomic<uint32_t> pendingCount;
 
     ~TestVisitorMessageSession();