| 1110 | } |
| 1111 | |
| 1112 | arrow::Status |
| 1113 | DoGet(const arrow::flight::ServerCallContext &context, |
| 1114 | const arrow::flight::Ticket &ticket, |
| 1115 | std::unique_ptr<arrow::flight::FlightDataStream> *stream) override |
| 1116 | { |
| 1117 | auto gacontext = gaflight_server_call_context_new_raw(&context); |
| 1118 | auto gaticket = gaflight_ticket_new_raw(&ticket); |
| 1119 | GError *gerror = nullptr; |
| 1120 | auto gastream = gaflight_server_do_get(gaserver_, gacontext, gaticket, &gerror); |
| 1121 | g_object_unref(gaticket); |
| 1122 | g_object_unref(gacontext); |
| 1123 | if (gerror) { |
| 1124 | return garrow_error_to_status(gerror, |
| 1125 | arrow::StatusCode::UnknownError, |
| 1126 | "[flight-server][do-get]"); |
| 1127 | } |
| 1128 | *stream = std::make_unique<DataStream>(gastream); |
| 1129 | return arrow::Status::OK(); |
| 1130 | } |
| 1131 | |
| 1132 | arrow::Status |
| 1133 | DoPut(const arrow::flight::ServerCallContext &context, |
no test coverage detected