- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 949 for node_name_ (3.27 sec)
-
tensorflow/cc/framework/ops.h
Input(const std::string& name, int32_t i, DataType dt) : node_name_(name), index_(i), data_type_(dt) {} Node* node() const { return output_.node(); } std::string node_name() const { return node_name_; } int32 index() const { return node_name_.empty() ? output_.index() : index_; } DataType data_type() const { return data_type_; }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Sat Apr 13 05:57:22 UTC 2024 - 10.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodename/node_name.go
limitations under the License. */ package nodename import ( "context" v1 "k8s.io/api/core/v1" "k8s.io/apimachinery/pkg/runtime" "k8s.io/kubernetes/pkg/scheduler/framework" "k8s.io/kubernetes/pkg/scheduler/framework/plugins/names" ) // NodeName is a plugin that checks if a pod spec node name matches the current node. type NodeName struct{} var _ framework.FilterPlugin = &NodeName{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 20 09:49:54 UTC 2023 - 2.3K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
dsw := NewDesiredStateOfWorld(volumePluginMgr) nodeName := k8stypes.NodeName("node-name") // Act dsw.AddNode(nodeName) // Assert nodeExists := dsw.NodeExists(nodeName) if !nodeExists { t.Fatalf("Added node %q does not exist, it should.", nodeName) } // Act dsw.AddNode(nodeName) // Assert nodeExists = dsw.NodeExists(nodeName) if !nodeExists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 35.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/types/nodename.go
// // To clarify the various types: // // - Node.Name is the Name field of the Node in the API. This should be stored in a NodeName. // Unfortunately, because Name is part of ObjectMeta, we can't store it as a NodeName at the API level. // // - Hostname is the hostname of the local machine (from uname -n). // However, some components allow the user to pass in a --hostname-override flag,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 2K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/actual_state_of_world_test.go
volumeSpec := controllervolumetesting.GetTestVolumeSpec(string(volumeName), volumeName) node1Name := types.NodeName("node1-name") node2Name := types.NodeName("node2-name") devicePath := "fake/device/path" // Act logger, _ := ktesting.NewTestContext(t) generatedVolumeName, err := asw.AddVolumeNode(logger, volumeName, volumeSpec, node1Name, devicePath, false) // Assert if err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 11 07:35:17 UTC 2024 - 66.1K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/reconciler/reconciler_test.go
nodeName1 := k8stypes.NodeName("node-name1") nodeName2 := k8stypes.NodeName(volumetesting.MultiAttachNode) dsw.AddNode(nodeName1) dsw.AddNode(nodeName2) generatedVolumeName, podAddErr := dsw.AddPod(types.UniquePodName(podName1), controllervolumetesting.NewPod(podName1, podName1), volumeSpec, nodeName1) if podAddErr != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 07:00:14 UTC 2024 - 72.8K bytes - Viewed (0) -
pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go
p = EmptyUniquePodName n = types.NodeName("operation-nodename") } volumeNames = append(volumeNames, v) podNames = append(podNames, p) nodeNames = append(nodeNames, n) } t.Run(fmt.Sprintf("Test %d", test.testID), func(t *testing.T) { if test.expectPass { testConcurrentOperationsPositive(t, volumeNames[0], podNames[0], nodeNames[0], volumeNames[1], podNames[1], nodeNames[1],
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 36.1K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/tests/prepare_tpu_computation_for_tf_export.mlir
func.func @CommunicateOpTokenAttrs() -> () { // CHECK: _xla_original_oc_node_name = [[NODE_NAME1:.*]], _xla_token_input_nodes = ["_xla_token_arg_node"] %0 = "tf.XlaRecvFromHost"() {key = "recv_key", shape = #tf_type.shape<>} : () -> tensor<i32> // CHECK: _xla_original_oc_node_name = [[NODE_NAME2:.*]], _xla_token_input_nodes = {{\[}}[[NODE_NAME1]]{{\]}} "tf.XlaSendToHost"(%0) {key = "send_key"} : (tensor<i32>) -> ()
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 14 18:46:36 UTC 2024 - 9.2K bytes - Viewed (0) -
cluster/log-dump/log-dump.sh
else echo 'Detecting nodes in the cluster' detect-node-names &> /dev/null if [[ -n "${NODE_NAMES:-}" ]]; then node_names=( "${NODE_NAMES[@]}" ) fi if [[ -n "${WINDOWS_NODE_NAMES:-}" ]]; then windows_node_names=( "${WINDOWS_NODE_NAMES[@]}" ) fi fi if [[ "${#node_names[@]}" == 0 && "${#windows_node_names[@]}" == 0 ]]; then echo 'No nodes found!' return fi
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 21:15:57 UTC 2024 - 28.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/quantization/common/quantization_lib/quantization_config.cc
return result; } } // namespace void ParseCustomOpSpecs(const absl::string_view node_names, const CustomOpUpdateOptions& update_option, CustomOpMap& custom_op_map) { if (node_names.empty()) return; const std::vector<std::string> custom_nodes = absl::StrSplit(node_names, ','); for (const std::string& cur_node : custom_nodes) {
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Tue Mar 05 07:39:40 UTC 2024 - 5.9K bytes - Viewed (0)