| 110 | } |
| 111 | |
| 112 | void DataStreamService::EndDataStream(const EndDataStreamRequestPB* request, |
| 113 | EndDataStreamResponsePB* response, RpcContext* rpc_context) { |
| 114 | DebugActionNoFail(FLAGS_debug_actions, "END_DATA_STREAM_DELAY"); |
| 115 | // CloseSender() is guaranteed to eventually respond to this RPC so we don't do it here. |
| 116 | ExecEnv::GetInstance()->stream_mgr()->CloseSender(request, response, rpc_context); |
| 117 | } |
| 118 | |
| 119 | void DataStreamService::TransmitData(const TransmitDataRequestPB* request, |
| 120 | TransmitDataResponsePB* response, RpcContext* rpc_context) { |
nothing calls this directly
no test coverage detected