- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 21 for newFunc (0.13 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)