| 322 | } |
| 323 | |
| 324 | Status ServerTransport::DoPut(const ServerCallContext& context, |
| 325 | ServerDataStream* stream) { |
| 326 | std::unique_ptr<TransportMessageReader> reader( |
| 327 | new TransportMessageReader(stream, memory_manager_)); |
| 328 | std::unique_ptr<FlightMetadataWriter> writer(new TransportMetadataWriter(stream)); |
| 329 | RETURN_NOT_OK(reader->Init()); |
| 330 | RETURN_NOT_OK(base_->DoPut(context, std::move(reader), std::move(writer))); |
| 331 | RETURN_NOT_OK(stream->WritesDone()); |
| 332 | return Status::OK(); |
| 333 | } |
| 334 | |
| 335 | Status ServerTransport::DoExchange(const ServerCallContext& context, |
| 336 | ServerDataStream* stream) { |
nothing calls this directly
no test coverage detected