- Sort Score
- Result 10 results
- Languages All
Results 161 - 170 of 516 for Until (0.41 sec)
-
guava-testlib/src/com/google/common/collect/testing/testers/MapCreationTester.java
} /** * Returns the {@link Method} instance for {@link #testCreateWithNullKeyUnsupported()} so that * tests can suppress it with {@code FeatureSpecificTestSuiteBuilder.suppressing()} until <a * href="https://bugs.openjdk.org/browse/JDK-5045147">JDK-5045147</a> is fixed. */ @J2ktIncompatible @GwtIncompatible // reflection public static Method getCreateWithNullKeyUnsupportedMethod() {Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 5.6K bytes - Viewed (0) -
docs/distributed/decom-compressed-sse-s3.sh
./mc ls -r myminio/versioned/ >expanded_ns.txt ./mc ls -r --versions myminio/versioned/ >expanded_ns_versions.txt ./mc admin decom start myminio/ http://localhost:9000/tmp/xl/{1...10}/disk{0...1} until $(./mc admin decom status myminio/ | grep -q Complete); do echo "waiting for decom to finish..." sleep 1 done kill $pid_1 kill $pid_2 sleep 5Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 4.3K bytes - Viewed (0) -
internal/s3select/progress.go
processedReader *countUpReader closedMu sync.Mutex closer io.ReadCloser closed bool } func (pr *progressReader) Read(p []byte) (n int, err error) { // This ensures that Close will block until Read has completed. // This allows another goroutine to close the reader. pr.closedMu.Lock() defer pr.closedMu.Unlock() if pr.closed { return 0, errors.New("progressReader: read after Close") }
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 22 00:33:43 UTC 2024 - 4.3K bytes - Viewed (0) -
docs/distributed/decom-encrypted-sse-s3.sh
./mc ls -r myminio/versioned/ >expanded_ns.txt ./mc ls -r --versions myminio/versioned/ >expanded_ns_versions.txt ./mc admin decom start myminio/ http://localhost:9000/tmp/xl/{1...10}/disk{0...1} until $(./mc admin decom status myminio/ | grep -q Complete); do echo "waiting for decom to finish..." sleep 1 done kill $pid_1 kill $pid_2 sleep 5Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 4.5K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/HttpHeaders.kt
* * ``` * WWW-Authenticate: Digest ,foo=bar * WWW-Authenticate: Digest ,foo * ``` */ fun Headers.parseChallenges(headerName: String): List<Challenge> { val result = mutableListOf<Challenge>() for (h in 0 until size) { if (headerName.equals(name(h), ignoreCase = true)) { val header = Buffer().writeUtf8(value(h)) try { header.readChallengeHeader(result) } catch (e: EOFException) {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Mon May 05 16:01:00 UTC 2025 - 7.2K bytes - Viewed (0) -
cmd/object-lambda-handlers.go
host := globalLocalNodeName secure := globalIsTLS if globalMinioEndpointURL != nil { host = globalMinioEndpointURL.Host secure = globalMinioEndpointURL.Scheme == "https" } duration := time.Until(cred.Expiration) if duration > time.Hour || duration < time.Hour { // Always limit to 1 hour. duration = time.Hour } clnt, err := miniogo.New(host, &miniogo.Options{Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jul 18 21:56:31 UTC 2025 - 6.5K bytes - Viewed (0) -
cmd/metacache.go
// Remove failed listings after 5 minutes. return time.Since(cache.lastUpdate) > 5*time.Minute } return true } // keepAlive will continuously update lastHandout until ctx is canceled. func (m metacache) keepAlive(ctx context.Context, rpc *peerRESTClient) { // we intentionally operate on a copy of m, so we can update without locks. t := time.NewTicker(metacacheMaxClientWait / 10)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Fri Jul 12 16:23:16 UTC 2024 - 6K bytes - Viewed (0) -
helm-releases/minio-3.6.2.tgz
+e ; # The connections to minio are allowed to fail. echo "Connecting to MinIO server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT" ; MC_COMMAND="${MC} alias set myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" ; $MC_COMMAND ; STATUS=$? ; until [ $STATUS = 0 ] do ATTEMPTS=`expr $ATTEMPTS + 1` ; echo \"Failed attempts: $ATTEMPTS\" ; if [ $ATTEMPTS -gt $LIMIT ]; then exit 1 ; fi ; sleep 2 ; # 1 second intervals between attempts $MC_COMMAND ; STATUS=$? ; done ; set -e ; # reset `e` as active...
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Thu Mar 17 18:30:55 UTC 2022 - 17.9K bytes - Viewed (0) -
helm-releases/minio-2.0.1.tgz
# The connections to minio are allowed to fail. echo "Connecting to Minio server: $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT" ; MC_COMMAND="${MC} config host add myminio $SCHEME://$MINIO_ENDPOINT:$MINIO_PORT $ACCESS $SECRET" ; $MC_COMMAND ; STATUS=$? ; until [ $STATUS = 0 ] do ATTEMPTS=`expr $ATTEMPTS + 1` ; echo \"Failed attempts: $ATTEMPTS\" ; if [ $ATTEMPTS -gt $LIMIT ]; then exit 1 ; fi ; sleep 2 ; # 1 second intervals between attempts $MC_COMMAND ; STATUS=$? ; done ; set -e ; # reset `e` as active...
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Aug 31 09:09:09 UTC 2021 - 13.6K bytes - Viewed (0) -
src/main/assemblies/files/fess
# -X prop set non-standard JAVA system property # --prop=val # --prop val set fess property (i.e. -Des.<prop>=<val>) CDPATH="" SCRIPT="$0" # SCRIPT may be an arbitrarily deep series of symlinks. Loop until we have the concrete path. while [ -h "$SCRIPT" ] ; do ls=`ls -ld "$SCRIPT"` # Drop everything prior to -> link=`expr "$ls" : '.*-> \(.*\)$'` if expr "$link" : '/.*' > /dev/null; then SCRIPT="$link" else
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sun Jan 15 06:32:15 UTC 2023 - 5.4K bytes - Viewed (0)