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

Method DoPut

c_glib/arrow-flight-glib/server.cpp:1132–1158  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

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_;

Callers 1

gaflight_client_do_putFunction · 0.45

Calls 7

gaflight_server_do_putFunction · 0.85
garrow_error_to_statusFunction · 0.85
OKFunction · 0.50
releaseMethod · 0.45

Tested by

no test coverage detected