- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 935 for done (0.14 sec)
-
internal/dsync/drwmutex.go
done = true } } case <-ctx.Done(): // Capture timedout locks as failed or took too long locksFailed++ if locksFailed > tolerance { // We know that we are not going to get the lock anymore, // so exit out and release any locks that did get acquired done = true } } if done { break } }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Feb 22 06:26:06 GMT 2024 - 19.7K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CombinedFuture.java
/* * If the output future is done, then it won't need to interrupt the task later, so it can clear * its reference to it. * * If the output future is *not* done, then the task field will be cleared after the task runs * or after the output future is done, whichever comes first. */ if (reason == OUTPUT_FUTURE_DONE) { this.task = null; } } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Thu Feb 01 21:46:34 GMT 2024 - 6.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
* that returns a {@code ClosingFuture} to its value. The function can use a {@link * DeferredCloser} to capture objects to be closed when the pipeline is done (other than those * captured by the returned {@link ClosingFuture}). * * <p>If this {@code ClosingFuture} succeeds, the derived one will be equivalent to the one * returned by the function. *
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Apr 01 16:15:01 GMT 2024 - 98.5K bytes - Viewed (0) -
internal/dsync/dsync_test.go
t.Fatal("Unlock timed out, which should not happen") case <-timer.C: } } // Borrowed from mutex_test.go func HammerMutex(m *DRWMutex, loops int, cdone chan bool) { for i := 0; i < loops; i++ { m.Lock(id, source) m.Unlock(context.Background()) } cdone <- true } // Borrowed from mutex_test.go func TestMutex(t *testing.T) { loops := 200 if testing.Short() { loops = 5 }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Sat Dec 24 03:49:07 GMT 2022 - 11K bytes - Viewed (0) -
src/main/java/org/codelibs/curl/io/ContentOutputStream.java
protected static final String SUFFIX = ".tmp"; protected boolean done = false; public ContentOutputStream(final int threshold, final File tmpDir) { super(threshold, PREFIX, SUFFIX, tmpDir); } @Override public File getFile() { done = true; return super.getFile(); } @Override public void close() throws IOException {
Java - Registered: Thu May 09 15:34:10 GMT 2024 - Last Modified: Mon Nov 14 21:05:19 GMT 2022 - 1.9K bytes - Viewed (0) -
cmd/notification.go
wg.Add(1) go func(ctx context.Context, peerChannel <-chan MetricV2, wg *sync.WaitGroup) { defer wg.Done() for { select { case m, ok := <-peerChannel: if !ok { return } select { case ch <- m: case <-ctx.Done(): return } case <-ctx.Done(): return } } }(ctx, peerChannels[index], &wg) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 12 18:13:36 GMT 2024 - 44.5K 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) -
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) -
cmd/metacache-walk.go
return err } ctx, done, err := p.TrackDiskHealth(ctx, storageMetricWalkDir, opts.Bucket, opts.BaseDir) if err != nil { return err } defer done(&err) return p.storage.WalkDir(ctx, opts, wr) } // WalkDir will traverse a directory and return all entries found. // On success a meta cache stream will be returned, that should be closed when done.
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.4K 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)