- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 20 for mgr2 (0.05 sec)
-
pilot/pkg/model/network.go
env.AppendNetworkGatewayHandler(mgr.reloadGateways) nameCache.AppendNetworkGatewayHandler(mgr.reloadGateways) mgr.reload() return mgr, nil } // reloadGateways reloads NetworkGateways and triggers a push if they change. func (mgr *NetworkManager) reloadGateways() { changed := mgr.reload() if changed && mgr.xdsUpdater != nil { log.Infof("gateways changed, triggering push")
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 24 03:31:28 UTC 2023 - 16.9K bytes - Viewed (0) -
pkg/kubelet/cm/cpumanager/cpu_manager_test.go
sourcesReady: &sourcesReadyStub{}, } mgr.sourcesReady = &sourcesReadyStub{} mgr.allocatableCPUs = testCase.policy.GetAllocatableCPUs(mgr.state) pod := makePod("fakePod", "fakeContainer", "2", "2") container := &pod.Spec.Containers[0] _ = mgr.Allocate(pod, container) if !mgr.GetAllocatableCPUs().Equals(testCase.expAllocatableCPUs) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 06 13:16:15 UTC 2023 - 42.9K bytes - Viewed (0) -
pilot/pkg/status/resourcelock_test.go
} var runCount int32 x := make(chan struct{}) y := make(chan struct{}) mgr := NewManager(nil) fakefunc := func(status *v1alpha1.IstioStatus, context any) *v1alpha1.IstioStatus { x <- struct{}{} atomic.AddInt32(&runCount, 1) y <- struct{}{} return nil } c1 := mgr.CreateIstioStatusController(fakefunc) c2 := mgr.CreateIstioStatusController(fakefunc) workers := NewWorkerPool(func(_ *config.Config, _ any) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Oct 31 14:48:28 UTC 2023 - 2.1K bytes - Viewed (0) -
src/cmd/vendor/golang.org/x/sys/windows/service.go
//sys 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) [failretval==0] = advapi32.CreateServiceW
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 23:33:33 UTC 2023 - 10.3K bytes - Viewed (0) -
operator/cmd/operator/server.go
// Setup Scheme for all resources if err := apis.AddToScheme(mgr.GetScheme()); err != nil { log.Fatalf("Could not add manager scheme: %v", err) } // Setup all Controllers options := &istiocontrolplane.Options{Force: sArgs.force, MaxConcurrentReconciles: sArgs.maxConcurrentReconciles} if err := controller.AddToManager(mgr, options); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Aug 30 21:09:08 UTC 2023 - 7.6K bytes - Viewed (0) -
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) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/catalog/SimpleGeneratedJavaClassCompiler.java
try (StandardJavaFileManager mgr = compiler.getStandardFileManager(ds, null, null)) { List<String> options = buildOptions(dstDir, classPath); List<File> filesToCompile = outputSourceFilesToSourceDir(srcDir, classes); if (dstDir.exists() || dstDir.mkdirs()) { Iterable<? extends JavaFileObject> sources = mgr.getJavaFileObjectsFromFiles(filesToCompile);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 10 21:10:11 UTC 2023 - 5.4K 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)