- Sort Score
- Num 10 results
- Language All
Results 141 - 150 of 218 for unpack (0.04 seconds)
-
doc/go_mem.html
Created: Tue Dec 30 11:13:12 GMT 2025 - Last Modified: Tue Aug 05 15:41:37 GMT 2025 - 26.6K bytes - Click Count (0) -
internal/config/browser/browser.go
ReferrerPolicy string `json:"referrer_policy"` } // Update Updates browser with new config func (browseCfg *Config) Update(newCfg Config) { configLock.Lock() defer configLock.Unlock() browseCfg.CSPPolicy = newCfg.CSPPolicy browseCfg.HSTSSeconds = newCfg.HSTSSeconds browseCfg.HSTSIncludeSubdomains = newCfg.HSTSIncludeSubdomains browseCfg.HSTSPreload = newCfg.HSTSPreload
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Jun 21 00:58:58 GMT 2024 - 5.9K bytes - Click Count (0) -
cmd/erasure-object.go
} if !dstOpts.NoLock { lk := er.NewNSLock(dstBucket, dstObject) lkctx, err := lk.GetLock(ctx, globalOperationTimeout) if err != nil { return oi, err } ctx = lkctx.Context() defer lk.Unlock(lkctx) } // Read metadata associated with the object from all disks. storageDisks := er.getDisks() var metaArr []FileInfo var errs []error // Read metadata associated with the object from all disks.Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 80.4K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Writer.kt
) : Closeable, Lockable { private val hpackBuffer: Buffer = Buffer() private var maxFrameSize: Int = INITIAL_MAX_FRAME_SIZE private var closed: Boolean = false val hpackWriter: Hpack.Writer = Hpack.Writer(out = hpackBuffer) @Throws(IOException::class) fun connectionPreface() { withLock { if (closed) throw IOException("closed")Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Wed May 28 23:28:25 GMT 2025 - 11K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java
GcFinalization.awaitClear(garbage); Lock writeLock = striped.get(key).writeLock(); readLock.lock(); assertFalse(writeLock.tryLock()); readLock.unlock(); } @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts. public void testStrongImplementations() { for (Striped<?> striped : strongImplementations()) {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 18:19:59 GMT 2025 - 8.5K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/StripedTest.java
GcFinalization.awaitClear(garbage); Lock writeLock = striped.get(key).writeLock(); readLock.lock(); assertFalse(writeLock.tryLock()); readLock.unlock(); } @AndroidIncompatible // Presumably GC doesn't trigger, despite our efforts. public void testStrongImplementations() { for (Striped<?> striped : strongImplementations()) {
Created: Fri Dec 26 12:43:10 GMT 2025 - Last Modified: Tue Oct 28 18:19:59 GMT 2025 - 8.5K bytes - Click Count (0) -
cmd/metrics-v3-types.go
ch <- metric } } // LockAndSetBuckets - locks the buckets and sets the given buckets. It returns // a function to unlock the buckets. func (mg *MetricsGroup) LockAndSetBuckets(buckets []string) func() { mg.bucketsLock.Lock() mg.buckets = buckets return func() { mg.bucketsLock.Unlock() } } // MetricFQN - returns the fully qualified name for the given metric name.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Feb 28 19:33:08 GMT 2025 - 15.6K bytes - Click Count (0) -
cmd/erasure-object-conditional_test.go
z.serverPools[0].erasureDisksMu.Lock() xl.getDisks = func() []StorageAPI { for i := range erasureDisks[:8] { erasureDisks[i] = nil } return erasureDisks } z.serverPools[0].erasureDisksMu.Unlock() t.Run("if-none-match with read quorum failure", func(t *testing.T) { // Test Case 1: if-none-match (create only if doesn't exist) // With if-none-match: *, this should only succeed if object doesn't exist.
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Fri Oct 24 04:05:31 GMT 2025 - 4.9K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Http2Reader.kt
private val source: BufferedSource, private val client: Boolean, ) : Closeable { private val continuation: ContinuationSource = ContinuationSource(this.source) private val hpackReader: Hpack.Reader = Hpack.Reader( source = continuation, headerTableSizeSetting = 4096, ) @Throws(IOException::class) fun readConnectionPreface(handler: Handler) { if (client) {Created: Fri Dec 26 11:42:13 GMT 2025 - Last Modified: Fri Dec 27 13:39:56 GMT 2024 - 19.8K bytes - Click Count (0) -
cmd/consolelogger.go
Created: Sun Dec 28 19:28:13 GMT 2025 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 5.4K bytes - Click Count (0)