| 1175 | ASSERT_OK(writer->Close()); |
| 1176 | } |
| 1177 | void IpcOptionsTest::TestDoExchangeServerWriteOptions() { |
| 1178 | // Call DoExchange and write nested data, but with a very low nesting depth set to fail |
| 1179 | // the call. (The low nesting depth is set on the server side.) |
| 1180 | auto descr = FlightDescriptor::Command(""); |
| 1181 | ASSERT_OK_AND_ASSIGN(auto do_exchange_result, client_->DoExchange(descr)); |
| 1182 | std::unique_ptr<FlightStreamWriter> writer = std::move(do_exchange_result.writer); |
| 1183 | RecordBatchVector batches; |
| 1184 | ASSERT_OK(ExampleNestedBatches(&batches)); |
| 1185 | ASSERT_OK(writer->Begin(batches[0]->schema())); |
| 1186 | FlightStreamChunk chunk; |
| 1187 | ASSERT_OK(writer->WriteRecordBatch(*batches[0])); |
| 1188 | ASSERT_OK(writer->DoneWriting()); |
| 1189 | ASSERT_RAISES(Invalid, writer->Close()); |
| 1190 | } |
| 1191 | |
| 1192 | //------------------------------------------------------------ |
| 1193 | // Test CUDA memory in data plane methods |
nothing calls this directly
no test coverage detected