From 51918a37074cd68850213d79f6a22fa76445fea2 Mon Sep 17 00:00:00 2001
From: Andrej Babic <andrej.babic@psi.ch>
Date: Tue, 9 Jun 2020 10:19:05 +0200
Subject: [PATCH] Change atomic type to int

---
 sf-stream/include/FastQueue.hpp | 4 ++--
 sf-stream/src/FastQueue.cpp     | 1 -
 2 files changed, 2 insertions(+), 3 deletions(-)

diff --git a/sf-stream/include/FastQueue.hpp b/sf-stream/include/FastQueue.hpp
index 95c1331..916b838 100644
--- a/sf-stream/include/FastQueue.hpp
+++ b/sf-stream/include/FastQueue.hpp
@@ -12,8 +12,8 @@ class FastQueue {
     char* buffer_;
     std::atomic_int* buffer_status_;
 
-    std::atomic_uint16_t write_slot_id_;
-    std::atomic_uint16_t read_slot_id_;
+    std::atomic_int write_slot_id_;
+    std::atomic_int read_slot_id_;
 
 public:
 
diff --git a/sf-stream/src/FastQueue.cpp b/sf-stream/src/FastQueue.cpp
index 1db833e..1a67664 100644
--- a/sf-stream/src/FastQueue.cpp
+++ b/sf-stream/src/FastQueue.cpp
@@ -15,7 +15,6 @@ FastQueue<T>::FastQueue(
     buffer_ = new char[slot_n_bytes_ * n_slots_];
     buffer_status_ = new atomic_int[n_slots];
 
-    // TODO: Are atomic variables initialized?
     for (size_t i=0; i < n_slots_; i++) {
         buffer_status_[i] = 0;
     }