| 107 | } |
| 108 | |
| 109 | void AssertEqual(const FlightInfo& expected, const FlightInfo& actual) { |
| 110 | ipc::DictionaryMemo expected_memo; |
| 111 | ipc::DictionaryMemo actual_memo; |
| 112 | ASSERT_OK_AND_ASSIGN(auto ex_schema, expected.GetSchema(&expected_memo)); |
| 113 | ASSERT_OK_AND_ASSIGN(auto actual_schema, actual.GetSchema(&actual_memo)); |
| 114 | |
| 115 | AssertSchemaEqual(*ex_schema, *actual_schema); |
| 116 | ASSERT_EQ(expected.total_records(), actual.total_records()); |
| 117 | ASSERT_EQ(expected.total_bytes(), actual.total_bytes()); |
| 118 | |
| 119 | ASSERT_EQ(expected.descriptor(), actual.descriptor()); |
| 120 | ASSERT_THAT(actual.endpoints(), ::testing::ContainerEq(expected.endpoints())); |
| 121 | } |
| 122 | |
| 123 | std::shared_ptr<Schema> ExampleIntSchema() { |
| 124 | auto f0 = field("f0", int8()); |
no test coverage detected