- Sort Score
- Result 10 results
- Languages All
Results 171 - 180 of 1,162 for Pool (0.02 sec)
-
cmd/xl-storage-format-v2.go
func (x xlMetaV2VersionHeader) matchesNotStrict(o xlMetaV2VersionHeader) (ok bool) { ok = x.VersionID == o.VersionID && x.Type == o.Type && x.matchesEC(o) if x.VersionID == [16]byte{} { ok = ok && o.ModTime == x.ModTime } return ok } func (x xlMetaV2VersionHeader) matchesEC(o xlMetaV2VersionHeader) bool { if x.hasEC() && o.hasEC() { return x.EcN == o.EcN && x.EcM == o.EcM
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 65.6K bytes - Viewed (1) -
cmd/erasure-healing.go
// skipped, like the meta-bucket. if isReservedOrInvalidBucket(volInfo.Name, false) { continue } healBuckets.Compute(volInfo.Name, func(oldValue VolInfo, loaded bool) (newValue VolInfo, del bool) { if loaded { newValue = oldValue newValue.count = oldValue.count + 1 return newValue, false } return VolInfo{ Name: volInfo.Name,
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 34.7K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbFile.java
Registered: Sat Dec 20 13:44:44 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 103.2K bytes - Viewed (0) -
cmd/test-utils_test.go
// modify the user-agent. // // Authorization: // // Is skipped for obvious reasons var ignoredHeaders = map[string]bool{ "Authorization": true, "User-Agent": true, } // Headers to ignore in streaming v4 var ignoredStreamingHeaders = map[string]bool{ "Authorization": true, "Content-Type": true, "Content-Md5": true, "User-Agent": true, }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 77K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java
Thread.yield(); long d = ns - (System.nanoTime() - startTime); if (d > 0L) millis = d / (1000 * 1000); else break; } } /** Waits out termination of a thread pool or fails doing so. */ void joinPool(ExecutorService exec) throws InterruptedException { try { exec.shutdown(); assertTrue( "ExecutorService did not terminate in a timely manner",
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 20:07:52 UTC 2025 - 37.8K bytes - Viewed (0) -
api/go1.3.txt
pkg regexp/syntax, method (InstOp) String() string pkg runtime/debug, func SetPanicOnFault(bool) bool pkg runtime/debug, func WriteHeapDump(uintptr) pkg sync, method (*Pool) Get() interface{} pkg sync, method (*Pool) Put(interface{}) pkg sync, type Pool struct pkg sync, type Pool struct, New func() interface{} pkg syscall (darwin-386), func FcntlFlock(uintptr, int, *Flock_t) error
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Mon Jun 02 02:45:00 UTC 2014 - 117K bytes - Viewed (0) -
cmd/server-main.go
globalTierConfigMgr = NewTierConfigMgr() globalTransitionState = newTransitionState(GlobalContext) globalSiteResyncMetrics = newSiteResyncMetrics(GlobalContext) } func configRetriableErrors(err error) bool { if err == nil { return false } notInitialized := strings.Contains(err.Error(), "Server not initialized, please try again") || errors.Is(err, errServerNotInitialized)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue May 27 15:18:36 UTC 2025 - 35.9K bytes - Viewed (4) -
doc/go_mem.html
<p> The <code>sync</code> package provides additional synchronization abstractions, including <a href="/pkg/sync/#Cond">condition variables</a>, <a href="/pkg/sync/#Map">lock-free maps</a>, <a href="/pkg/sync/#Pool">allocation pools</a>, and <a href="/pkg/sync/#WaitGroup">wait groups</a>. The documentation for each of these specifies the guarantees it makes concerning synchronization. </p> <p>
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Tue Aug 05 15:41:37 UTC 2025 - 26.6K bytes - Viewed (0) -
cmd/xl-storage.go
// Indicate of NSScanner is in progress in this disk scanning int32 drivePath string endpoint Endpoint globalSync bool oDirect bool // indicates if this disk supports ODirect diskID string formatFileInfo os.FileInfo formatFile string formatLegacy bool formatLastCheck time.Time diskInfoCache *cachevalue.Cache[DiskInfo] sync.RWMutex formatData []byte
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 91.7K bytes - Viewed (0) -
src/cmd/asm/internal/asm/testdata/arm64.s
FMOVD 0x8008(R1), F2 // FMOVD 32776(R1), F2 // 3b204091620740fd FMOVD 0x1006ff8(R1), F2 // FMOVD 16805880(R1), F2 // 3bfc7f9162ff7ffd // very large or unaligned offset uses constant pool. // the encoding cannot be checked as the address of the constant pool is unknown. // here we only test that they can be assembled. MOVB R1, 0x1000000(R2) // MOVB R1, 16777216(R2) MOVB R1, 0x44332211(R2) // MOVB R1, 1144201745(R2)
Registered: Tue Dec 30 11:13:12 UTC 2025 - Last Modified: Mon Nov 10 17:34:13 UTC 2025 - 96.1K bytes - Viewed (0)