Always respond with E_REJECT when killing a volume tablet actor #1988
Conversation
drbasic
force-pushed
the
users/drbasic/save-all-partition-requests
branch
from
b7d8ab2
to
757227e
Compare
drbasic
added
large-tests
drbasic
force-pushed
the
users/drbasic/save-all-partition-requests
branch
from
10072e5
to
4be0511
Compare
drbasic
force-pushed
the
users/drbasic/save-all-partition-requests
branch
from
4be0511
to
f3b10ca
Compare
drbasic
changed the title
| @@ -55,8 +55,6 @@ class TMultiPartitionRequestActor final | |||
| { | |||
| private: | |||
| const TRequestInfoPtr RequestInfo; | |||
| const NActors::TActorId VolumeActorId; | |||
There was a problem hiding this comment.
Теперь не нужно отправлять отдельно уведомление что завершилась многопартиционная запись, вольюм и так об этом узнает, так как все запросы проходят через него
| const TCallContextPtr ForkedContext; | ||
| const ui64 ReceiveTime; | ||
| TCancelRoutine* const CancelRoutine; | ||
| const bool IsMultipartitionWriteOrZero; |
There was a problem hiding this comment.
если запрос был на запись и мультипартиционный, запоминаем этот факь
| @@ -167,46 +228,26 @@ void TVolumeActor::SendRequestToPartition( | |||
| ToString(partActorId).data()); | |||
| } | |||
|
|
|||
| const bool processed = SendRequestToPartitionWithUsedBlockTracking<TMethod>( | |||
| ctx, | |||
| auto wrappedRequest = WrapRequest<TMethod>( | |||
There was a problem hiding this comment.
переношу подготовку запроса к отправке в партишен в отдельный метод
| FillResponse<TMethod>(*msg, cc, volumeRequest.ReceiveTime); | ||
| template <typename TMethod> | ||
| bool TVolumeActor::ReplyToOriginalRequest( | ||
| const NActors::TActorContext& ctx, |
There was a problem hiding this comment.
унификация перенаправления ответа от партишена к тому кто присылал запрос
| isTraced, | ||
| now)) | ||
| { | ||
| if constexpr (IsWriteMethod<TMethod>) { |
There was a problem hiding this comment.
запрос не был зарегистрирован в VolumeRequests, к тому же отменен из-за того что клиент передумал.
по этому отвечаем не через ReplyToOriginalRequest.
| @@ -349,11 +348,6 @@ struct TEvVolumePrivate | |||
| EvPartStatsSaved | |||
| >; | |||
|
|
|||
| using TEvMultipartitionWriteOrZeroCompleted = TRequestEvent< | |||
There was a problem hiding this comment.
сообщение больше не нужно
Раньше не всегда запросы, которые отправлялись в партишен, сохранялись в акторе вольюма в векторе VolumeRequests. Это работало только если паришен был один, и не происходило отслеживание записанных блоков.
Сейчас сохранение происходит во всех случаях. А значит, если таблетка вольюма умирает, то и E_REJECTED будет отправляться всегда https://github.com/ydb-platform/nbs/blob/main/cloud/blockstore/libs/storage/volume/volume_actor.cpp#L531
Поведение стало консистентным.