Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 165 for Allocate (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top