- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 320 for compacted (0.48 sec)
-
cmd/data-usage-cache.go
due, ok := d.Cache[hashPath(path).Key()] if !ok { return nil } return &due } // isCompacted returns whether an entry is compacted. // Returns false if not found. func (d *dataUsageCache) isCompacted(h dataUsageHash) bool { due, ok := d.Cache[h.Key()] if !ok { return false } return due.Compacted } // findChildrenCopy returns a copy of the children of the supplied hash.
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 41.4K bytes - Viewed (1) -
cmd/data-scanner.go
} if !into.Compacted && f.newCache.Info.Name != folder.name { flat := f.newCache.sizeRecursive(thisHash.Key()) flat.Compacted = true var compact bool if flat.Objects < dataScannerCompactLeastObject { compact = true } else { // Compact if we only have objects as children... compact = true for k := range into.Children {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Apr 22 17:49:30 GMT 2024 - 47.4K bytes - Viewed (0) -
cmd/data-usage_test.go
}, { // Gets compacted... path: "bucket/dir1", size: 1302010, objs: 5, oSizes: sizeHistogram{0: 1, 1: 1, 2: 2, 4: 1}, }, { // Gets compacted at this level... path: "bucket/dirwithalot/0", size: filesBelowT, objs: filesBelowT, oSizes: sizeHistogram{0: filesBelowT}, }, { // Gets compacted at this level (below obj threshold)...
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Wed Mar 27 15:10:40 GMT 2024 - 14.1K bytes - Viewed (0) -
cmd/data-usage-cache_gen.go
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Thu Mar 21 17:21:35 GMT 2024 - 100.8K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/TestUtilJvm.kt
* the internal list. */ @JvmStatic fun fragmentBuffer(buffer: Buffer): Buffer { // Write each byte into a new buffer, then clone it so that the segments are shared. // Shared segments cannot be compacted so we'll get a long chain of short segments. val result = Buffer() while (!buffer.exhausted()) { val box = Buffer() box.write(buffer, 1) result.write(box.copy(), 1) } return result
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Thu Apr 11 22:09:35 GMT 2024 - 4.3K bytes - Viewed (0) -
cmd/data-scanner-metric.go
scannerMetricScanFolder // Scan a folder on disk, recursively. scannerMetricScanCycle // Full cycle, cluster global scannerMetricScanBucketDrive // Single bucket on one drive scannerMetricCompactFolder // Folder compacted. // Must be last: scannerMetricLast ) // log scanner action. // Use for s > scannerMetricStartTrace func (p *scannerMetrics) log(s scannerMetric, paths ...string) func(custom map[string]string) {
Go - Registered: Sun Apr 28 19:28:10 GMT 2024 - Last Modified: Mon Sep 25 05:15:31 GMT 2023 - 9.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache/DiskLruCache.kt
* o READ lines track accesses for LRU. * * o REMOVE lines track entries that have been deleted. * * The journal file is appended to as cache operations occur. The journal may occasionally be * compacted by dropping redundant lines. A temporary file named "journal.tmp" will be used during * compaction; that file should be deleted if it exists when the cache is opened. */ private val journalFile: Path
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 34.7K bytes - Viewed (0) -
tests/test_computed_fields.py
from .utils import needs_pydanticv2 @pytest.fixture(name="client") def get_client(): app = FastAPI() from pydantic import BaseModel, computed_field class Rectangle(BaseModel): width: int length: int @computed_field @property def area(self) -> int: return self.width * self.length @app.get("/") def read_root() -> Rectangle:
Python - Registered: Sun Apr 28 07:19:10 GMT 2024 - Last Modified: Fri Aug 04 20:47:07 GMT 2023 - 2.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
* either this Future was cancelled (which we ruled out with the isCancelled check above), * or it had already failed. (It couldn't have completed *successfully* or even had * setFuture called on it: Neither of those can happen until we've finished processing all * the completed inputs. And we're still processing at least one input, the one that * triggered handleException.) *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 15.4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskQueue.kt
return insertAt == 0 } /** * Schedules immediate execution of [Task.tryCancel] on all currently-enqueued tasks. These calls * will not be made until any currently-executing task has completed. Tasks that return true will * be removed from the execution schedule. */ fun cancelAll() { lock.assertNotHeld() taskRunner.lock.withLock { if (cancelAllAndDecide()) {
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 7.5K bytes - Viewed (0)