- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 570 for done (0.2 sec)
-
internal/http/listener.go
send := func(result acceptResult) bool { select { case listener.acceptCh <- result: // Successfully written to acceptCh return true case <-listener.ctx.Done(): return false } } // Closure to handle TCPListener until done channel is closed. handleListener := func(idx int, listener net.Listener) { for { conn, err := listener.Accept() send(acceptResult{conn, err, idx}) } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 24 04:08:47 GMT 2024 - 5.6K bytes - Viewed (0) -
mockwebserver/src/test/java/mockwebserver3/CustomDispatcherTest.kt
// First response is still waiting. assertThat(firstResponseCode.get()).isEqualTo(0) // Second response is done. assertThat(secondResponseCode.get()).isEqualTo(200) latch.countDown() startsFirst.join() // And now it's done! assertThat(firstResponseCode.get()).isEqualTo(200) // (Still done). assertThat(secondResponseCode.get()).isEqualTo(200) } private fun buildRequestThread(
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 3.3K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestPlatform.java
Thread.interrupted(); } /** * Retrieves the result of a {@code Future} known to be done but uses the {@code get(long, * TimeUnit)} overload in order to test that method. */ static <V> V getDoneFromTimeoutOverload(Future<V> future) throws ExecutionException { checkState(future.isDone(), "Future was expected to be done: %s", future); try { return getUninterruptibly(future, 0, SECONDS);
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Mon Dec 04 17:37:03 GMT 2017 - 2.9K bytes - Viewed (0) -
buildscripts/verify-healing-empty-erasure-set.sh
done "${MINIO[@]}" --address ":$((start_port + 1))" $args >"${WORK_DIR}/dist-minio-server1.log" 2>&1 & pid1=$! disown ${pid1}
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:55:41 GMT 2024 - 3.2K bytes - Viewed (0) -
buildscripts/verify-healing.sh
d=$((d + 1)) args="$args http://127.0.0.1:$((start_port + 1))${WORK_DIR}/1/${d}/ http://127.0.0.1:$((start_port + 2))${WORK_DIR}/2/${d}/ http://127.0.0.1:$((start_port + 3))${WORK_DIR}/3/${d}/ " done "${MINIO[@]}" --address ":$((start_port + 1))" $args >"${WORK_DIR}/dist-minio-server1.log" 2>&1 & pid1=$! disown ${pid1}
Shell Script - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:55:41 GMT 2024 - 4.2K bytes - Viewed (1) -
internal/grid/muxserver.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 9.1K bytes - Viewed (0) -
src/cmd/cgo/internal/test/issue1435.go
// #include <unistd.h> // #include <sys/types.h> // // pthread_t *t = NULL; // pthread_mutex_t mu; // int nts = 0; // int all_done = 0; // // static void *aFn(void *vargp) { // int done = 0; // while (!done) { // usleep(100); // pthread_mutex_lock(&mu); // done = all_done; // pthread_mutex_unlock(&mu); // } // return NULL; // } // // void trial(int argc) { // int i;
Go - Registered: Tue Apr 23 11:13:09 GMT 2024 - Last Modified: Fri Jul 28 21:31:41 GMT 2023 - 7.5K bytes - Viewed (0) -
internal/logger/target/kafka/kafka_scram_client_contrib.go
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Nov 09 04:04:01 GMT 2023 - 3.3K bytes - Viewed (1) -
android/guava/src/com/google/common/hash/MacHashFunction.java
checkNotDone(); checkNotNull(bytes); mac.update(bytes); } private void checkNotDone() { checkState(!done, "Cannot re-use a Hasher after calling hash() on it"); } @Override public HashCode hash() { checkNotDone(); done = true; return HashCode.fromBytesNoCopy(mac.doFinal()); } }
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Feb 15 22:31:55 GMT 2022 - 3.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFutureTask.java
/** * A {@link FutureTask} that also implements the {@link ListenableFuture} interface. Unlike {@code * FutureTask}, {@code ListenableFutureTask} does not provide an overrideable {@link * FutureTask#done() done()} method. For similar functionality, call {@link #addListener}. * * <p>Few users should use this class. It is intended primarily for those who are implementing an
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Tue Apr 04 09:45:04 GMT 2023 - 4.3K bytes - Viewed (0)