- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 165 for Allocate (0.11 sec)
-
src/unique/handle.go
// this path on the first use of Make, and it's not on the hot path. setupMake.Do(registerCleanup) ma = addUniqueMap[T](typ) } m := ma.(*uniqueMap[T]) // Keep around any values we allocate for insertion. There // are a few different ways we can race with other threads // and create values that we might discard. By keeping // the first one we make around, we can avoid generating
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 16:01:55 UTC 2024 - 5.3K bytes - Viewed (0) -
pkg/dns/server/name_table.go
continue } addressList = append(addressList, svcAddress) } else { // The IP will be unspecified here if its headless service or if the auto // IP allocation logic for service entry was unable to allocate an IP. if svc.Resolution == model.Passthrough && len(svc.Ports) > 0 { for _, instance := range cfg.Push.ServiceEndpointsByPort(svc, svc.Ports[0].Port, nil) { // empty addresses are possible here
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 27 07:19:38 UTC 2024 - 6.3K bytes - Viewed (0) -
src/runtime/os_aix.go
perrno uintptr // pointer to tls errno } //go:nosplit func semacreate(mp *m) { if mp.waitsema != 0 { return } var sem *semt // Call libc's malloc rather than malloc. This will // allocate space on the C heap. We can't call mallocgc // here because it could cause a deadlock. sem = (*semt)(malloc(unsafe.Sizeof(*sem))) if sem_init(sem, 0, 0) != 0 { throw("sem_init") }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 8.9K bytes - Viewed (0) -
cmd/kubeadm/app/cmd/options/constant.go
NetworkingServiceSubnet = "service-cidr" // NetworkingPodSubnet flag sets the range of IP addresses for the pod network. If set, the control plane will automatically allocate CIDRs for every node. NetworkingPodSubnet = "pod-network-cidr" // NodeCRISocket flag sets the CRI socket to connect to. NodeCRISocket = "cri-socket" // NodeName flag sets the node name. NodeName = "node-name"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Feb 29 05:14:21 UTC 2024 - 6.9K bytes - Viewed (0) -
src/runtime/sigqueue.go
// license that can be found in the LICENSE file. // This file implements runtime support for signal handling. // // Most synchronization primitives are not available from // the signal handler (it cannot block, allocate memory, or use locks) // so the handler communicates with a processing goroutine // via struct sig, below. // // sigsend is called by the signal handler to queue a new signal.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 7.6K bytes - Viewed (0) -
src/mime/multipart/formdata.go
if _, err := file.Write(b.Bytes()); err != nil { return nil, err } if copyBuf == nil { copyBuf = make([]byte, 32*1024) // same buffer size as io.Copy uses } // os.File.ReadFrom will allocate its own copy buffer if we let io.Copy use it. type writerOnly struct{ io.Writer } remainingSize, err := io.CopyBuffer(writerOnly{file}, p, copyBuf) if err != nil { return nil, err }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Mar 21 16:12:35 UTC 2024 - 7.7K bytes - Viewed (0) -
src/runtime/cpuprof.go
cpuprof.addExtra() cpuprof.log.close() } unlock(&cpuprof.lock) } // add adds the stack trace to the profile. // It is called from signal handlers and other limited environments // and cannot allocate memory or acquire locks that might be // held at the time of the signal, nor can it use substantial amounts // of stack. // //go:nowritebarrierrec func (p *cpuProfile) add(tagPtr *unsafe.Pointer, stk []uintptr) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 29 17:58:53 UTC 2024 - 8.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go
go func() { defer func() { err := recover() // do not wrap the sentinel ErrAbortHandler panic value if err != nil && err != http.ErrAbortHandler { // Same as stdlib http server code. Manually allocate stack // trace buffer size to prevent excessively large logs const size = 64 << 10 buf := make([]byte, size) buf = buf[:runtime.Stack(buf, false)] err = fmt.Sprintf("%v\n%s", err, buf) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 8.9K bytes - Viewed (0) -
src/runtime/sys_windows_amd64.s
MOVQ mp+0(FP), AX LEAQ m_tls(AX), DI CALL runtime·settls(SB) RET // This is called from rt0_go, which runs on the system stack // using the initial stack allocated by the OS. TEXT runtime·wintls(SB),NOSPLIT,$0 // Allocate a TLS slot to hold g across calls to external code MOVQ SP, AX ANDQ $~15, SP // alignment as per Windows requirement SUBQ $48, SP // room for SP and 4 args as per Windows requirement
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 19 07:24:08 UTC 2024 - 8.4K bytes - Viewed (0) -
src/sync/poolqueue.go
d = new(poolChainElt) d.vals = make([]eface, initSize) c.head = d c.tail.Store(d) } if d.pushHead(val) { return } // The current dequeue is full. Allocate a new one of twice // the size. newSize := len(d.vals) * 2 if newSize >= dequeueLimit { // Can't make it any bigger. newSize = dequeueLimit } d2 := &poolChainElt{} d2.prev.Store(d)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Feb 26 18:12:29 UTC 2024 - 8.3K bytes - Viewed (0)