- Sort Score
- Result 10 results
- Languages All
Results 121 - 130 of 180 for unpack (0.1 sec)
-
cmd/metrics-v3-cache.go
v.ioStats[d] = getDriveIOStatMetrics(getDiffStats(ps, cs), duration) } } } } prevDriveIOStats = currentStats prevDriveIOStatsRefreshedAt = now prevDriveIOStatsMu.Unlock() return } return cachevalue.NewFromFunc(1*time.Minute, cachevalue.Opts{ReturnLastGood: true}, loadDriveMetrics) } func newCPUMetricsCache() *cachevalue.Cache[madmin.CPUMetrics] {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Sun Mar 30 00:56:02 UTC 2025 - 8K bytes - Viewed (0) -
cmd/naughty-disk_test.go
} func (d *naughtyDisk) Close() (err error) { if err = d.calcError(); err != nil { return err } return d.disk.Close() } func (d *naughtyDisk) calcError() (err error) { d.mu.Lock() defer d.mu.Unlock() d.callNR++ if err, ok := d.errors[d.callNR]; ok { return err } if d.defaultErr != nil { return d.defaultErr } return nil }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Apr 25 05:41:04 UTC 2025 - 10.1K bytes - Viewed (0) -
docs/smb3-features/01-smb3-lease-design.md
leases.put(newKey, newEntry); pathToLease.put(path, newKey); return newKey; } finally { lock.writeLock().unlock(); } } public void updateLease(Smb2LeaseKey key, int grantedState) { LeaseEntry entry = leases.get(key); if (entry != null) { entry.updateState(grantedState);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 02:53:50 UTC 2025 - 22K bytes - Viewed (0) -
docs/changelogs/changelog_2x.md
* New: APIs to iterate and selectively clear the response cache. * New: Support for SOCKS proxies. * New: Support for `TLS_FALLBACK_SCSV`. * New: Update HTTP/2 support to `h2-16` and `hpack-10`. * New: APIs to prevent retrying non-idempotent requests. * Fix: Drop NPN support. Going forward we support ALPN only. * Fix: The hostname verifier is now strict. This is consistent with the hostname
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 26.6K bytes - Viewed (0) -
cmd/prepare-storage.go
return func(endpoint Endpoint, err error, once bool) { reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String()) ctx := logger.SetReqInfo(GlobalContext, reqInfo) mutex.Lock() defer mutex.Unlock() m, ok := printOnce[endpoint] if !ok { m = make(map[string]int) printOnce[endpoint] = m if once { m[err.Error()]++ peersLogAlwaysIf(ctx, err) return } }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (1) -
docs/changelogs/changelog_1x.md
it throws an `InterruptedIOException`. ## Version 1.5.2 _2014-03-17_ * Fix bug where deleting a file that was absent from the `HttpResponseCache` caused an IOException. * Fix bug in HTTP/2 where our HPACK decoder wasn't emitting entries in certain eviction scenarios, leading to dropped response headers. ## Version 1.5.1 _2014-03-11_ * Fix 1.5.0 regression where connections should not have been recycled.
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Sun Feb 06 02:19:09 UTC 2022 - 6.4K bytes - Viewed (0) -
tensorflow/BUILD
"@platforms//:__subpackages__", "@snappy//:__subpackages__", "@upb//:__subpackages__", "@zlib//:__subpackages__", "@dlpack//:__subpackages__", "@arm_neon_2_x86_sse//:__subpackages__", "@cpuinfo//:__subpackages__", "@ruy//:__subpackages__", "@XNNPACK//:__subpackages__", "@pthreadpool//:__subpackages__", "@FXdiv//:__subpackages__", "@FP16//:__subpackages__",
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Thu Aug 28 19:11:51 UTC 2025 - 53.4K bytes - Viewed (0) -
src/main/java/jcifs/SmbConstants.java
*/ int DEFAULT_CONN_TIMEOUT = 35000; /** * No flags set in SMB header. */ int FLAGS_NONE = 0x00; /** * Obsolete lock and read/write and unlock flag. */ int FLAGS_LOCK_AND_READ_WRITE_AND_UNLOCK = 0x01; /** * Receive buffer has been posted flag. */ int FLAGS_RECEIVE_BUFFER_POSTED = 0x02; /**
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sun Aug 24 00:49:49 UTC 2025 - 12.8K bytes - Viewed (0) -
ci/official/containers/ml_build_arm64/builder.devtoolset/gcc9-fixups.patch
+ { while (*ep != NULL) if (!strncmp (*ep, name, len) && (*ep)[len] == '=') { @@ -332,6 +333,7 @@ unsetenv (const char *name) } else ++ep; + } UNLOCK; diff --git a/support/Makefile b/support/Makefile index a253698..2f4e2a9 100644 --- a/support/Makefile +++ b/support/Makefile @@ -167,13 +167,6 @@ CFLAGS-support_paths.c = \ -DINSTDIR_PATH=\"$(prefix)\" \
Registered: Tue Sep 09 12:39:10 UTC 2025 - Last Modified: Mon Nov 11 19:25:56 UTC 2024 - 8.9K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/ws/WebSocketReader.kt
readControlFrame() } } /** * Reads a message body into across one or more frames. Control frames that occur between * fragments will be processed. If the message payload is masked this will unmask as it's being * processed. */ @Throws(IOException::class) private fun readMessage() { while (true) { if (closed) throw IOException("closed") if (frameLength > 0L) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Tue Jul 29 22:04:11 UTC 2025 - 9.9K bytes - Viewed (0)