Skip to content

Commit c92cad7

Browse files
authored
Merge 7193e8e into ec02f9b
2 parents ec02f9b + 7193e8e commit c92cad7

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

ydb/core/blobstorage/pdisk/blobstorage_pdisk_requestimpl.cpp

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -25,6 +25,15 @@ void TRequestBase::AbortDelete(TRequestBase* request, TActorSystem* actorSystem)
2525
request->Abort(actorSystem);
2626
break;
2727
}
28+
case ERequestType::RequestLogWrite:
29+
{
30+
auto* log = static_cast<TLogWrite*>(request);
31+
while (log) {
32+
auto batch = log->PopFromBatch();
33+
log->Abort(actorSystem);
34+
log = batch;
35+
}
36+
}
2837
default:
2938
request->Abort(actorSystem);
3039
delete request;

0 commit comments

Comments
 (0)