[SDK] Valgrind errors on std::atomic variables

exporters/elasticsearch/include/opentelemetry/exporters/elasticsearch/es_log_record_exporter.h

@@ -125,8 +125,8 @@ class ElasticsearchLogRecordExporter final : public opentelemetry::sdk::logs::Lo
 # ifdef ENABLE_ASYNC_EXPORT
  struct SynchronizationData
  {
- std::atomic<std::size_t> session_counter_;
- std::atomic<std::size_t> finished_session_counter_;
+ std::atomic<std::size_t> session_counter_{0};
+ std::atomic<std::size_t> finished_session_counter_{0};
  std::condition_variable force_flush_cv;
  std::mutex force_flush_cv_m;
  std::recursive_mutex force_flush_m;

exporters/otlp/src/otlp_http_client.cc

@@ -64,7 +64,7 @@ namespace
 {
 
 /**
- * This class handles the response message from the Elasticsearch request
+ * This class handles the response message from the HTTP request
  */
 class ResponseHandler : public http_client::EventHandler
 {
@@ -75,9 +75,7 @@ class ResponseHandler : public http_client::EventHandler
  ResponseHandler(std::function<bool(opentelemetry::sdk::common::ExportResult)> &&callback,
  bool console_debug = false)
  : result_callback_{std::move(callback)}, console_debug_{console_debug}
- {
- stopping_.store(false);
- }
+ {}
 
  std::string BuildResponseLogMessage(http_client::Response &response,
  const std::string &body) noexcept
@@ -356,7 +354,7 @@ class ResponseHandler : public http_client::EventHandler
  const opentelemetry::ext::http::client::Session *session_ = nullptr;
 
  // Whether notify has been called
- std::atomic<bool> stopping_;
+ std::atomic<bool> stopping_{false};
 
  // A string to store the response body
  std::string body_ = "";

ext/include/opentelemetry/ext/http/client/curl/http_client_curl.h

@@ -159,7 +159,7 @@ class Session : public opentelemetry::ext::http::client::Session,
  std::string scheme = "http",
  const std::string &host = "",
  uint16_t port = 80)
- : http_client_(http_client), is_session_active_(false)
+ : http_client_(http_client)
  {
  host_ = scheme + "://" + host + ":" + std::to_string(port) + "/";
  }
@@ -216,7 +216,7 @@ class Session : public opentelemetry::ext::http::client::Session,
  std::unique_ptr<HttpOperation> curl_operation_;
  uint64_t session_id_;
  HttpClient &http_client_;
- std::atomic<bool> is_session_active_;
+ std::atomic<bool> is_session_active_{false};
 };
 
 class HttpClientSync : public opentelemetry::ext::http::client::HttpClientSync
@@ -352,7 +352,7 @@ class HttpClient : public opentelemetry::ext::http::client::HttpClient
 
  std::mutex multi_handle_m_;
  CURLM *multi_handle_;
- std::atomic<uint64_t> next_session_id_;
+ std::atomic<uint64_t> next_session_id_{0};
  uint64_t max_sessions_per_connection_;
 
  std::mutex sessions_m_;

ext/include/opentelemetry/ext/http/client/curl/http_operation_curl.h

@@ -273,11 +273,11 @@ class HttpOperation
 
  const char *GetCurlErrorMessage(CURLcode code);
 
- std::atomic<bool> is_aborted_; // Set to 'true' when async callback is aborted
- std::atomic<bool> is_finished_; // Set to 'true' when async callback is finished.
- std::atomic<bool> is_cleaned_; // Set to 'true' when async callback is cleaned.
- const bool is_raw_response_; // Do not split response headers from response body
- const bool reuse_connection_; // Reuse connection
+ std::atomic<bool> is_aborted_{false}; // Set to 'true' when async callback is aborted
+ std::atomic<bool> is_finished_{false}; // Set to 'true' when async callback is finished.
+ std::atomic<bool> is_cleaned_{false}; // Set to 'true' when async callback is cleaned.
+ const bool is_raw_response_;  // Do not split response headers from response body
+ const bool reuse_connection_;  // Reuse connection
  const std::chrono::milliseconds http_conn_timeout_; // Timeout for connect. Default: 5000ms
 
  char curl_error_message_[CURL_ERROR_SIZE];
@@ -311,7 +311,7 @@ class HttpOperation
 
  std::thread::id callback_thread;
  std::function<void(HttpOperation &)> callback;
- std::atomic<bool> is_promise_running;
+ std::atomic<bool> is_promise_running{false};
  std::promise<CURLcode> result_promise;
  std::future<CURLcode> result_future;
  };

ext/include/opentelemetry/ext/zpages/tracez_data_aggregator.h

@@ -155,7 +155,7 @@ class TracezDataAggregator
 
  /** A boolean that is set to true in the constructor and false in the
  * destructor to start and end execution of aggregate spans **/
- std::atomic<bool> execute_;
+ std::atomic<bool> execute_{false};
 
  /** Thread that executes aggregate spans at regurlar intervals during this
  object's lifetime**/

ext/test/http/curl_http_test.cc

@@ -99,8 +99,8 @@ class BasicCurlHttpTests : public ::testing::Test, public HTTP_SERVER_NS::HttpRe
 protected:
  HTTP_SERVER_NS::HttpServer server_;
  std::string server_address_;
- std::atomic<bool> is_setup_;
- std::atomic<bool> is_running_;
+ std::atomic<bool> is_setup_{false};
+ std::atomic<bool> is_running_{false};
  std::vector<HTTP_SERVER_NS::HttpRequest> received_requests_;
  std::mutex mtx_requests;
  std::condition_variable cv_got_events;

sdk/include/opentelemetry/sdk/logs/batch_log_record_processor.h

@@ -115,11 +115,11 @@ class BatchLogRecordProcessor : public LogRecordProcessor
  std::mutex cv_m, force_flush_cv_m, shutdown_m;
 
  /* Important boolean flags to handle the workflow of the processor */
- std::atomic<bool> is_force_wakeup_background_worker;
- std::atomic<bool> is_force_flush_pending;
- std::atomic<bool> is_force_flush_notified;
- std::atomic<std::chrono::microseconds::rep> force_flush_timeout_us;
- std::atomic<bool> is_shutdown;
+ std::atomic<bool> is_force_wakeup_background_worker{false};
+ std::atomic<bool> is_force_flush_pending{false};
+ std::atomic<bool> is_force_flush_notified{false};
+ std::atomic<std::chrono::microseconds::rep> force_flush_timeout_us{0};
+ std::atomic<bool> is_shutdown{false};
  };
 
  /**

sdk/include/opentelemetry/sdk/logs/simple_log_record_processor.h

@@ -53,7 +53,7 @@ class SimpleLogRecordProcessor : public LogRecordProcessor
  // The lock used to ensure the exporter is not called concurrently
  opentelemetry::common::SpinLockMutex lock_;
  // The atomic boolean to ensure the ShutDown() function is only called once
- std::atomic<bool> is_shutdown_;
+ std::atomic<bool> is_shutdown_{false};
 };
 } // namespace logs
 } // namespace sdk

sdk/include/opentelemetry/sdk/metrics/export/periodic_exporting_metric_reader.h

@@ -50,9 +50,9 @@ class PeriodicExportingMetricReader : public MetricReader
  std::thread worker_thread_;
 
  /* Synchronization primitives */
- std::atomic<bool> is_force_flush_pending_;
- std::atomic<bool> is_force_wakeup_background_worker_;
- std::atomic<bool> is_force_flush_notified_;
+ std::atomic<bool> is_force_flush_pending_{false};
+ std::atomic<bool> is_force_wakeup_background_worker_{false};
+ std::atomic<bool> is_force_flush_notified_{false};
  std::condition_variable cv_, force_flush_cv_;
  std::mutex cv_m_, force_flush_m_;
 };

sdk/include/opentelemetry/sdk/trace/batch_span_processor.h

@@ -114,11 +114,11 @@ class BatchSpanProcessor : public SpanProcessor
  std::mutex cv_m, force_flush_cv_m, shutdown_m;
 
  /* Important boolean flags to handle the workflow of the processor */
- std::atomic<bool> is_force_wakeup_background_worker;
- std::atomic<bool> is_force_flush_pending;
- std::atomic<bool> is_force_flush_notified;
- std::atomic<std::chrono::microseconds::rep> force_flush_timeout_us;
- std::atomic<bool> is_shutdown;
+ std::atomic<bool> is_force_wakeup_background_worker{false};
+ std::atomic<bool> is_force_flush_pending{false};
+ std::atomic<bool> is_force_flush_notified{false};
+ std::atomic<std::chrono::microseconds::rep> force_flush_timeout_us{0};
+ std::atomic<bool> is_shutdown{false};
  };
 
  /**

sdk/src/logs/batch_log_record_processor.cc

@@ -30,12 +30,7 @@ BatchLogRecordProcessor::BatchLogRecordProcessor(
  buffer_(max_queue_size_),
  synchronization_data_(std::make_shared<SynchronizationData>()),
  worker_thread_(&BatchLogRecordProcessor::DoBackgroundWork, this)
-{
- synchronization_data_->is_force_wakeup_background_worker.store(false);
- synchronization_data_->is_force_flush_pending.store(false);
- synchronization_data_->is_force_flush_notified.store(false);
- synchronization_data_->is_shutdown.store(false);
-}
+{}
 
 BatchLogRecordProcessor::BatchLogRecordProcessor(std::unique_ptr<LogRecordExporter> &&exporter,
  const BatchLogRecordProcessorOptions &options)
@@ -46,13 +41,7 @@ BatchLogRecordProcessor::BatchLogRecordProcessor(std::unique_ptr<LogRecordExport
  buffer_(options.max_queue_size),
  synchronization_data_(std::make_shared<SynchronizationData>()),
  worker_thread_(&BatchLogRecordProcessor::DoBackgroundWork, this)
-{
- synchronization_data_->is_force_wakeup_background_worker.store(false);
- synchronization_data_->is_force_flush_pending.store(false);
- synchronization_data_->is_force_flush_notified.store(false);
- synchronization_data_->force_flush_timeout_us.store(0);
- synchronization_data_->is_shutdown.store(false);
-}
+{}
 
 std::unique_ptr<Recordable> BatchLogRecordProcessor::MakeRecordable() noexcept
 {

sdk/src/trace/batch_span_processor.cc

@@ -31,13 +31,7 @@ BatchSpanProcessor::BatchSpanProcessor(std::unique_ptr<SpanExporter> &&exporter,
  buffer_(max_queue_size_),
  synchronization_data_(std::make_shared<SynchronizationData>()),
  worker_thread_(&BatchSpanProcessor::DoBackgroundWork, this)
-{
- synchronization_data_->is_force_wakeup_background_worker.store(false);
- synchronization_data_->is_force_flush_pending.store(false);
- synchronization_data_->is_force_flush_notified.store(false);
- synchronization_data_->force_flush_timeout_us.store(0);
- synchronization_data_->is_shutdown.store(false);
-}
+{}
 
 std::unique_ptr<Recordable> BatchSpanProcessor::MakeRecordable() noexcept
 {