- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 412 for reeds (0.04 sec)
-
cmd/metrics-v3-cluster-usage.go
"Cluster object size distribution", "range") usageVersionsDistributionMD = NewGaugeMD(usageVersionCountDistribution, "Cluster object version count distribution", "range") ) // loadClusterUsageObjectMetrics - reads cluster usage metrics. // // This is a `MetricsLoaderFn`. func loadClusterUsageObjectMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { dataUsageInfo, err := c.dataUsageInfo.Get() if err != nil {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 6.5K bytes - Viewed (0) -
cmd/tier-sweeper.go
package cmd import ( "context" "github.com/minio/minio/internal/bucket/lifecycle" ) // objSweeper determines if a transitioned object needs to be removed from the remote tier. // A typical usage would be like, // os := newObjSweeper(bucket, object) // // Perform a ObjectLayer.GetObjectInfo to fetch object version information // goiOpts := os.GetOpts()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Wed Apr 17 05:09:58 UTC 2024 - 4.7K bytes - Viewed (0) -
android/guava/src/com/google/common/base/Suppliers.java
public T get() { // Another variant of Double Checked Locking. // // We use two volatile reads. We could reduce this to one by // putting our fields into a holder class, but (at least on x86) // the extra memory consumption and indirection are more // expensive than the extra volatile reads. long nanos = expirationNanos; long now = System.nanoTime(); if (nanos == 0 || now - nanos >= 0) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 16.5K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFuture.java
// call to addListener() will callback to setOneValue(), transitively call our cleanup // listener, and set this.futures to null. // This is not actually a problem, since the foreach only needs this.futures to be non-null // at the beginning of the loop. int i = 0; for (ListenableFuture<? extends InputT> future : futures) { int index = i++; if (future.isDone()) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 16K bytes - Viewed (0) -
docs/en/docs/tutorial/dependencies/dependencies-with-yield.md
{* ../../docs_src/dependencies/tutorial008_an_py39.py hl[6,14,22] *} And all of them can use `yield`. In this case `dependency_c`, to execute its exit code, needs the value from `dependency_b` (here named `dep_b`) to still be available. And, in turn, `dependency_b` needs the value from `dependency_a` (here named `dep_a`) to be available for its exit code. {* ../../docs_src/dependencies/tutorial008_an_py39.py hl[18:19,26:27] *}
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 12.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/InterruptibleTask.java
// Some Android 5.0.x Samsung devices have bugs in JDK reflection APIs that cause // getDeclaredField to throw a NoSuchFieldException when the field is definitely there. // Since this class only needs CAS on one field, we can avoid this bug by extending AtomicReference // instead of using an AtomicReferenceFieldUpdater. This reference stores Thread instances // and DONE/INTERRUPTED - they have a common ancestor of Runnable.
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 10K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* MoreExecutors.listeningDecorator}. * <li>If you manually call {@link java.util.concurrent.FutureTask#set} or a similar method, * create a {@link SettableFuture} instead. (If your needs are more complex, you may prefer * {@link AbstractFuture}.) * </ul> * * <p><b>Test doubles</b>: If you need a {@code ListenableFuture} for your test, try a {@link
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Mon Mar 17 20:26:29 UTC 2025 - 8K bytes - Viewed (0) -
guava/src/com/google/common/collect/Serialization.java
* serialize collections that are defined elsewhere. * * @author Jared Levy */ @GwtIncompatible @J2ktIncompatible final class Serialization { private Serialization() {} /** * Reads a count corresponding to a serialized map, multiset, or multimap. It returns the size of * a map serialized by {@link #writeMap(Map, ObjectOutputStream)}, the number of distinct elements
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 8.5K bytes - Viewed (0) -
src/test/java/jcifs/dcerpc/msrpc/lsarpcIntegrationTest.java
decodedName.decode(decodeBuffer); // Verify the decoded data matches assertEquals(translatedName.sid_type, decodedName.sid_type); // The decode process doesn't preserve the original length, it reads from the buffer assertNotNull(decodedName.name); assertNotNull(decodedName.name.buffer); // Buffer length is based on maximum_length/2 from the encoded data
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 05:31:44 UTC 2025 - 10.8K bytes - Viewed (0) -
docs/en/docs/tutorial/request-files.md
`UploadFile` has the following `async` methods. They all call the corresponding file methods underneath (using the internal `SpooledTemporaryFile`). * `write(data)`: Writes `data` (`str` or `bytes`) to the file. * `read(size)`: Reads `size` (`int`) bytes/characters of the file. * `seek(offset)`: Goes to the byte position `offset` (`int`) in the file. * E.g., `await myfile.seek(0)` would go to the start of the file.
Registered: Sun Sep 07 07:19:17 UTC 2025 - Last Modified: Sun Aug 31 09:15:41 UTC 2025 - 7.3K bytes - Viewed (0)