| 1130 | } |
| 1131 | |
| 1132 | arrow::Status |
| 1133 | DoPut(const arrow::flight::ServerCallContext &context, |
| 1134 | std::unique_ptr<arrow::flight::FlightMessageReader> reader, |
| 1135 | std::unique_ptr<arrow::flight::FlightMetadataWriter> writer) override |
| 1136 | { |
| 1137 | auto gacontext = gaflight_server_call_context_new_raw(&context); |
| 1138 | auto gareader = gaflight_message_reader_new_raw(reader.release(), TRUE); |
| 1139 | auto gawriter = gaflight_metadata_writer_new_raw(writer.release()); |
| 1140 | GError *gerror = nullptr; |
| 1141 | auto success = |
| 1142 | gaflight_server_do_put(gaserver_, gacontext, gareader, gawriter, &gerror); |
| 1143 | g_object_unref(gawriter); |
| 1144 | g_object_unref(gareader); |
| 1145 | g_object_unref(gacontext); |
| 1146 | if (!success && !gerror) { |
| 1147 | g_set_error(&gerror, |
| 1148 | GARROW_ERROR, |
| 1149 | GARROW_ERROR_UNKNOWN, |
| 1150 | "GAFlightServerClass::do_put() returns FALSE but error isn't set"); |
| 1151 | } |
| 1152 | if (gerror) { |
| 1153 | return garrow_error_to_status(gerror, |
| 1154 | arrow::StatusCode::UnknownError, |
| 1155 | "[flight-server][do-put]"); |
| 1156 | } |
| 1157 | return arrow::Status::OK(); |
| 1158 | } |
| 1159 | |
| 1160 | private: |
| 1161 | GAFlightServer *gaserver_; |
no test coverage detected