issue-1922: making background ops' read/writeblob requests async (#1996)

ydb-platform · Sep 10, 2024 · ea883f6 · ea883f6
1 parent 84329d3
commit ea883f6
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 0 deletions.
diff --git a/cloud/filestore/libs/storage/tablet/tablet_actor_compaction.cpp b/cloud/filestore/libs/storage/tablet/tablet_actor_compaction.cpp
@@ -163,6 +163,7 @@ void TCompactionActor::ReadBlob(const TActorContext& ctx)
                 BlockSize
             ));
             request->Blobs.emplace_back(blob.BlobId, std::move(blocks));
+            request->Blobs.back().Async = true;
 
             Buffers[blob.BlobId] = request->Buffer;
 
@@ -204,6 +205,7 @@ void TCompactionActor::WriteBlob(const TActorContext& ctx)
         }
 
         request->Blobs.emplace_back(blob.BlobId, std::move(blobContent));
+        request->Blobs.back().Async = true;
     }
 
     NCloud::Send(ctx, Tablet, std::move(request));

diff --git a/cloud/filestore/libs/storage/tablet/tablet_actor_flush.cpp b/cloud/filestore/libs/storage/tablet/tablet_actor_flush.cpp
@@ -116,6 +116,7 @@ void TFlushActor::WriteBlob(const TActorContext& ctx)
 
     for (auto& blob: Blobs) {
         request->Blobs.emplace_back(blob.BlobId, std::move(blob.BlobContent));
+        request->Blobs.back().Async = true;
     }
 
     NCloud::Send(ctx, Tablet, std::move(request));

diff --git a/cloud/filestore/libs/storage/tablet/tablet_actor_flush_bytes.cpp b/cloud/filestore/libs/storage/tablet/tablet_actor_flush_bytes.cpp
@@ -258,6 +258,7 @@ void TFlushBytesActor::ReadBlobs(const TActorContext& ctx)
                 BlockSize
             ));
             request->Blobs.emplace_back(blobToRead.BlobId, std::move(blocks));
+            request->Blobs.back().Async = true;
 
             Buffers[blobToRead.BlobId] = request->Buffer;
 
@@ -324,6 +325,7 @@ void TFlushBytesActor::WriteBlob(const TActorContext& ctx)
         }
 
         request->Blobs.emplace_back(blob.BlobId, std::move(blobContent));
+        request->Blobs.back().Async = true;
     }
 
     NCloud::Send(ctx, Tablet, std::move(request));