diff --git a/libraries/net/node.cpp b/libraries/net/node.cpp index 990d1f0b..419e095a 100644 --- a/libraries/net/node.cpp +++ b/libraries/net/node.cpp @@ -559,14 +559,14 @@ namespace graphene { namespace net { namespace detail { peer_database _potential_peer_db; fc::promise::ptr _retrigger_connect_loop_promise; - bool _potential_peer_database_updated; + std::atomic_bool _potential_peer_database_updated; fc::future _p2p_network_connect_loop_done; // @} /// used by the task that fetches sync items during synchronization // @{ fc::promise::ptr _retrigger_fetch_sync_items_loop_promise; - bool _sync_items_to_fetch_updated; + std::atomic_bool _sync_items_to_fetch_updated; fc::future _fetch_sync_items_loop_done; typedef std::unordered_map active_sync_requests_map; @@ -576,13 +576,13 @@ namespace graphene { namespace net { namespace detail { std::list _received_sync_items; /// list of sync blocks we've received, but can't yet process because we are still missing blocks that come earlier in the chain // @} - fc::future _process_backlog_of_sync_blocks_done; - bool _suspend_fetching_sync_blocks; + fc::future _process_backlog_of_sync_blocks_done; + std::atomic_bool _suspend_fetching_sync_blocks; /// used by the task that fetches items during normal operation // @{ fc::promise::ptr _retrigger_fetch_item_loop_promise; - bool _items_to_fetch_updated; + std::atomic_bool _items_to_fetch_updated; fc::future _fetch_item_loop_done; struct item_id_index{};