Method FuseRecvTensorHandlerRaw

tensorflow/contrib/star/star_worker_service.cc:244–261

}

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

      StarCall<FuseRecvTensorRequest, StarFuseTensorResponse> *call =
          new StarCall<FuseRecvTensorRequest, StarFuseTensorResponse>();

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

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

void StarWorkerService::Schedule(std::function<void()> f) {
  worker_->env()->compute_pool->Schedule(std::move(f));