- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for resource_infos_ (0.23 sec)
-
tensorflow/compiler/mlir/tensorflow/analysis/resource_value_typed_analyzer.cc
auto* operation = resource.getDefiningOp(); if (operation && isa<TF::VarHandleOp>(operation)) return mutable_variables_.contains(GetResourceKey(operation)); auto it = resource_infos_.find(resource); if (it == resource_infos_.end()) { return false; } return it->second.potentially_written; } // Analyze the specified region for resource mutating operations, namely
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 15 09:04:13 UTC 2024 - 8K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/analysis/resource_value_typed_analyzer.h
bool potentially_written = false; }; // Key: Resource Value's // Value: Information we know about that Value. // Note that these Value's are in general in different functions. DenseMap<Value, ResourceInfo> resource_infos_; // The set of regions we already discovered. DenseSet<Region*> discovered_; // Identifiers about mutable variables. // All variables are identified by (device, container, shared_name).
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed May 15 09:04:13 UTC 2024 - 3K bytes - Viewed (0) -
tensorflow/compiler/mlir/tensorflow/transforms/promote_resources_to_args.cc
if (func_arg.getOwner() != &block) return read_op.emitOpError(kResourceFunctionMsg); ResourceInfo& resource_info = resources[func_arg.getArgNumber()]; resource_info.read = true; read_op.getValue().replaceAllUsesWith(resource_info.live_value); } else { return read_op.emitOpError(kInvalidResourceMsg); } read_op.erase();
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Apr 25 16:01:03 UTC 2024 - 17.1K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storageversion/manager.go
return } klog.V(2).Infof("storage version updates complete") s.setComplete() } // dedupResourceInfos dedups ResourceInfos with the same underlying storage. // ResourceInfos from the same Group with different Versions share the same underlying storage. // ResourceInfos from different Groups may share the same underlying storage, e.g. // networking.k8s.io ingresses and extensions ingresses. The StorageVersion manager
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 17:47:19 UTC 2023 - 10.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/groupversion.go
installer := &APIInstaller{ group: g, prefix: prefix, minRequestTimeout: g.MinRequestTimeout, } apiResources, resourceInfos, ws, registrationErrors := installer.Install() versionDiscoveryHandler := discovery.NewAPIVersionHandler(g.Serializer, g.GroupVersion, staticLister{apiResources}) versionDiscoveryHandler.AddToWebService(ws) container.Add(ws)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 5.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver.go
discoveryAPIResources, r, err := apiGroupVersion.InstallREST(s.Handler.GoRestfulContainer) if err != nil { return fmt.Errorf("unable to setup API %v: %v", apiGroupInfo, err) } resourceInfos = append(resourceInfos, r...) if utilfeature.DefaultFeatureGate.Enabled(features.AggregatedDiscoveryEndpoint) { // Aggregated discovery only aggregates resources under /apis if apiPrefix == APIGroupPrefix {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 42.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/installer.go
} if apiResource != nil { apiResources = append(apiResources, *apiResource) } if resourceInfo != nil { resourceInfos = append(resourceInfos, resourceInfo) } } return apiResources, resourceInfos, ws, errors } // newWebService creates a new restful webservice with the api installer's prefix and version. func (a *APIInstaller) newWebService() *restful.WebService {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 18:15:22 UTC 2024 - 51.5K bytes - Viewed (0)