Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for resource_infos_ (0.23 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
Back to top