Method TransmitData

be/src/runtime/data-stream-test.cc:136–141

  }

  virtual void TransmitData(const TransmitDataRequestPB* request,
      TransmitDataResponsePB* response, RpcContext* rpc_context) {
    transmit_counter_++;
    DebugActionNoFail(FLAGS_debug_actions, "TRANSMIT_DATA_DELAY");
    stream_mgr_->AddData(request, response, rpc_context);
  }

  virtual void EndDataStream(const EndDataStreamRequestPB* request,
      EndDataStreamResponsePB* response, RpcContext* rpc_context) {