- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 95 for Finish (0.17 sec)
-
maven-compat/src/main/java/org/apache/maven/artifact/resolver/ResolutionListener.java
* */ @Deprecated public interface ResolutionListener { String ROLE = ResolutionListener.class.getName(); int TEST_ARTIFACT = 1; int PROCESS_CHILDREN = 2; int FINISH_PROCESSING_CHILDREN = 3; int INCLUDE_ARTIFACT = 4; int OMIT_FOR_NEARER = 5; int UPDATE_SCOPE = 6; @Deprecated int MANAGE_ARTIFACT = 7; int OMIT_FOR_CYCLE = 8;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Sep 06 11:28:54 GMT 2023 - 3K bytes - Viewed (0) -
android/guava/src/com/google/common/io/LineReader.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed May 17 14:35:11 GMT 2023 - 3.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt
} if (connectResult.isSuccess) { // We have a connected TCP connection. Cancel and defer the racing connects that all lost. cancelInFlightConnects() // Finish connecting. We won't have to if the winner is from the connection pool. if (!connectResult.plan.isReady) { connectResult = connectResult.plan.connectTlsEtc() }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.8K bytes - Viewed (0) -
internal/dsync/drwmutex_test.go
} // Wait for all parallel RLock()s to succeed. for i := 0; i < numReaders; i++ { <-clocked } for i := 0; i < numReaders; i++ { cunlock <- true } // Wait for the goroutines to finish. for i := 0; i < numReaders; i++ { <-cdone } } // Borrowed from rwmutex_test.go func TestParallelReaders(t *testing.T) { defer runtime.GOMAXPROCS(runtime.GOMAXPROCS(-1))
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 9.7K bytes - Viewed (0) -
common-protos/k8s.io/api/apiserverinternal/v1alpha1/generated.proto
// If all API server instances agree on the same encoding storage version, // then this field is set to that version. Otherwise this field is left empty. // API servers should finish updating its storageVersionStatus entry before // serving write operations, so that this field will be in sync with the reality. // +optional optional string commonEncodingVersion = 2;
Plain Text - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Mon Mar 11 18:43:24 GMT 2024 - 4.1K bytes - Viewed (0) -
cni/pkg/util/podutil.go
// If 'PodIPs' exists, it is preferred (and should be guaranteed to contain the address in 'PodIP'), // otherwise fallback to 'PodIP'. // // Note that very early in the pod's lifecycle (before all the node CNI plugin invocations finish) // K8S may not have received the pod IPs yet, and may not report the pod as having any. func GetPodIPsIfPresent(pod *corev1.Pod) []netip.Addr { var podIPs []netip.Addr if len(pod.Status.PodIPs) != 0 {
Go - Registered: Wed May 08 22:53:08 GMT 2024 - Last Modified: Fri May 03 19:29:42 GMT 2024 - 3.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java
import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * Implementation of {@code Futures#withTimeout}. * * <p>Future that delegates to another but will finish early (via a {@link TimeoutException} wrapped * in an {@link ExecutionException}) if the specified duration expires. The delegate future is * interrupted and cancelled if it times out. */ @J2ktIncompatible @GwtIncompatible
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 7.7K bytes - Viewed (0) -
cmd/leak-detect_test.go
func (initialSnapShot LeakDetect) DetectLeak(t TestErrHandler) { if t.Failed() { return } // Loop, waiting for goroutines to shut down. // Wait up to 5 seconds, but finish as quickly as possible. deadline := UTCNow().Add(leakDetectDeadline * time.Second) for { // get sack snapshot of relevant go routines. leaked := initialSnapShot.CompareCurrentSnapshot()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.2K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/resolver/PluginsMetadataGenerator.java
return Collections.emptyList(); } @Override public Artifact transformArtifact(Artifact artifact) { return artifact; } @Override public Collection<? extends Metadata> finish(Collection<? extends Artifact> artifacts) { LinkedHashMap<String, PluginsMetadata> plugins = new LinkedHashMap<>(); for (Artifact artifact : artifacts) {
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 6.2K bytes - Viewed (0) -
docs/distributed/decom-encrypted-sse-s3.sh
./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 (minio server --address ":9001" http://localhost:9001/tmp/xl/{11...30}/disk{0...3} 2>&1 >/tmp/removed.log) & pid=$! sleep 30
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Apr 23 17:15:52 GMT 2024 - 4.5K bytes - Viewed (0)