- Sort Score
- Result 10 results
- Languages All
Results 141 - 150 of 4,046 for until (0.12 sec)
-
okhttp/src/jvmTest/kotlin/okhttp3/ConnectionCoalescingTest.kt
import java.io.IOException import java.net.InetAddress import java.net.InetSocketAddress import java.net.Proxy import java.security.cert.X509Certificate import java.util.Arrays import java.util.concurrent.CountDownLatch import java.util.concurrent.atomic.AtomicInteger import java.util.concurrent.atomic.AtomicReference import javax.net.ssl.HostnameVerifier import javax.net.ssl.SSLPeerUnverifiedException import javax.net.ssl.SSLSession
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Jun 19 11:44:16 UTC 2025 - 19.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/AbstractListenableFutureTest.java
import com.google.common.util.concurrent.ListenableFuture; import java.util.concurrent.CancellationException; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import junit.framework.TestCase;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Fri Jul 11 18:52:30 UTC 2025 - 6.1K bytes - Viewed (0) -
guava-testlib/src/com/google/common/collect/testing/testers/MapPutAllTester.java
import com.google.common.collect.testing.features.MapFeature; import java.lang.reflect.Method; import java.util.ConcurrentModificationException; import java.util.Iterator; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.Map.Entry; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; import org.junit.Ignore; /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 6.8K bytes - Viewed (0) -
src/archive/tar/reader.go
// data that describes the next file. These meta data "files" should not // normally be visible to the outside. As such, this loop iterates through // one or more "header files" until it finds a "normal file". format := FormatUSTAR | FormatPAX | FormatGNU for { // Discard the remainder of the file and any padding. if err := discard(tr.r, tr.curr.physicalRemaining()); err != nil { return nil, err
Registered: Tue Sep 09 11:13:09 UTC 2025 - Last Modified: Fri Mar 08 01:59:14 UTC 2024 - 26.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AggregateFutureState.java
* the License. */ package com.google.common.util.concurrent; import static com.google.common.collect.Sets.newConcurrentHashSet; import static java.util.Objects.requireNonNull; import static java.util.concurrent.atomic.AtomicIntegerFieldUpdater.newUpdater; import static java.util.concurrent.atomic.AtomicReferenceFieldUpdater.newUpdater; import com.google.common.annotations.GwtCompatible;
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 8.5K bytes - Viewed (0) -
helm-releases/minio-3.0.0.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 Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Sep 02 01:47:43 UTC 2021 - 13.8K 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 Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 18 21:56:31 UTC 2025 - 6.5K 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 5
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon May 27 19:17:46 UTC 2024 - 4.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/collect/testing/testers/MapPutAllTester.java
import com.google.common.collect.testing.features.MapFeature; import java.lang.reflect.Method; import java.util.ConcurrentModificationException; import java.util.Iterator; import java.util.LinkedHashMap; import java.util.List; import java.util.Map; import java.util.Map.Entry; import org.jspecify.annotations.NullMarked; import org.jspecify.annotations.Nullable; import org.junit.Ignore; /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 6.8K 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: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Sun Jan 15 06:32:15 UTC 2023 - 5.4K bytes - Viewed (0)