- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 129 for Danish (0.23 sec)
-
internal/lsync/lrwmutex_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: Sun Mar 05 04:57:35 GMT 2023 - 7.9K bytes - Viewed (0) -
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/s3select/select.go
outputQueue = outputQueue[:0] return true } var rec sql.Record OuterLoop: for { if s3Select.statement.LimitReached() { if !sendRecord() { break } if err = writer.Finish(s3Select.getProgress()); err != nil { // FIXME: log this error. err = nil } break } if rec, err = s3Select.recordReader.Read(rec); err != nil { if err != io.EOF { break
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Nov 06 22:26:08 GMT 2023 - 21K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
boolean lockAcquired = tryLockUninterruptibly(lock, 500, MILLISECONDS); assertFalse(lockAcquired); assertAtLeastTimePassed(stopwatch, 500); assertNotInterrupted(); // finish locking thread lockThread.interrupt(); } public void testTryLockTimeoutNotExceeded() { Stopwatch stopwatch = Stopwatch.createStarted(); Lock lock = new ReentrantLock();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Feb 09 22:57:07 GMT 2022 - 31.7K 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) -
okhttp/src/test/java/okhttp3/internal/idn/PunycodeTest.kt
) // (I) Russian (Cyrillic) testEncodeDecode( unicode = "почемужеонинеговорятпорусски", punycode = "xn--b1abfaaepdrnnbgefbadotcwatmq2g4l", ) // (J) Spanish testEncodeDecode( unicode = "PorquénopuedensimplementehablarenEspañol", punycode = "xn--PorqunopuedensimplementehablarenEspaol-fmd56a", ) // (K) Vietnamese testEncodeDecode(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 5.3K 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)