Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for InProgress (0.14 sec)

  1. src/encoding/gob/decode.go

    // GobEncoder/Decoder pairs.
    // Structs are considered ok; fields will be checked later.
    func (dec *Decoder) compatibleType(fr reflect.Type, fw typeId, inProgress map[reflect.Type]typeId) bool {
    	if rhs, ok := inProgress[fr]; ok {
    		return rhs == fw
    	}
    	inProgress[fr] = fw
    	ut := userType(fr)
    	wire, ok := dec.wireType[fw]
    	// If wire was encoded with an encoding method, fr must have that method.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Sep 07 19:10:23 UTC 2023
    - 40.1K bytes
    - Viewed (0)
  2. src/encoding/gob/encode.go

    	// Return the pointer to the op we're already building.
    	if opPtr := inProgress[rt]; opPtr != nil {
    		return opPtr, ut.indir
    	}
    	typ := ut.base
    	indir := ut.indir
    	k := typ.Kind()
    	var op encOp
    	if int(k) < len(encOpTable) {
    		op = encOpTable[k]
    	}
    	if op == nil {
    		inProgress[rt] = &op
    		// Special cases
    		switch t := typ; t.Kind() {
    		case reflect.Slice:
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 16 02:00:26 UTC 2024
    - 19K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/admission/plugin/resourcequota/controller.go

    	e.queue.Add(ns)
    
    	if e.inProgress.Has(ns) {
    		e.dirtyWork[ns] = append(e.dirtyWork[ns], a)
    		return
    	}
    
    	e.work[ns] = append(e.work[ns], a)
    }
    
    func (e *quotaEvaluator) completeWork(ns string) {
    	e.workLock.Lock()
    	defer e.workLock.Unlock()
    
    	e.queue.Done(ns)
    	e.work[ns] = e.dirtyWork[ns]
    	delete(e.dirtyWork, ns)
    	e.inProgress.Delete(ns)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  4. platforms/core-configuration/configuration-cache/src/integTest/groovy/org/gradle/internal/cc/impl/ConfigurationCacheBuildServiceIntegrationTest.groovy

    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Jun 10 11:47:23 UTC 2024
    - 29.1K bytes
    - Viewed (0)
Back to top