Home
last modified time | relevance | path

Searched refs:cluster_name (Results 1 – 25 of 33) sorted by relevance

12

/external/tensorflow/tensorflow/compiler/mlir/tensorflow/transforms/
Dexecutor_tpuv1_island_coarsening.cc130 StringAttr cluster_name = in MergeIsland() local
132 if (!cluster_name) in MergeIsland()
133 cluster_name = wrapped_op.getAttrOfType<StringAttr>(kTpuStatusAttr); in MergeIsland()
134 if (!cluster_name) return success(); in MergeIsland()
155 if (candidate_cluster_name != cluster_name && in MergeIsland()
156 !is_op_calling_func_for_cluster(cluster_name, &candidate_wrapped_op)) in MergeIsland()
270 StringAttr cluster_name = in runOnOperation() local
272 if (!cluster_name) in runOnOperation()
273 cluster_name = op->getAttrOfType<StringAttr>(kTpuStatusAttr); in runOnOperation()
274 if (!cluster_name) return; in runOnOperation()
[all …]
/external/tensorflow/tensorflow/compiler/jit/
Dencapsulate_util.h99 XlaClusterInfo(const string& cluster_name, in XlaClusterInfo()
102 : cluster_name(cluster_name), in XlaClusterInfo()
107 const string cluster_name; member
Dmark_for_compilation_pass.cc1454 if (absl::optional<absl::string_view> cluster_name = in DumpPostClusteringGraphs() local
1456 n->set_name(absl::StrCat(*cluster_name, "/", n->name())); in DumpPostClusteringGraphs()
1491 absl::string_view cluster_name = cluster.name(); in VLogClusteringSummary() local
1493 VLOG(2) << " " << cluster_name << " " in VLogClusteringSummary()
1515 absl::optional<absl::string_view> cluster_name; in VLogClusteringSummary() member
1518 return cluster_name ? *cluster_name : "[none]"; in VLogClusteringSummary()
1523 return {node_name, cluster_name}; in VLogClusteringSummary()
1568 auto print_edge_info_set_for_cluster = [&](absl::string_view cluster_name, in VLogClusteringSummary()
1571 auto it = edge_info_map.find(cluster_name); in VLogClusteringSummary()
1584 for (absl::string_view cluster_name : cluster_names_to_print) { in VLogClusteringSummary() local
[all …]
Dpartially_decluster_pass.cc120 absl::string_view cluster_name = *GetXlaClusterForNode(*n); in PartiallyDeclusterNode() local
130 if (dst_cluster_name != cluster_name) { in PartiallyDeclusterNode()
314 absl::string_view cluster_name = *GetXlaClusterForNode(*n); in PartiallyDeclusterGraph() local
319 return !incoming_cluster || *incoming_cluster != cluster_name; in PartiallyDeclusterGraph()
Dincrease_dynamism_for_auto_jit_pass.cc238 absl::string_view cluster_name, Node** result) { in ConvertTensorFlowSliceToStaticShapedSlice() argument
246 .WithXlaCluster(string(cluster_name)) in ConvertTensorFlowSliceToStaticShapedSlice()
306 absl::string_view cluster_name) { in RewriteSlice() argument
311 g, slice, slice_inputs, cluster_name, &static_shaped_slice)); in RewriteSlice()
Dxla_activity_listener_test.cc164 EXPECT_EQ(listener()->jit_compilation_activity().cluster_name(), "cluster_0"); in TEST_F()
181 EXPECT_EQ(listener()->jit_compilation_activity().cluster_name(), "cluster_0"); in TEST_F()
Dxla_cluster_util.cc361 absl::optional<absl::string_view> cluster_name = GetXlaClusterForNode(*n); in GetXlaAutoClusteringSummary() local
362 if (cluster_name) { in GetXlaAutoClusteringSummary()
364 ClusterInfo* info = &cluster_name_to_info[*cluster_name]; in GetXlaAutoClusteringSummary()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/xds/
Dxds_client.h145 void WatchClusterData(absl::string_view cluster_name,
147 void CancelClusterDataWatch(absl::string_view cluster_name,
166 absl::string_view lrs_server, absl::string_view cluster_name,
169 absl::string_view cluster_name,
176 absl::string_view lrs_server, absl::string_view cluster_name,
180 absl::string_view /*lrs_server*/, absl::string_view cluster_name,
Dxds_client_stats.cc46 absl::string_view cluster_name, in XdsClusterDropStats() argument
53 cluster_name_(cluster_name), in XdsClusterDropStats()
99 absl::string_view cluster_name, absl::string_view eds_service_name, in XdsClusterLocalityStats() argument
106 cluster_name_(cluster_name), in XdsClusterLocalityStats()
Dxds_client.cc1005 const char* cluster_name = p.first.c_str(); in AcceptCdsUpdate() local
1007 auto& state = cds_state.subscribed_resources[cluster_name]; in AcceptCdsUpdate()
1011 cluster_name, cds_update.ToString().c_str()); in AcceptCdsUpdate()
1015 ? cluster_name in AcceptCdsUpdate()
1018 ClusterState& cluster_state = xds_client()->cluster_map_[cluster_name]; in AcceptCdsUpdate()
1038 const std::string& cluster_name = p.first; in AcceptCdsUpdate() local
1039 if (cds_update_map.find(cluster_name) == cds_update_map.end()) { in AcceptCdsUpdate()
1040 ClusterState& cluster_state = xds_client()->cluster_map_[cluster_name]; in AcceptCdsUpdate()
1895 absl::string_view cluster_name, in WatchClusterData() argument
1897 std::string cluster_name_str = std::string(cluster_name); in WatchClusterData()
[all …]
Dxds_client_stats.h132 absl::string_view cluster_name,
206 absl::string_view cluster_name,
Dxds_api.h134 std::string cluster_name; member
152 cluster_name == other.cluster_name &&
Dxds_api.cc294 if (!cluster_name.empty()) { in ToString()
295 contents.push_back(absl::StrFormat("Cluster name: %s", cluster_name)); in ToString()
1267 route->cluster_name = UpbStringToStdString( in RouteActionParse()
1269 if (route->cluster_name.empty()) { in RouteActionParse()
1718 std::string cluster_name = in CdsResponseParse() local
1720 if (expected_cluster_names.find(cluster_name) == in CdsResponseParse()
1725 if (cds_update_map->find(cluster_name) != cds_update_map->end()) { in CdsResponseParse()
1727 absl::StrCat("duplicate resource name \"", cluster_name, "\"") in CdsResponseParse()
1730 XdsApi::CdsUpdate& cds_update = (*cds_update_map)[std::move(cluster_name)]; in CdsResponseParse()
2212 const std::string& cluster_name = p.first.first; in CreateLrsRequest() local
[all …]
/external/tensorflow/tensorflow/lite/toco/tensorflow_graph_matching/
Dresolve_cluster.cc47 for (const std::string& cluster_name : cluster_names) { in AddNodeToGraph() local
48 if (StrContains(node_input, cluster_name) && in AddNodeToGraph()
49 !StrContains(node.name(), cluster_name)) { in AddNodeToGraph()
50 new_node->add_input(cluster_name); in AddNodeToGraph()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_impl.cc126 std::string cluster_name, std::string eds_service_name, in XdsClusterImplLbConfig() argument
131 cluster_name_(std::move(cluster_name)), in XdsClusterImplLbConfig()
143 const std::string& cluster_name() const { return cluster_name_; } in cluster_name() function in grpc_core::__anonc021a63c0111::XdsClusterImplLbConfig
438 config_->cluster_name(), config_->eds_service_name()); in UpdateLocked()
441 config_->cluster_name(), config_->eds_service_name()); in UpdateLocked()
446 GPR_ASSERT(config_->cluster_name() == old_config->cluster_name()); in UpdateLocked()
527 const_cast<char*>(config_->cluster_name().c_str())); in UpdateChildPolicyLocked()
560 xds_cluster_impl_policy_->config_->cluster_name(), in CreateSubchannel()
662 std::string cluster_name; in ParseLoadBalancingConfig() local
671 cluster_name = it->second.string_value(); in ParseLoadBalancingConfig()
[all …]
Dxds_cluster_manager.cc209 auto cluster_name = in Pick() local
211 auto it = cluster_map_.find(cluster_name); in Pick()
220 cluster_name, "\"") in Pick()
346 const std::string& cluster_name = p.first; in UpdateStateLocked() local
348 cluster_map[cluster_name]; in UpdateStateLocked()
349 child_picker = children_[cluster_name]->picker_wrapper(); in UpdateStateLocked()
356 this, cluster_name.c_str()); in UpdateStateLocked()
359 cluster_name, absl::make_unique<QueuePicker>( in UpdateStateLocked()
Dxds_cluster_resolver.cc63 std::string cluster_name; member
74 return (cluster_name == other.cluster_name && in operator ==()
144 return parent_->config_->discovery_mechanisms()[index_].cluster_name; in GetXdsClusterResolverResourceName()
153 parent_->config_->discovery_mechanisms()[index_].cluster_name, in GetLrsClusterKey()
1158 discovery_mechanism->cluster_name = it->second.string_value(); in ParseDiscoveryMechanism()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/xds/
Dxds_resolver.cc125 ClusterState(const std::string& cluster_name, in ClusterState() argument
128 ->emplace(cluster_name, std::unique_ptr<ClusterState>(this)) in ClusterState()
299 MaybeAddCluster(route.cluster_name); in XdsConfigSelector()
491 absl::string_view cluster_name; in GetCallConfig() local
493 cluster_name = entry.route.cluster_name; in GetCallConfig()
517 cluster_name = entry.weighted_cluster_state[index].second; in GetCallConfig()
519 auto it = clusters_.find(cluster_name); in GetCallConfig()
/external/perfetto/src/traced/probes/ftrace/test/data/android_walleye_OPM5.171019.017.A1_4.4.88/events/msm_low_power/cluster_enter/
Dformat15 print fmt: "cluster_name:%s idx:%d sync:0x%lx child:0x%lx idle:%d", REC->name, REC->index, REC->syn…
/external/perfetto/src/traced/probes/ftrace/test/data/android_walleye_OPM5.171019.017.A1_4.4.88/events/msm_low_power/cluster_exit/
Dformat15 print fmt: "cluster_name:%s idx:%d sync:0x%lx child:0x%lx idle:%d", REC->name, REC->index, REC->syn…
/external/perfetto/src/traced/probes/ftrace/test/data/android_seed_N2F62_3.10.49/events/msm_low_power/cluster_enter/
Dformat15 print fmt: "cluster_name:%s idx:%d sync:0x%lx child:0x%lx idle:%d", REC->name, REC->index, REC->syn…
/external/perfetto/src/traced/probes/ftrace/test/data/android_seed_N2F62_3.10.49/events/msm_low_power/cluster_exit/
Dformat15 print fmt: "cluster_name:%s idx:%d sync:0x%lx child:0x%lx idle:%d", REC->name, REC->index, REC->syn…
/external/tensorflow/tensorflow/python/compiler/xla/
Dxla.py345 cluster_name = ops.get_default_graph().unique_name('cluster')
346 pivot = control_flow_ops.no_op(name=cluster_name + '/pivot')
347 context = XLACompileContext(name=cluster_name, pivot=pivot)
/external/tensorflow/tensorflow/core/tpu/graph_rewrite/
Dencapsulate_tpu_computations_pass.cc359 const std::string& cluster_name, Graph* g, Graph* xla_graph, Node* xla_node, in MoveHeadOutsideCompilationToHost() argument
475 copy_node->AddAttr(kTPUReplicateAttr, cluster_name); in MoveHeadOutsideCompilationToHost()
1000 const std::string& cluster_name, Graph* g, Graph* xla_graph, Node* xla_node, in MoveTailOutsideCompilationToHost() argument
1126 copy_node->AddAttr(kTPUReplicateAttr, cluster_name); in MoveTailOutsideCompilationToHost()
1618 string cluster_name; in RenameClustersWithDuplicatedNames() local
1619 TF_RETURN_IF_ERROR(GetNodeAttr(n->def(), kTPUReplicateAttr, &cluster_name)); in RenameClustersWithDuplicatedNames()
1620 cluster_name_to_metadata_nodes[cluster_name].push_back(n); in RenameClustersWithDuplicatedNames()
1621 cluster_names.insert(cluster_name); in RenameClustersWithDuplicatedNames()
1657 string cluster_name; in RenameClustersWithDuplicatedNames() local
1659 if (GetNodeAttr(e->dst()->def(), kTPUReplicateAttr, &cluster_name) in RenameClustersWithDuplicatedNames()
[all …]
/external/tensorflow/tensorflow/python/tpu/
Dtpu.py1389 cluster_name = graph.unique_name("cluster_" + graph.name)
1391 cluster_name = graph.unique_name("cluster")
1392 pivot = control_flow_ops.no_op(name=cluster_name + "/pivot")
1394 attr_value_pb2.AttrValue(s=compat.as_bytes(cluster_name)))
1396 name=cluster_name, num_replicas=num_replicas, pivot=pivot)
1524 attr_value = attr_value_pb2.AttrValue(s=compat.as_bytes(cluster_name))

12