Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 15 of 15 for initPipe (0.14 sec)

  1. src/syscall/security_windows.go

    func (t Token) Close() error {
    	return CloseHandle(Handle(t))
    }
    
    // getInfo retrieves a specified type of information about an access token.
    func (t Token) getInfo(class uint32, initSize int) (unsafe.Pointer, error) {
    	n := uint32(initSize)
    	for {
    		b := make([]byte, n)
    		e := GetTokenInformation(t, class, &b[0], uint32(len(b)), &n)
    		if e == nil {
    			return unsafe.Pointer(&b[0]), nil
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Sep 12 16:42:41 UTC 2023
    - 10K bytes
    - Viewed (0)
  2. src/sync/poolqueue.go

    	next, prev atomic.Pointer[poolChainElt]
    }
    
    func (c *poolChain) pushHead(val any) {
    	d := c.head
    	if d == nil {
    		// Initialize the chain.
    		const initSize = 8 // Must be a power of 2
    		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.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon Feb 26 18:12:29 UTC 2024
    - 8.3K bytes
    - Viewed (0)
  3. cmd/bucket-replication-metrics.go

    }
    
    // newRateMeasurement creates a new instance of the measurement with the initial start time.
    func newRateMeasurement(initTime time.Time) *rateMeasurement {
    	return &rateMeasurement{
    		startTime: initTime,
    	}
    }
    
    // incrementBytes add bytes reported for a bucket/target.
    func (m *rateMeasurement) incrementBytes(bytes uint64) {
    	atomic.AddUint64(&m.bytesSinceLastWindow, bytes)
    }
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Tue Feb 06 06:00:45 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  4. pkg/wasm/cache_test.go

    			}
    			cache := NewLocalFileCache(tmpDir, options)
    			cache.httpFetcher.initialBackoff = time.Microsecond
    			defer close(cache.stopChan)
    
    			var cacheHitKey *moduleKey
    			initTime := time.Now()
    			cache.mux.Lock()
    			for k, m := range c.initialCachedModules {
    				filePath := generateModulePath(t, tmpDir, k.name, m.modulePath)
    				err := os.WriteFile(filePath, []byte("data/\n"), 0o644)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Apr 17 20:06:41 UTC 2024
    - 33.9K bytes
    - Viewed (0)
  5. src/cmd/vendor/golang.org/x/sys/windows/security_windows.go

    func (t Token) Close() error {
    	return CloseHandle(Handle(t))
    }
    
    // getInfo retrieves a specified type of information about an access token.
    func (t Token) getInfo(class uint32, initSize int) (unsafe.Pointer, error) {
    	n := uint32(initSize)
    	for {
    		b := make([]byte, n)
    		e := GetTokenInformation(t, class, &b[0], uint32(len(b)), &n)
    		if e == nil {
    			return unsafe.Pointer(&b[0]), nil
    		}
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 52.5K bytes
    - Viewed (0)
Back to top