Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 101 for heapLen (0.17 sec)

  1. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    // happen. The delete claim event will not invoke it, so newObj will never be nil.
    func (pl *dynamicResources) isSchedulableAfterClaimChange(logger klog.Logger, pod *v1.Pod, oldObj, newObj interface{}) (framework.QueueingHint, error) {
    	originalClaim, modifiedClaim, err := schedutil.As[*resourcev1alpha2.ResourceClaim](oldObj, newObj)
    	if err != nil {
    		// Shouldn't happen.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
  2. tensorflow/c/experimental/filesystem/filesystem_interface.h

      /// removing duplicate `/`s, and resolving `..` and `.`.
      ///
      /// Plugins must not return `nullptr`. Returning empty strings is allowed.
      ///
      /// The allocation and freeing of memory must happen via the functions sent to
      /// core TensorFlow upon registration (see the `TF_FilesystemPluginInfo`
      /// structure in Section 4).
      ///
      /// This function will be called by core TensorFlow to clean up all path
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Fri May 27 17:36:54 UTC 2022
    - 53.1K bytes
    - Viewed (0)
  3. pilot/pkg/config/kube/gateway/conversion.go

    	}
    	switch match.Uri.MatchType.(type) {
    	case *istio.StringMatch_Exact:
    		return 3
    	case *istio.StringMatch_Prefix:
    		return 2
    	case *istio.StringMatch_Regex:
    		return 1
    	}
    	// should not happen
    	return -1
    }
    
    func getURILength(match *istio.HTTPMatchRequest) int {
    	if match.Uri == nil {
    		return 0
    	}
    	switch match.Uri.MatchType.(type) {
    	case *istio.StringMatch_Prefix:
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 84.7K bytes
    - Viewed (0)
  4. src/runtime/mgc.go

    	// enabled because they must be enabled before
    	// any non-leaf heap objects are marked. Since
    	// allocations are blocked until assists can
    	// happen, we want to enable assists as early as
    	// possible.
    	setGCPhase(_GCmark)
    
    	gcBgMarkPrepare() // Must happen before assists are enabled.
    	gcMarkRootPrepare()
    
    	// Mark all active tinyalloc blocks. Since we're
    	// allocating from these, they need to be black like
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 29 16:25:21 UTC 2024
    - 62K bytes
    - Viewed (0)
  5. src/index/suffixarray/sais2.go

    	// We can process the former but want to leave the latter for the caller.
    	// We record the difference by negating j-1 if it is preceded by type S.
    	// Either way, the insertion (into the text[j-1] bucket) is guaranteed to
    	// happen at sa[i´] for some i´ > i, that is, in the portion of sa we have
    	// yet to scan. A single pass therefore sees indexes j, j-1, j-2, j-3,
    	// and so on, in sorted but not necessarily adjacent order, until it finds
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Mar 18 23:57:18 UTC 2024
    - 52.3K bytes
    - Viewed (0)
  6. src/internal/trace/order.go

    	// This event becomes advanceable when its P is not in a syscall state
    	// (lack of a P altogether is also acceptable for advancing).
    	// The transfer out of ProcSyscall can happen either voluntarily via
    	// ProcStop or involuntarily via ProcSteal. We may also acquire a new P
    	// before we get here (after the transfer out) but that's OK: that new
    	// P won't be in the ProcSyscall state anymore.
    	//
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 03 14:56:25 UTC 2024
    - 52.4K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apiextensions-apiserver/pkg/apiserver/customresource_handler.go

    func (r *crdHandler) createCustomResourceDefinition(obj interface{}) {
    	crd := obj.(*apiextensionsv1.CustomResourceDefinition)
    	r.customStorageLock.Lock()
    	defer r.customStorageLock.Unlock()
    	// this could happen if the create event is merged from create-update events
    	storageMap := r.customStorage.Load().(crdStorageMap)
    	oldInfo, found := storageMap[crd.UID]
    	if !found {
    		return
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 19:06:46 UTC 2024
    - 52.9K bytes
    - Viewed (0)
  8. pkg/proxy/winkernel/proxier.go

    		// Hcn *can* fail the query to grab the version of hcn itself (which this call will do internally before parsing
    		// to see if dual stack is supported), but the only time this can happen, at least that can be discerned, is if the host
    		// is pre-1803 and hcn didn't exist. hcsshim should truthfully return a known error if this happened that we can
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 13:25:06 UTC 2024
    - 59K bytes
    - Viewed (0)
  9. pilot/pkg/networking/core/listener.go

    		// HTTP filter chain is different from TCP filter chain's.
    		mergeTCPFilterChains(currentListenerEntry, opts, listenerOpts)
    
    	default:
    		// This should never happen
    		log.Errorf("Got unexpected conflict type %v. This should never happen", conflictType)
    	}
    }
    
    // httpListenerOpts are options for an HTTP listener
    type httpListenerOpts struct {
    	routeConfig *route.RouteConfiguration
    	rds         string
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 06 04:44:06 UTC 2024
    - 55.1K bytes
    - Viewed (0)
  10. pkg/controller/nodelifecycle/node_lifecycle_controller.go

    // processPod is processing events of assigning pods to nodes. In particular:
    // 1. for NodeReady=true node, taint eviction for this pod will be cancelled
    // 2. for NodeReady=false or unknown node, taint eviction of pod will happen and pod will be marked as not ready
    // 3. if node doesn't exist in cache, it will be skipped.
    func (nc *Controller) processPod(ctx context.Context, podItem podUpdateItem) {
    	defer nc.podUpdateQueue.Done(podItem)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.6K bytes
    - Viewed (0)
Back to top