diff options
| author | alexvru <alexvru@ydb.tech> | 2023-11-20 12:18:49 +0300 |
|---|---|---|
| committer | alexvru <alexvru@ydb.tech> | 2023-11-20 12:47:59 +0300 |
| commit | 4227de2e7097a5dfff01c245ea3ae508356286ed (patch) | |
| tree | 1f11c9cf3b5a72b1fd8fa7eb3eab80332970f17c | |
| parent | d7560330c3eadb39eb8f8cdbd42f86e722e82140 (diff) | |
| download | ydb-4227de2e7097a5dfff01c245ea3ae508356286ed.tar.gz | |
Fix some TestShard issues KIKIMR-11082
| -rw-r--r-- | ydb/core/test_tablet/load_actor_impl.h | 2 | ||||
| -rw-r--r-- | ydb/core/test_tablet/load_actor_state.cpp | 12 |
2 files changed, 12 insertions, 2 deletions
diff --git a/ydb/core/test_tablet/load_actor_impl.h b/ydb/core/test_tablet/load_actor_impl.h index f64ff3550d..32186991ac 100644 --- a/ydb/core/test_tablet/load_actor_impl.h +++ b/ydb/core/test_tablet/load_actor_impl.h @@ -79,7 +79,7 @@ namespace NKikimr::NTestShard { //////////////////////////////////////////////////////////////////////////////////////////////////////////////// // Generic request/response management - ui32 BytesProcessed = 0; + ui64 BytesProcessed = 0; ui32 StallCounter = 0; ui64 LastCookie = 0; diff --git a/ydb/core/test_tablet/load_actor_state.cpp b/ydb/core/test_tablet/load_actor_state.cpp index ae621b40fc..53ffc6ebf0 100644 --- a/ydb/core/test_tablet/load_actor_state.cpp +++ b/ydb/core/test_tablet/load_actor_state.cpp @@ -8,7 +8,12 @@ namespace NKikimr::NTestShard { (To, to)); // some sanity checks - Y_ABORT_UNLESS(key.second.ConfirmedState == key.second.PendingState); + Y_VERIFY_S(key.second.ConfirmedState == key.second.PendingState, "key# " << key.first + << " ConfirmedState# " << key.second.ConfirmedState + << " PendingState# " << key.second.PendingState + << " from# " << from + << " to# " << to + << " Request# "<< bool(key.second.Request)); Y_ABORT_UNLESS(key.second.ConfirmedState == from); Y_ABORT_UNLESS(!key.second.Request); Y_ABORT_UNLESS(from != to); @@ -141,3 +146,8 @@ namespace NKikimr::NTestShard { } } // NKikimr::NTestShard + +template<> +void Out<::NTestShard::TStateServer::EEntityState>(IOutputStream& s, ::NTestShard::TStateServer::EEntityState value) { + s << ::NTestShard::TStateServer::EEntityState_Name(value); +} |