Skip to content

Commit 183215c

Browse files
committed
fixup! Pass split message
1 parent a152dd6 commit 183215c

File tree

1 file changed

+10
-10
lines changed

1 file changed

+10
-10
lines changed

ydb/core/persqueue/partition_index_generator/partition_index_generator_ut.cpp

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,7 @@ namespace NKikimr::NPQ {
1010
for (ui32 i = 0; i < 100; ++i) {
1111
auto result = generator.GetNextUnreservedId();
1212
UNIT_ASSERT(result.has_value());
13-
UNIT_ASSERT_VALUES_EQUAL(*result, 100 + i);
13+
UNIT_ASSERT_VALUES_EQUAL(result.value(), 100 + i);
1414
}
1515
UNIT_ASSERT(generator.ValidateAllocationSequence().has_value());
1616
}
@@ -26,7 +26,7 @@ namespace NKikimr::NPQ {
2626

2727
auto getReserved = generator.GetNextReservedId(105);
2828
UNIT_ASSERT(getReserved.has_value());
29-
UNIT_ASSERT_VALUES_EQUAL(*getReserved, 105);
29+
UNIT_ASSERT_VALUES_EQUAL(getReserved.value(), 105);
3030
UNIT_ASSERT(!generator.ValidateAllocationSequence().has_value());
3131
}
3232

@@ -42,13 +42,13 @@ namespace NKikimr::NPQ {
4242
for (ui32 i = 0; i < 7; ++i) {
4343
auto result = generator.GetNextUnreservedId();
4444
UNIT_ASSERT(result.has_value());
45-
UNIT_ASSERT_VALUES_EQUAL(*result, 100 + i + (i >= 5 ? 1 : 0)); // Skip 105
45+
UNIT_ASSERT_VALUES_EQUAL(result.value(), 100 + i + (i >= 5 ? 1 : 0)); // Skip 105
4646
}
4747

4848
// Verify 105 is availiable
4949
auto reservedResult = generator.GetNextReservedId(105);
5050
UNIT_ASSERT(reservedResult.has_value());
51-
UNIT_ASSERT_VALUES_EQUAL(*reservedResult, 105);
51+
UNIT_ASSERT_VALUES_EQUAL(reservedResult.value(), 105);
5252

5353
UNIT_ASSERT(generator.ValidateAllocationSequence().has_value());
5454
}
@@ -77,7 +77,7 @@ namespace NKikimr::NPQ {
7777

7878
auto nextUnreserved = generator.GetNextUnreservedId();
7979
UNIT_ASSERT(nextUnreserved.has_value());
80-
UNIT_ASSERT_VALUES_EQUAL(*nextUnreserved, 100);
80+
UNIT_ASSERT_VALUES_EQUAL(nextUnreserved.value(), 100);
8181
UNIT_ASSERT(generator.ValidateAllocationSequence().has_value());
8282
}
8383

@@ -93,16 +93,16 @@ namespace NKikimr::NPQ {
9393
Y_UNIT_TEST(TestReserve2) {
9494
TPartitionIndexGenerator generator(200);
9595
UNIT_ASSERT(generator.ReservePartitionIndex(200, 0, false).has_value());
96-
UNIT_ASSERT_VALUES_EQUAL(*generator.GetNextUnreservedId(), 201);
97-
UNIT_ASSERT_VALUES_EQUAL(*generator.GetNextReservedId(200), 200);
98-
UNIT_ASSERT_EXCEPTION(*generator.GetNextReservedId(200), yexception);
96+
UNIT_ASSERT_VALUES_EQUAL(generator.GetNextUnreservedId().value(), 201);
97+
UNIT_ASSERT_VALUES_EQUAL(generator.GetNextReservedId(200).value(), 200);
98+
UNIT_ASSERT_EXCEPTION(generator.GetNextReservedId(200).value(), std::exception);
9999
UNIT_ASSERT(generator.ValidateAllocationSequence().has_value());
100100
}
101101

102102
Y_UNIT_TEST(TestReserve3) {
103103
TPartitionIndexGenerator generator(200);
104-
UNIT_ASSERT_VALUES_EQUAL(*generator.GetNextUnreservedId(), 200);
105-
UNIT_ASSERT_EXCEPTION(*generator.GetNextReservedId(200), yexception);
104+
UNIT_ASSERT_VALUES_EQUAL(generator.GetNextUnreservedId().value(), 200);
105+
UNIT_ASSERT_EXCEPTION(generator.GetNextReservedId(200).value(), std::exception);
106106
UNIT_ASSERT(generator.ValidateAllocationSequence().has_value());
107107
}
108108
} // Y_UNIT_TEST_SUITE(TPartitionIndexGeneratorTest)

0 commit comments

Comments
 (0)