- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 14 for mgr1 (0.41 sec)
-
tensorflow/compiler/mlir/tensorflow/utils/session_utils.cc
tensorflow::Var* GetVariableFromSession(mlir::TF::VarHandleOp var_handle_op, llvm::StringRef device_name, const tensorflow::DeviceMgr* mgr) { tensorflow::Device* device = nullptr; if (!mgr || !mgr->LookupDevice(StringRefToView(device_name), &device).ok()) return nullptr; tensorflow::Var* var_ptr = nullptr; const auto& container = var_handle_op.getContainer().str();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 3.2K bytes - Viewed (0) -
operator/pkg/controller/istiocontrolplane/istiocontrolplane_controller.go
func Add(mgr manager.Manager, options *Options) error { restConfig = mgr.GetConfig() kubeClient, err := kube.NewClient(kube.NewClientConfigForRestConfig(restConfig), "") if err != nil { return fmt.Errorf("create Kubernetes client: %v", err) } return add(mgr, &ReconcileIstioOperator{client: mgr.GetClient(), scheme: mgr.GetScheme(), kubeClient: kubeClient, options: options}, options) }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 13:56:46 UTC 2024 - 19.4K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/initialize_variables_in_session_init.cc
} } } // namespace LogicalResult InitializeVariablesInSessionInitializer( ModuleOp module, tensorflow::Session* session) { const tensorflow::DeviceMgr* mgr = nullptr; auto status = session->LocalDeviceManager(&mgr); if (!status.ok()) { module->emitError( absl::StrCat("failed to fetch device manager: ", status.message())); return failure(); } // Fetch all VarHandleOp.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu May 23 09:05:47 UTC 2024 - 7K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/tf_saved_model_freeze_variables.cc
} // namespace LogicalResult FreezeVariables(ModuleOp module, tensorflow::Session* session) { if (failed(ValidateModule(module))) return failure(); const tensorflow::DeviceMgr* mgr = nullptr; auto status = session->LocalDeviceManager(&mgr); if (!status.ok()) { module->emitError( absl::StrCat("failed to fetch device manager: ", status.message())); return failure(); }
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 09:56:53 UTC 2024 - 19.4K bytes - Viewed (0) -
pkg/controller/tainteviction/taint_eviction_test.go
nodeIndexer := informerFactory.Core().V1().Nodes().Informer().GetIndexer() mgr, _ := New(ctx, fakeClientSet, informerFactory.Core().V1().Pods(), informerFactory.Core().V1().Nodes(), "taint-eviction-controller") mgr.podListerSynced = alwaysReady mgr.nodeListerSynced = alwaysReady mgr.getPodsAssignedToNode = getPodsAssignedToNode(ctx, fakeClientSet) return mgr, podIndexer, nodeIndexer } type timestampedPod struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 14:24:16 UTC 2024 - 31.3K bytes - Viewed (0) -
src/crypto/rsa/pss.go
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:11:18 UTC 2024 - 11K bytes - Viewed (0) -
src/crypto/rsa/rsa.go
// crypto.Decrypter interface. type OAEPOptions struct { // Hash is the hash function that will be used when generating the mask. Hash crypto.Hash // MGFHash is the hash function used for MGF1. // If zero, Hash is used instead. MGFHash crypto.Hash // Label is an arbitrary byte string that must be equal to the value // used when encrypting. Label []byte } var (
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 23 00:11:18 UTC 2024 - 23.4K bytes - Viewed (0) -
src/internal/syscall/windows/syscall_windows.go
ServiceSpecificExitCode uint32 CheckPoint uint32 WaitHint uint32 } const ( SERVICE_RUNNING = 4 SERVICE_QUERY_STATUS = 4 ) //sys OpenService(mgr syscall.Handle, serviceName *uint16, access uint32) (handle syscall.Handle, err error) = advapi32.OpenServiceW //sys QueryServiceStatus(hService syscall.Handle, lpServiceStatus *SERVICE_STATUS) (err error) = advapi32.QueryServiceStatus
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Apr 26 22:55:25 UTC 2024 - 15.5K bytes - Viewed (0) -
cmd/kubeadm/app/phases/upgrade/staticpods_test.go
defer cleanup() backupEtcdDir, cleanup := getTempDir(t, "backupEtcdDir") defer cleanup() mgr := NewKubeStaticPodPathManager(realKubernetesDir, "", tempManifestDir, backupManifestDir, backupEtcdDir, test.keepManifest, test.keepEtcd) err := mgr.CleanupDirs() if err != nil { t.Errorf("unexpected error cleaning up: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 01 07:10:31 UTC 2024 - 32K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/windows/zsyscall_windows.go
} return } func CreateService(mgr Handle, serviceName *uint16, displayName *uint16, access uint32, srvType uint32, startType uint32, errCtl uint32, pathName *uint16, loadOrderGroup *uint16, tagId *uint32, dependencies *uint16, serviceStartName *uint16, password *uint16) (handle Handle, err error) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Jun 04 16:19:04 UTC 2024 - 195.8K bytes - Viewed (0)