diff options
| author | gvit <gvit@ydb.tech> | 2022-11-06 21:26:50 +0300 |
|---|---|---|
| committer | gvit <gvit@ydb.tech> | 2022-11-06 21:26:50 +0300 |
| commit | 93a84938198bc81acb1fe0735ffc51fda87d0780 (patch) | |
| tree | 0b7a0be17d6a4c52f0888dd4c93c1235569e3e29 | |
| parent | bdb9bd3bdc2b672fa6e7729255ee760efca90ce1 (diff) | |
| download | ydb-93a84938198bc81acb1fe0735ffc51fda87d0780.tar.gz | |
continue switching datashard tests to public api
| -rw-r--r-- | ydb/core/tx/datashard/datashard_ut_order.cpp | 15 |
1 files changed, 6 insertions, 9 deletions
diff --git a/ydb/core/tx/datashard/datashard_ut_order.cpp b/ydb/core/tx/datashard/datashard_ut_order.cpp index 0de66fc2d9..031201578d 100644 --- a/ydb/core/tx/datashard/datashard_ut_order.cpp +++ b/ydb/core/tx/datashard/datashard_ut_order.cpp @@ -1953,10 +1953,9 @@ Y_UNIT_TEST(TestOutOfOrderRestartLocksSingleWithoutBarrier) { auto prevObserverFunc = runtime.SetObserverFunc(captureRS); // Send a commit request, it would block on readset exchange - auto sender2 = runtime.AllocateEdgeActor(); - SendRequest(runtime, sender2, MakeCommitRequest(sessionId, txId, Q_(R"( + SendRequest(runtime, MakeSimpleRequestRPC(Q_(R"( UPSERT INTO `/Root/table-1` (key, value) VALUES (3, 2); - UPSERT INTO `/Root/table-2` (key, value) VALUES (4, 2))"))); + UPSERT INTO `/Root/table-2` (key, value) VALUES (4, 2))"), sessionId, txId, true)); // Wait until we captured both readsets if (readSets.size() < 2) { @@ -2097,10 +2096,9 @@ Y_UNIT_TEST(MvccTestOutOfOrderRestartLocksSingleWithoutBarrier) { auto prevObserverFunc = runtime.SetObserverFunc(captureRS); // Send a commit request, it would block on readset exchange - auto sender2 = runtime.AllocateEdgeActor(); - SendRequest(runtime, sender2, MakeCommitRequest(sessionId, txId, Q_(R"( + SendRequest(runtime, MakeSimpleRequestRPC(Q_(R"( UPSERT INTO `/Root/table-1` (key, value) VALUES (3, 2); - UPSERT INTO `/Root/table-2` (key, value) VALUES (4, 2))"))); + UPSERT INTO `/Root/table-2` (key, value) VALUES (4, 2))"), sessionId, txId, true)); // Wait until we captured both readsets if (readSets.size() < 2) { @@ -2237,10 +2235,9 @@ Y_UNIT_TEST_TWIN(TestOutOfOrderRestartLocksReorderedWithoutBarrier, UseMvcc) { auto prevObserverFunc = runtime.SetObserverFunc(captureRS); // Send a commit request, it would block on readset exchange - auto sender2 = runtime.AllocateEdgeActor(); - SendRequest(runtime, sender2, MakeCommitRequest(sessionId, txId, Q_(R"( + SendRequest(runtime, MakeSimpleRequestRPC(Q_(R"( UPSERT INTO `/Root/table-1` (key, value) VALUES (3, 2); - UPSERT INTO `/Root/table-2` (key, value) VALUES (4, 2))"))); + UPSERT INTO `/Root/table-2` (key, value) VALUES (4, 2))"), sessionId, txId, true)); // Wait until we captured both readsets if (readSets.size() < 2) { |