Abort TLogWrite requests properly (#11665)

Author: va-kuznecov

ydb/core/blobstorage/pdisk/blobstorage_pdisk_requestimpl.cpp

@@ -25,6 +25,15 @@ void TRequestBase::AbortDelete(TRequestBase* request, TActorSystem* actorSystem)
         request->Abort(actorSystem);
         break;
     }
+    case ERequestType::RequestLogWrite:
+    {
+        auto* log = static_cast<TLogWrite*>(request);
+        while (log) {
+            auto batch = log->PopFromBatch();
+            log->Abort(actorSystem);
+            log = batch;
+        }
+    }
     default:
         request->Abort(actorSystem);
         delete request;

ydb/core/blobstorage/pdisk/blobstorage_pdisk_requestimpl.h

@@ -344,7 +344,9 @@ class TLogWrite : public TRequestBase {
     }
 
     void Abort(TActorSystem* actorSystem) override {
-        actorSystem->Send(Sender, new NPDisk::TEvLogResult(NKikimrProto::CORRUPTED, 0, "TLogWrite is being aborted"));
+        auto *result = new NPDisk::TEvLogResult(NKikimrProto::CORRUPTED, 0, "TLogWrite is being aborted");
+        result->Results.emplace_back(Lsn, Cookie);
+        actorSystem->Send(Sender, result);
     }
 
     TString ToString() const {

ydb/core/blobstorage/pdisk/blobstorage_pdisk_ut.cpp

@@ -1023,11 +1023,7 @@ Y_UNIT_TEST_SUITE(TPDiskTest) {
 
             for (ui32 i = 0; i < 100;) {
                 auto result = testCtx.Recv<NPDisk::TEvLogResult>();
-                if (result->Status == NKikimrProto::OK) {
-                    i += result->Results.size();
-                } else {
-                    ++i;
-                }
+                i += result->Results.size();
             }
             Cerr << "all log writes are received" << Endl;
         }