build: work around atomic<bool> absence on riscv64

riscv64 only has instructions for atomic<int32_t> (amoswap.w.aq) and
atomic<long> (amoswap.d.aq), requiring library support for 8/16-bit
quantities, which usually involves a mutex. Just pick a larger memory
cell than waiting on such a mutex.

Author: jengelh

exch/exchange_emsmdb/asyncemsmdb_interface.cpp

@@ -1,11 +1,11 @@
 // SPDX-License-Identifier: GPL-2.0-only WITH linking exception
-#include <atomic>
 #include <condition_variable>
 #include <csignal>
 #include <cstring>
 #include <mutex>
 #include <libHX/defs.h>
 #include <libHX/string.h>
+#include <gromox/atomic.hpp>
 #include <gromox/defs.h>
 #include "asyncemsmdb_interface.h"
 #include "emsmdb_interface.h"
@@ -43,7 +43,7 @@ static constexpr size_t TAG_SIZE = UADDR_SIZE + 1 + HXSIZEOF_Z32;
 static int g_threads_num;
 static pthread_t g_scan_id;
 static pthread_t *g_thread_ids;
-static std::atomic<bool> g_notify_stop{true};
+static gromox::atomic_bool g_notify_stop{true};
 static DOUBLE_LIST g_wakeup_list;
 static STR_HASH_TABLE *g_tag_hash;
 static std::mutex g_list_lock, g_async_lock;

exch/exchange_emsmdb/emsmdb_interface.cpp

@@ -1,9 +1,9 @@
 // SPDX-License-Identifier: GPL-2.0-only WITH linking exception
-#include <atomic>
 #include <csignal>
 #include <cstdint>
 #include <mutex>
 #include <libHX/string.h>
+#include <gromox/atomic.hpp>
 #include <gromox/defs.h>
 #include "asyncemsmdb_interface.h"
 #include "emsmdb_interface.h"
@@ -76,7 +76,7 @@ static constexpr size_t TAG_SIZE = 256;
 static time_t g_start_time;
 static pthread_t g_scan_id;
 static std::mutex g_lock, g_notify_lock;
-static std::atomic<bool> g_notify_stop{true};
+static gromox::atomic_bool g_notify_stop{true};
 static pthread_key_t g_handle_key;
 static STR_HASH_TABLE *g_user_hash;
 static STR_HASH_TABLE *g_handle_hash;

exch/exchange_emsmdb/rop_processor.cpp

@@ -1,9 +1,9 @@
 // SPDX-License-Identifier: GPL-2.0-only WITH linking exception
-#include <atomic>
 #include <csignal>
 #include <cstdint>
 #include <cstring>
 #include <mutex>
+#include <gromox/atomic.hpp>
 #include <gromox/defs.h>
 #include "subscription_object.h"
 #include "fastdownctx_object.h"
@@ -64,7 +64,7 @@ struct OBJECT_NODE {
 static int g_scan_interval;
 static pthread_t g_scan_id;
 static int g_average_handles;
-static std::atomic<bool> g_notify_stop{true};
+static gromox::atomic_bool g_notify_stop{true};
 static std::mutex g_hash_lock;
 static STR_HASH_TABLE *g_logon_hash;
 static LIB_BUFFER *g_logmap_allocator;

exch/exchange_nsp/ab_tree.cpp

@@ -1,7 +1,6 @@
 // SPDX-License-Identifier: GPL-2.0-only WITH linking exception
 // SPDX-FileCopyrightText: 2021 grommunio GmbH
 // This file is part of Gromox.
-#include <atomic>
 #include <cstdint>
 #include <memory>
 #include <mutex>
@@ -11,6 +10,7 @@
 #include <utility>
 #include <vector>
 #include <libHX/string.h>
+#include <gromox/atomic.hpp>
 #include <gromox/defs.h>
 #include <gromox/fileio.h>
 #include <gromox/util.hpp>
@@ -82,7 +82,7 @@ struct ab_sort_item {
 
 static size_t g_base_size;
 static int g_file_blocks, g_ab_cache_interval;
-static std::atomic<bool> g_notify_stop{false};
+static gromox::atomic_bool g_notify_stop{false};
 static pthread_t g_scan_id;
 static char g_nsp_org_name[256];
 static std::unordered_map<int, AB_BASE> g_base_hash;

exch/exmdb_provider/db_engine.cpp

@@ -1,5 +1,4 @@
 // SPDX-License-Identifier: GPL-2.0-only WITH linking exception
-#include <atomic>
 #include <chrono>
 #include <csignal>
 #include <cstdint>
@@ -8,6 +7,7 @@
 #include <string>
 #include <unordered_map>
 #include <vector>
+#include <gromox/atomic.hpp>
 #include <gromox/database.h>
 #include <gromox/exmdb_rpc.hpp>
 #include <gromox/mapidefs.h>
@@ -95,7 +95,7 @@ static BOOL g_wal;
 static BOOL g_async;
 static size_t g_table_size; /* hash table size */
 static int g_threads_num;
-static std::atomic<bool> g_notify_stop{false}; /* stop signal for scaning thread */
+static gromox::atomic_bool g_notify_stop{false}; /* stop signal for scaning thread */
 static pthread_t g_scan_tid;
 static uint64_t g_mmap_size;
 static int g_cache_interval;	/* maximum living interval in table */

exch/exmdb_provider/exmdb_client.cpp

@@ -2,7 +2,6 @@
 // SPDX-FileCopyrightText: 2021 grommunio GmbH
 // This file is part of Gromox.
 #include <algorithm>
-#include <atomic>
 #include <list>
 #include <cstdint>
 #include <list>
@@ -11,6 +10,7 @@
 #include <utility>
 #include <vector>
 #include <libHX/string.h>
+#include <gromox/atomic.hpp>
 #include <gromox/defs.h>
 #include <gromox/exmdb_rpc.hpp>
 #include <gromox/socket.h>
@@ -73,7 +73,7 @@ static int cl_wr_sock(int fd, const BINARY *b) { return exmdb_client_write_socke
 
 static int g_conn_num;
 static int g_threads_num;
-static std::atomic<bool> g_notify_stop{false};
+static gromox::atomic_bool g_notify_stop{false};
 static pthread_t g_scan_id;
 static std::list<REMOTE_CONN> g_lost_list;
 static std::list<AGENT_THREAD> g_agent_list;

exch/exmdb_provider/exmdb_listener.cpp

@@ -1,13 +1,13 @@
 // SPDX-License-Identifier: GPL-2.0-only WITH linking exception
 #include <algorithm>
-#include <atomic>
 #include <cerrno>
 #include <csignal>
 #include <cstdint>
 #include <string>
 #include <utility>
 #include <vector>
 #include <libHX/string.h>
+#include <gromox/atomic.hpp>
 #include <gromox/defs.h>
 #include <gromox/exmdb_rpc.hpp>
 #include <gromox/socket.h>
@@ -29,7 +29,7 @@ using namespace gromox;
 
 static uint16_t g_listen_port;
 static int g_listen_sockd;
-static std::atomic<bool> g_notify_stop{false};
+static gromox::atomic_bool g_notify_stop{false};
 static char g_listen_ip[40];
 static std::vector<std::string> g_acl_list;
 static pthread_t g_listener_id;

exch/exmdb_provider/exmdb_parser.h

@@ -1,9 +1,9 @@
 #pragma once
-#include <atomic>
 #include <condition_variable>
 #include <memory>
 #include <mutex>
 #include <string>
+#include <gromox/atomic.hpp>
 #include <gromox/common_types.hpp>
 #include <gromox/double_list.hpp>
 #include <pthread.h>
@@ -19,7 +19,7 @@ class EXMDB_CONNECTION : public std::enable_shared_from_this<EXMDB_CONNECTION> {
 	~EXMDB_CONNECTION();
 	void operator=(EXMDB_CONNECTION &&) = delete;
 
-	std::atomic<bool> b_stop{false};
+	gromox::atomic_bool b_stop{false};
 	pthread_t thr_id{};
 	std::string remote_id;
 	int sockd = -1;
@@ -31,7 +31,7 @@ struct ROUTER_CONNECTION {
 	~ROUTER_CONNECTION();
 	void operator=(ROUTER_CONNECTION &&) = delete;
 
-	std::atomic<bool> b_stop{false};
+	gromox::atomic_bool b_stop{false};
 	pthread_t thr_id{};
 	std::string remote_id;
 	int sockd = -1;

exch/http/http_parser.cpp

@@ -4,7 +4,6 @@
 /* http parser is a module, which first read data from socket, parses rpc over http and
    relay the stream to pdu processor. it also process other http request
  */ 
-#include <atomic>
 #include <cassert>
 #include <cerrno>
 #include <mutex>
@@ -13,6 +12,7 @@
 #include <utility>
 #include <vector>
 #include <libHX/string.h>
+#include <gromox/atomic.hpp>
 #include <gromox/defs.h>
 #include <gromox/fileio.h>
 #include <gromox/util.hpp>
@@ -81,7 +81,7 @@ class VCONN_REF {
 }
 
 static size_t g_context_num;
-static std::atomic<bool> g_async_stop{false};
+static gromox::atomic_bool g_async_stop{false};
 static BOOL g_support_ssl;
 static SSL_CTX *g_ssl_ctx;
 static int g_max_auth_times;

exch/http/listener.cpp

@@ -5,11 +5,11 @@
  *    connection is legal, construct a context to represent the connection and 
  *    throw it into contexts pool, or close the connection
  */
-#include <atomic>
 #include <cerrno>
 #include <csignal>
 #include <cstdint>
 #include <libHX/string.h>
+#include <gromox/atomic.hpp>
 #include <gromox/fileio.h>
 #include <gromox/socket.h>
 #include "listener.h"
@@ -33,7 +33,7 @@ static void *htls_thrwork(void *);
 static void *htls_thrworkssl(void *);
 
 static int g_mss_size;
-static std::atomic<bool> g_stop_accept{false};
+static gromox::atomic_bool g_stop_accept{false};
 static pthread_t g_thr_id;
 static int g_listener_sock;
 static uint16_t g_listener_port, g_listener_ssl_port;