| 539 | void TearDown() override { IpcTestFixture::TearDown(); } |
| 540 | |
| 541 | void TestMetadataVersion(MetadataVersion expected_version) { |
| 542 | std::shared_ptr<RecordBatch> batch; |
| 543 | ASSERT_OK(MakeIntRecordBatch(&batch)); |
| 544 | |
| 545 | mmap_.reset(); // Ditch previous mmap view, to avoid errors on Windows |
| 546 | ASSERT_OK_AND_ASSIGN(mmap_, |
| 547 | io::MemoryMapFixture::InitMemoryMap(1 << 16, "test-metadata")); |
| 548 | |
| 549 | int32_t metadata_length; |
| 550 | int64_t body_length; |
| 551 | const int64_t buffer_offset = 0; |
| 552 | ASSERT_OK(WriteRecordBatch(*batch, buffer_offset, mmap_.get(), &metadata_length, |
| 553 | &body_length, options_)); |
| 554 | |
| 555 | ASSERT_OK_AND_ASSIGN(std::unique_ptr<Message> message1, |
| 556 | ReadMessage(0, metadata_length, mmap_.get())); |
| 557 | ASSERT_EQ(expected_version, message1->metadata_version()); |
| 558 | |
| 559 | ASSERT_OK_AND_ASSIGN(auto message2, |
| 560 | ReadMessage(0, metadata_length, body_length, mmap_.get())); |
| 561 | ASSERT_EQ(expected_version, message2->metadata_version()); |
| 562 | |
| 563 | ASSERT_TRUE(message1->Equals(*message2)); |
| 564 | } |
| 565 | }; |
| 566 | |
| 567 | TEST_P(TestIpcRoundTrip, RoundTrip) { |
nothing calls this directly
no test coverage detected