WIP Async writing

Author: franzpoeschel

include/openPMD/toolkit/Aws.hpp

@@ -6,12 +6,16 @@
 
 namespace openPMD::internal
 {
+struct AwsAsyncHandler
+{};
+
 struct ExternalBlockStorageAws : ExternalBlockStorageBackend
 {
 private:
     Aws::S3::S3Client m_client;
     std::string m_bucketName;
     std::optional<std::string> m_endpoint;
+    std::optional<AwsAsyncHandler> m_async;
 
 public:
     ExternalBlockStorageAws(

src/toolkit/Aws.cpp

@@ -71,16 +71,40 @@ auto ExternalBlockStorageAws::put(
     put_request.SetBody(input_data);
     put_request.SetContentLength(static_cast<long long>(len));
 
-    auto put_outcome = m_client.PutObject(put_request);
-
-    if (put_outcome.IsSuccess())
+    if (!m_async.has_value())
     {
-        std::cout << "File uploaded successfully to S3!" << std::endl;
+        auto put_outcome = m_client.PutObject(put_request);
+
+        if (put_outcome.IsSuccess())
+        {
+            std::cout << "File uploaded successfully to S3!" << std::endl;
+        }
+        else
+        {
+            std::cerr << "Upload failed: "
+                      << put_outcome.GetError().GetMessage() << std::endl;
+        }
     }
     else
     {
-        std::cerr << "Upload failed: " << put_outcome.GetError().GetMessage()
-                  << std::endl;
+        auto responseReceivedHandler =
+            [](const Aws::S3::S3Client *,
+               const Aws::S3::Model::PutObjectRequest &,
+               const Aws::S3::Model::PutObjectOutcome &put_outcome,
+               const std::shared_ptr<const Aws::Client::AsyncCallerContext> &) {
+                if (put_outcome.IsSuccess())
+                {
+                    std::cout << "File uploaded successfully to S3!"
+                              << std::endl;
+                }
+                else
+                {
+                    std::cerr << "Upload failed: "
+                              << put_outcome.GetError().GetMessage()
+                              << std::endl;
+                }
+            };
+        m_client.PutObjectAsync(put_request, responseReceivedHandler);
     }
     return sanitized;
 }