- Sort Score
- Result 10 results
- Languages All
Results 2051 - 2060 of 2,167 for latch (0.04 sec)
-
src/archive/zip/reader_test.go
ModTime time.Time Modified time.Time // Information describing expected zip file content. // First, reading the entire content should produce the error ContentErr. // Second, if ContentErr==nil, the content should match Content. // If content is large, an alternative to setting Content is to set File, // which names a file in the testdata/ directory containing the // uncompressed expected content.
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Thu Jul 25 00:25:45 UTC 2024 - 55.6K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/Striped.java
* bulkGet(keys)} with a relative large number of keys can cause an excessive number of shared * stripes (much like the birthday paradox, where much fewer than anticipated birthdays are needed * for a pair of them to match). Please consider carefully the implications of the number of * stripes, the intended concurrency level, and the typical number of keys used in a {@code
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Jun 26 12:58:35 UTC 2024 - 20.6K bytes - Viewed (0) -
cmd/site-replication.go
func isIAMPolicyReplicated(cntReplicated, total int, policies []*policy.Policy) bool { if cntReplicated > 0 && cntReplicated != total { return false } // check if policies match between sites var prev *policy.Policy for i, p := range policies { if i == 0 { prev = p continue } if !prev.Equals(*p) { return false } } return true }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 185.1K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Range.java
} else { Cut<C> newLower = (lowerCmp >= 0) ? lowerBound : connectedRange.lowerBound; Cut<C> newUpper = (upperCmp <= 0) ? upperBound : connectedRange.upperBound; // create() would catch this, but give a confusing error message checkArgument( newLower.compareTo(newUpper) <= 0, "intersection is undefined for disconnected ranges %s and %s", this,
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Oct 16 17:21:56 UTC 2024 - 27.8K bytes - Viewed (0) -
compat/maven-embedder/src/main/java/org/apache/maven/cli/props/MavenProperties.java
out.append((char) value); unicode.setLength(0); inUnicode = false; hadSlash = false; } catch (NumberFormatException nfe) { throw new IllegalArgumentException("Unable to parse unicode value: " + unicode, nfe); } } continue; }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 38.2K bytes - Viewed (0) -
cmd/metrics-v2.go
} metrics = append(metrics, MetricV2{ Description: MetricDescription{ Namespace: bucketMetricNamespace, Subsystem: "batch", Name: MetricName(jtype + "_objects"), Help: "Get successfully completed batch job " + jtype + "objects", Type: counterMetric, }, Value: objects,
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 131.9K bytes - Viewed (0) -
cmd/erasure-metadata.go
// We have removed this check to allow reading objects with different DataDir // values in a few drives (due to a rebalance-stop race bug) // provided their their etags or ModTimes match. if !meta.Deleted && meta.Size != 0 { fmt.Fprintf(h, "%v+%v", meta.Erasure.DataBlocks, meta.Erasure.ParityBlocks) fmt.Fprintf(h, "%v", meta.Erasure.Distribution) } if meta.IsRemote() {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 31 22:10:24 UTC 2024 - 21.3K bytes - Viewed (0) -
cmd/streaming-signature-v4.go
signingKey := getSigningKey(cred.SecretKey, signV4Values.Credential.scope.date, region, serviceS3) // Calculate signature. newSignature := getSignature(signingKey, stringToSign) // Verify if signature match. if !compareSignatureV4(newSignature, signV4Values.Signature) { return cred, "", "", time.Time{}, ErrSignatureDoesNotMatch } // Return calculated signature. return cred, newSignature, region, date, ErrNone
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 16 23:13:47 UTC 2024 - 18.2K bytes - Viewed (0) -
src/main/java/org/codelibs/core/beans/util/CopyOptions.java
} try { if (value.getClass() == String.class) { return converter.getAsObject((String) value); } return converter.getAsString(value); } catch (final Throwable cause) { throw new ConverterRuntimeException(destPropertyName, value, cause); } } /** * クラスに対応するコンバータを探します。 * * @param clazz
Registered: Fri Nov 01 20:58:10 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 18.6K bytes - Viewed (0) -
common-protos/k8s.io/api/policy/v1beta1/generated.proto
// AllowedHostPath defines the host volume conditions that will be enabled by a policy // for pods to use. It requires the path prefix to be defined. message AllowedHostPath { // pathPrefix is the path prefix that the host volume must match. // It does not support `*`. // Trailing slashes are trimmed when validating the path prefix with a host path. // // Examples: // `/foo` would allow `/foo`, `/foo/` and `/foo/bar`
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 19.6K bytes - Viewed (0)