Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 21 for newFunc (0.13 sec)

  1. staging/src/k8s.io/apiserver/pkg/storage/storagebackend/factory/etcd3.go

    		compactor.refs--
    		if compactor.refs == 0 {
    			compactor.cancel()
    			compactor.client.Close()
    			delete(compactors, key)
    		}
    	}, nil
    }
    
    func newETCD3Storage(c storagebackend.ConfigForResource, newFunc, newListFunc func() runtime.Object, resourcePrefix string) (storage.Interface, DestroyFunc, error) {
    	stopCompactor, err := startCompactorOnce(c.Transport, c.CompactionInterval)
    	if err != nil {
    		return nil, nil, err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 07:56:39 UTC 2024
    - 15.1K bytes
    - Viewed (0)
  2. src/cmd/compile/internal/ssa/func.go

    }
    
    type LocalSlotSplitKey struct {
    	parent *LocalSlot
    	Off    int64       // offset of slot in N
    	Type   *types.Type // type of slot
    }
    
    // NewFunc returns a new, empty function object.
    // Caller must reset cache before calling NewFunc.
    func (c *Config) NewFunc(fe Frontend, cache *Cache) *Func {
    	return &Func{
    		fe:     fe,
    		Config: c,
    		Cache:  cache,
    
    		NamedValues:          make(map[LocalSlot][]*Value),
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Jun 10 19:44:43 UTC 2024
    - 25.8K bytes
    - Viewed (0)
  3. src/cmd/compile/internal/ssagen/abi.go

    		return
    	}
    
    	// Reuse f's types.Sym to create a new ODCLFUNC/function.
    	// TODO(mdempsky): Means we can't set sym.Def in Declfunc, ugh.
    	fn := ir.NewFunc(pos, pos, f.Sym(), types.NewSignature(nil,
    		typecheck.NewFuncParams(ft.Params()),
    		typecheck.NewFuncParams(ft.Results())))
    	fn.ABI = wrapperABI
    	typecheck.DeclFunc(fn)
    
    	fn.SetABIWrapper(true)
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed May 15 19:57:43 UTC 2024
    - 13.8K bytes
    - Viewed (0)
  4. src/cmd/compile/internal/rangefunc/rewrite.go

    	intType := types2.Universe.Lookup("int").Type()
    
    	// func deferrangefunc() unsafe.Pointer
    	obj := types2.NewFunc(nopos, pkg, "deferrangefunc", types2.NewSignatureType(nil, nil, nil, nil, types2.NewTuple(types2.NewParam(nopos, pkg, "extra", anyType)), false))
    	pkg.Scope().Insert(obj)
    
    	// func panicrangestate()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:05:44 UTC 2024
    - 41.6K bytes
    - Viewed (0)
  5. src/cmd/compile/internal/types2/resolver.go

    				obj := NewTypeName(s.Name.Pos(), pkg, s.Name.Value, nil)
    				check.declarePkgObj(s.Name, obj, &declInfo{file: fileScope, tdecl: s})
    
    			case *syntax.FuncDecl:
    				name := s.Name.Value
    				obj := NewFunc(s.Name.Pos(), pkg, name, nil)
    				hasTParamError := false // avoid duplicate type parameter errors
    				if s.Recv == nil {
    					// regular function
    					if name == "init" || name == "main" && pkg.name == "main" {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Apr 18 14:10:44 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  6. src/go/types/resolver.go

    				obj := NewTypeName(d.spec.Name.Pos(), pkg, d.spec.Name.Name, nil)
    				check.declarePkgObj(d.spec.Name, obj, &declInfo{file: fileScope, tdecl: d.spec})
    			case funcDecl:
    				name := d.decl.Name.Name
    				obj := NewFunc(d.decl.Name.Pos(), pkg, name, nil) // signature set later
    				hasTParamError := false                           // avoid duplicate type parameter errors
    				if d.decl.Recv.NumFields() == 0 {
    					// regular function
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Fri May 17 16:22:59 UTC 2024
    - 26.1K bytes
    - Viewed (0)
  7. pkg/registry/core/persistentvolume/strategy_test.go

    	)
    }
    
    func TestStatusUpdate(t *testing.T) {
    	now := metav1.Now()
    	origin := metav1.NewTime(now.Add(time.Hour))
    	later := metav1.NewTime(now.Add(time.Hour * 2))
    	NowFunc = func() metav1.Time { return now }
    	defer func() {
    		NowFunc = metav1.Now
    	}()
    	tests := []struct {
    		name        string
    		fg          bool
    		oldObj      *api.PersistentVolume
    		newObj      *api.PersistentVolume
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 11K bytes
    - Viewed (0)
  8. pkg/kubelet/nodestatus/setters.go

    func MemoryPressureCondition(nowFunc func() time.Time, // typically Kubelet.clock.Now
    	pressureFunc func() bool, // typically Kubelet.evictionManager.IsUnderMemoryPressure
    	recordEventFunc func(eventType, event string), // typically Kubelet.recordNodeStatusEvent
    ) Setter {
    	return func(ctx context.Context, node *v1.Node) error {
    		currentTime := metav1.NewTime(nowFunc())
    		var condition *v1.NodeCondition
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 12:12:04 UTC 2024
    - 30.5K bytes
    - Viewed (0)
  9. src/runtime/runtime.go

    	name string
    	inc  atomic.Pointer[func()]
    }
    
    func (g *godebugInc) IncNonDefault() {
    	inc := g.inc.Load()
    	if inc == nil {
    		newInc := godebugNewIncNonDefault.Load()
    		if newInc == nil {
    			return
    		}
    		inc = new(func())
    		*inc = (*newInc)(g.name)
    		if raceenabled {
    			racereleasemerge(unsafe.Pointer(&g.inc))
    		}
    		if !g.inc.CompareAndSwap(nil, inc) {
    			inc = g.inc.Load()
    		}
    	}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu May 23 01:16:47 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  10. tensorflow/compiler/mlir/tensorflow/transforms/sparsecore/embedding_sequencing.cc

      auto caller = MakeFuncCaller(builder, module.getLoc(), new_func, inputs);
    
      Block* block = new_func.addEntryBlock();
    
      for (Operation* op : topological_order) op->moveBefore(block, block->end());
    
      // Replace the 'inputs' values with the new function's arguments.
      for (auto p : llvm::zip(inputs, new_func.getArguments()))
        replaceAllUsesInRegionWith(std::get<0>(p), std::get<1>(p),
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Thu Apr 25 16:01:03 UTC 2024
    - 39.4K bytes
    - Viewed (0)
Back to top