| 117 | } |
| 118 | |
| 119 | void DataStreamService::TransmitData(const TransmitDataRequestPB* request, |
| 120 | TransmitDataResponsePB* response, RpcContext* rpc_context) { |
| 121 | DebugActionNoFail(FLAGS_debug_actions, "TRANSMIT_DATA_DELAY"); |
| 122 | // AddData() is guaranteed to eventually respond to this RPC so we don't do it here. |
| 123 | ExecEnv::GetInstance()->stream_mgr()->AddData(request, response, rpc_context); |
| 124 | } |
| 125 | |
| 126 | void DataStreamService::UpdateFilter( |
| 127 | const UpdateFilterParamsPB* req, UpdateFilterResultPB* resp, RpcContext* context) { |
nothing calls this directly
no test coverage detected