- Sort Score
- Result 10 results
- Languages All
Results 11 - 14 of 14 for initPipe (0.19 sec)
-
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) -
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) -
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) -
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)