Lines Matching refs:req
101 CreateSessionRequest req;
102 *req.mutable_config() = options_.config;
103 *req.mutable_graph_def() = graph;
104 req.set_target(options_.target);
105 ReEncodeConsts(req.mutable_graph_def());
107 Status s = master_->CreateSession(call_options, &req, &resp);
141 ExtendSessionRequest req;
142 req.set_session_handle(handle_);
143 *req.mutable_graph_def() = graph;
144 req.set_current_graph_version(current_graph_version_);
146 Status s = master_->ExtendSession(call_options, &req, &resp);
173 std::unique_ptr<MutableRunStepRequestWrapper> req(
178 *req->mutable_options() = run_options;
181 req->mutable_options()->set_timeout_in_ms(
186 req->set_partial_run_handle(prun_handle);
190 req->add_feed(it.first, it.second);
194 req->set_store_errors_in_response_body(true);
202 req->add_fetch(name);
206 req->add_target(target);
210 call_options.SetTimeout(req->options().timeout_in_ms());
211 TF_RETURN_IF_ERROR(RunProto(&call_options, req.get(), resp.get()));
274 MutableRunStepRequestWrapper* req,
282 req->set_session_handle(handle_);
284 return master_->RunStep(call_options, req, resp);
292 PartialRunSetupRequest req;
301 req.set_session_handle(handle_);
304 req.add_feed(feed);
307 req.add_fetch(fetch);
310 req.add_target(target);
313 TF_RETURN_IF_ERROR(master_->PartialRunSetup(&call_options, &req, &resp));
329 CloseSessionRequest req;
335 req.set_session_handle(handle_);
341 return master_->CloseSession(&call_options, &req, &resp);
345 ListDevicesRequest req;
348 req.set_session_handle(handle_);
350 if (req.session_handle().empty()) {
358 req.set_session_handle(handle_);
364 Status s = master_->ListDevices(&call_options, &req, &resp);
392 ResetRequest req;
393 for (const auto& c : containers) req.add_container(c);
397 Status ret = master->Reset(&call_options, &req, &resp);
