Method RecvTensorHandlerRaw

tensorflow/contrib/star/star_worker_service.cc:225–242

}

void StarWorkerService::RecvTensorHandlerRaw(StarServerTag *tag) {
  // LOG(INFO) << "StarWorkerService::RecvTensorHandlerRaw";
  Schedule([this, tag]() {
      CallOptions* call_opts = new CallOptions;

      StarCall<RecvTensorRequest, StarTensorResponse> *call =
          new StarCall<RecvTensorRequest, StarTensorResponse>();

      InitStarServerTag(&call->req_, &call->resp_, tag, [call] (const Status& s) {delete call;});

      worker_->RecvTensorAsync(call_opts, &call->req_, &call->resp_,
                               [tag, call, call_opts
                               ](const Status& s) {
                                 delete call_opts;
                                 tag->ProcessDone(s);
                               });
    });
}

void StarWorkerService::FuseRecvTensorHandlerRaw(StarServerTag *tag) {
  // LOG(INFO) << "StarWorkerService::FuseRecvTensorHandlerRaw";