JSON output: use std::atomic<bool> to ensure memory synchronization between threads.

Author: norrisjeremy

src/plugins/output/json/src/File.hpp

@@ -42,6 +42,7 @@
 #ifndef JSON_FILE_H
 #define JSON_FILE_H
 
+#include <atomic>
 #include <string>
 #include <ctime>
 #include <cstdio>
@@ -72,7 +73,7 @@ class File : public Output {
         ipx_ctx_t *ctx;              /**< Plugin instance context    */
         pthread_t thread;            /**< Thread                     */
         pthread_rwlock_t rwlock;     /**< Data rwlock                */
-        bool stop;                   /**< Stop flag for termination  */
+        std::atomic<bool> stop;      /**< Stop flag for termination  */
 
         unsigned int window_size;    /**< Size of a time window      */
         time_t window_time;          /**< Current time window        */

src/plugins/output/json/src/Server.hpp

@@ -40,6 +40,7 @@
 #ifndef JSON_SERVER_H
 #define JSON_SERVER_H
 
+#include <atomic>
 #include <string>
 #include <vector>
 #include <pthread.h>
@@ -78,10 +79,10 @@ class Server : public Output
         ipx_ctx_t *ctx;                     /**< Instance context (for log only ) */
         pthread_t thread;					/**< Thread                           */
         pthread_mutex_t mutex;              /**< Mutex for the array              */
-        bool stop;                          /**< Stop flag for terminating        */
+        std::atomic<bool> stop;             /**< Stop flag for terminating        */
 
         int socket_fd;                      /**< Server socket                    */
-        bool new_clients_ready;             /**< New clients flag                 */
+        std::atomic<bool> new_clients_ready; /**< New clients flag                 */
         std::vector<client_t> new_clients;  /**< Array of new clients             */
     } acceptor_t;