MCPcopy Create free account
hub / github.com/apache/arrow / DoAction

Method DoAction

cpp/src/arrow/flight/flight_test.cc:753–762  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

751
752class ErrorMiddlewareServer : public FlightServerBase {
753 Status DoAction(const ServerCallContext& context, const Action& action,
754 std::unique_ptr<ResultStream>* result) override {
755 std::string msg = "error_message";
756 auto buf = Buffer::FromString("");
757
758 std::shared_ptr<FlightStatusDetail> flightStatusDetail(
759 new FlightStatusDetail(FlightStatusCode::Failed, msg));
760 *result = std::make_unique<SimpleResultStream>(std::vector<Result>{Result{buf}});
761 return Status(StatusCode::ExecutionError, "test failed", flightStatusDetail);
762 }
763};
764
765class PropagatingTestServer : public FlightServerBase {

Callers

nothing calls this directly

Calls 2

FromStringFunction · 0.85
StatusClass · 0.70

Tested by

no test coverage detected