| 730 | } |
| 731 | |
| 732 | arrow::Status |
| 733 | Authenticate(const arrow::flight::ServerCallContext &context, |
| 734 | arrow::flight::ServerAuthSender *sender, |
| 735 | arrow::flight::ServerAuthReader *reader) override |
| 736 | { |
| 737 | auto klass = GAFLIGHT_SERVER_CUSTOM_AUTH_HANDLER_GET_CLASS(handler_); |
| 738 | auto gacontext = gaflight_server_call_context_new_raw(&context); |
| 739 | auto gasender = gaflight_server_auth_sender_new_raw(sender); |
| 740 | auto gareader = gaflight_server_auth_reader_new_raw(reader); |
| 741 | GError *error = nullptr; |
| 742 | klass->authenticate(handler_, gacontext, gasender, gareader, &error); |
| 743 | g_object_unref(gareader); |
| 744 | g_object_unref(gasender); |
| 745 | g_object_unref(gacontext); |
| 746 | if (error) { |
| 747 | return garrow_error_to_status(error, |
| 748 | arrow::StatusCode::Invalid, |
| 749 | "[flight-server-custom-auth-handler]" |
| 750 | "[authenticate]"); |
| 751 | } else { |
| 752 | return arrow::Status::OK(); |
| 753 | } |
| 754 | } |
| 755 | |
| 756 | arrow::Status |
| 757 | IsValid(const arrow::flight::ServerCallContext &context, |
no test coverage detected