|
|
|
@ -720,7 +720,7 @@ TEST_F(ColumnFamilyTest, DifferentWriteBufferSizes) { |
|
|
|
|
two.max_write_buffer_number = 10; |
|
|
|
|
two.min_write_buffer_number_to_merge = 3; |
|
|
|
|
two.max_write_buffer_number_to_maintain = 2; |
|
|
|
|
three.write_buffer_size = 4096 * 22 + 2048; |
|
|
|
|
three.write_buffer_size = 4096 * 22; |
|
|
|
|
three.arena_block_size = 4096; |
|
|
|
|
three.max_write_buffer_number = 10; |
|
|
|
|
three.min_write_buffer_number_to_merge = 4; |
|
|
|
@ -745,15 +745,15 @@ TEST_F(ColumnFamilyTest, DifferentWriteBufferSizes) { |
|
|
|
|
env_->SleepForMicroseconds(micros_wait_for_flush); |
|
|
|
|
AssertNumberOfImmutableMemtables({0, 1, 2, 0}); |
|
|
|
|
AssertCountLiveLogFiles(4); |
|
|
|
|
PutRandomData(3, 91, 990); |
|
|
|
|
PutRandomData(3, 93, 990); |
|
|
|
|
env_->SleepForMicroseconds(micros_wait_for_flush); |
|
|
|
|
AssertNumberOfImmutableMemtables({0, 1, 2, 1}); |
|
|
|
|
AssertCountLiveLogFiles(5); |
|
|
|
|
PutRandomData(3, 90, 990); |
|
|
|
|
PutRandomData(3, 88, 990); |
|
|
|
|
env_->SleepForMicroseconds(micros_wait_for_flush); |
|
|
|
|
AssertNumberOfImmutableMemtables({0, 1, 2, 2}); |
|
|
|
|
AssertCountLiveLogFiles(6); |
|
|
|
|
PutRandomData(3, 90, 990); |
|
|
|
|
PutRandomData(3, 88, 990); |
|
|
|
|
env_->SleepForMicroseconds(micros_wait_for_flush); |
|
|
|
|
AssertNumberOfImmutableMemtables({0, 1, 2, 3}); |
|
|
|
|
AssertCountLiveLogFiles(7); |
|
|
|
@ -765,11 +765,11 @@ TEST_F(ColumnFamilyTest, DifferentWriteBufferSizes) { |
|
|
|
|
WaitForFlush(2); |
|
|
|
|
AssertNumberOfImmutableMemtables({0, 1, 0, 3}); |
|
|
|
|
AssertCountLiveLogFiles(9); |
|
|
|
|
PutRandomData(3, 90, 990); |
|
|
|
|
PutRandomData(3, 88, 990); |
|
|
|
|
WaitForFlush(3); |
|
|
|
|
AssertNumberOfImmutableMemtables({0, 1, 0, 0}); |
|
|
|
|
AssertCountLiveLogFiles(10); |
|
|
|
|
PutRandomData(3, 90, 990); |
|
|
|
|
PutRandomData(3, 88, 990); |
|
|
|
|
env_->SleepForMicroseconds(micros_wait_for_flush); |
|
|
|
|
AssertNumberOfImmutableMemtables({0, 1, 0, 1}); |
|
|
|
|
AssertCountLiveLogFiles(11); |
|
|
|
@ -777,9 +777,9 @@ TEST_F(ColumnFamilyTest, DifferentWriteBufferSizes) { |
|
|
|
|
WaitForFlush(1); |
|
|
|
|
AssertNumberOfImmutableMemtables({0, 0, 0, 1}); |
|
|
|
|
AssertCountLiveLogFiles(5); |
|
|
|
|
PutRandomData(3, 90 * 3, 990); |
|
|
|
|
PutRandomData(3, 88 * 3, 990); |
|
|
|
|
WaitForFlush(3); |
|
|
|
|
PutRandomData(3, 90 * 4, 990); |
|
|
|
|
PutRandomData(3, 88 * 4, 990); |
|
|
|
|
WaitForFlush(3); |
|
|
|
|
AssertNumberOfImmutableMemtables({0, 0, 0, 0}); |
|
|
|
|
AssertCountLiveLogFiles(12); |
|
|
|
|