- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 94 for cluster_1 (0.23 sec)
-
tensorflow/compiler/mlir/tensorflow/tests/cluster_outlining.mlir
} // CHECK: func private @[[CLUSTER]] // CHECK-SAME: () -> tensor<?xi32> // CHECK: %[[A_OUTPUT:[0-9]*]] = "tf.A"() // CHECK: return %[[A_OUTPUT]] // ----- // Tests cluster attributes are copied over to cluster_func. // CHECK-LABEL: func @cluster_attrs func.func @cluster_attrs() -> tensor<?xi32> { %0 = "tf_device.cluster"() ({ %1 = "tf.A"() : () -> tensor<?xi32>
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Apr 30 21:25:12 UTC 2024 - 4.8K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/tpu_cluster_formation.mlir
// CHECK-SAME: device = "device_1" // CHECK-SAME: topology = "topology_1" // CHECK: return %[[CLUSTER_0]], %[[CLUSTER_1]] // Test operands and results of ops of a cluster that are interleaved between // other ops of the same cluster are moved before and after the cluster // properly. // CHECK-LABEL: func @interleaved_cluster_operands_results func.func @interleaved_cluster_operands_results() {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 02 22:03:30 UTC 2024 - 53.9K bytes - Viewed (0) -
pilot/pkg/xds/endpoints/ep_filters_test.go
Weight: 42, }, }, wantWorkloadMetadata: []string{ ";ns;example;;cluster1a", ";ns;example;;cluster1a", ";ns;example;;cluster1b", ";ns;example;;cluster4", ";;;;cluster2a", ";;;;cluster2b", ";;;;cluster2b", }, }, { name: "from_network1_cluster1b", proxy: makeProxy("network1", "cluster1b"), want: []xdstest.LocLbEpInfo{ { LbEps: []xdstest.LbEpInfo{
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 01:17:58 UTC 2024 - 26.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/conversion_test.go
metav1 "k8s.io/apimachinery/pkg/apis/meta/v1" "istio.io/api/annotation" meshconfig "istio.io/api/mesh/v1alpha1" "istio.io/istio/pkg/cluster" "istio.io/istio/pkg/config/kube" "istio.io/istio/pkg/config/protocol" ) var ( domainSuffix = "company.com" clusterID = cluster.ID("test-cluster") ) func TestConvertProtocol(t *testing.T) { http := "http" type protocolCase struct { port int32
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 23 21:07:03 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/xds/server_test.go
model.EndpointType: { NonceSent: "nonce", ResourceNames: []string{"cluster2", "cluster1"}, }, }, }, request: &discovery.DiscoveryRequest{ TypeUrl: model.EndpointType, VersionInfo: "v1", ResponseNonce: "nonce", ResourceNames: []string{"cluster1", "cluster2"}, }, response: false, }, { name: "unsubscribe EDS",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 4.8K bytes - Viewed (0) -
pilot/pkg/serviceregistry/serviceentry/conversion.go
} labels := labelutil.AugmentLabels(we.Labels, clusterID, locality, "", networkID) return &model.WorkloadInstance{ Endpoint: &model.IstioEndpoint{ Address: addr, // Not setting ports here as its done by k8s controller Network: network.ID(we.Network), Locality: model.Locality{ Label: locality, ClusterID: clusterID, }, LbWeight: we.Weight, Namespace: cfg.Namespace,
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 29 02:03:58 UTC 2024 - 16.9K bytes - Viewed (0) -
pkg/test/framework/components/cluster/clusters.go
func (c Clusters) Default() Cluster { return c[0] } // GetOrDefault returns the given cluster if non-nil. Otherwise returns the first // Cluster in the list. func (c Clusters) GetOrDefault(cluster Cluster) Cluster { if cluster != nil { return cluster } return c.Default() } // GetByName returns the Cluster with the given name or nil if it is not in the list.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 4.7K bytes - Viewed (0) -
pilot/pkg/serviceregistry/kube/controller/network.go
network: *nw, } _ = ranger.Insert(rangerEntry) } if ep.GetFromRegistry() != "" && cluster.ID(ep.GetFromRegistry()) == n.clusterID { fromRegistry = true } } // fromRegistry field specified this cluster if fromRegistry { // treat endpoints in this cluster as part of this network if n.networkFromMeshConfig != "" {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 22:23:22 UTC 2024 - 15.4K bytes - Viewed (0) -
pilot/pkg/serviceregistry/aggregate/controller_test.go
registry2Counter := atomic.NewInt32(0) for _, r := range registries { counter := atomic.NewInt32(0) clusterID := r.Cluster() if clusterID == "cluster1" { counter = registry1Counter } if clusterID == "cluster2" { counter = registry2Counter } ctrl.AppendServiceHandlerForCluster(clusterID, func(_, curr *model.Service, event model.Event) { counter.Add(1) }) ctrl.AddRegistry(r) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed May 15 06:28:11 UTC 2024 - 14.5K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/internal/passes/extract_head_tail_outside_compilation.cc
return signalPassFailure(); OpBuilder builder(&getContext()); llvm::SmallVector<mlir::tf_device::ClusterOp, 4> clusters; module.walk( [&](mlir::tf_device::ClusterOp cluster) { clusters.push_back(cluster); }); for (mlir::tf_device::ClusterOp cluster : clusters) { std::string host_device; bool cluster_updated = false;
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 20.6K bytes - Viewed (0)