in cpp/acs_agent_client.cc [460:476]
std::unique_ptr<AcsStub> AcsAgentClient::GenerateConnectionIdAndStub() {
absl::StatusOr<AgentConnectionId> new_connection_id =
connection_id_generator_ != nullptr
? connection_id_generator_()
: GenerateAgentConnectionId(connection_id_.channel_id,
connection_id_.regional);
if (!new_connection_id.ok()) {
ABSL_LOG(WARNING) << "Failed to get connection id from agent connection "
<< "name: " << connection_id_.channel_id;
return nullptr;
}
connection_id_ = *std::move(new_connection_id);
if (stub_generator_ != nullptr) {
return stub_generator_();
}
return AcsAgentClientReactor::CreateStub(connection_id_.endpoint);
}