- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 587 for dong (0.02 sec)
-
buildscripts/verify-healing.sh
test $foundFiles1 -eq $foundFiles2 v2=$? [ $v1 == 0 -a $v2 == 0 ] && return 0 sleep 10 done return 1 } function purge() { rm -rf "$1" } function fail() { for i in $(seq 1 3); do echo "server$i log:" cat "${WORK_DIR}/dist-minio-server$i.log" done pkill -9 minio echo "FAILED" purge "$WORK_DIR" exit 1 } function __init__() {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java
// When a listener is first added, we run a task that will wait for the delegate to finish, // and when it is done will run the listeners. if (hasListeners.compareAndSet(false, true)) { if (delegate.isDone()) { // If the delegate is already done, run the execution list immediately on the current // thread. executionList.execute(); return; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 7.5K bytes - Viewed (0) -
buildscripts/minio-upgrade.sh
} add_alias() { for i in $(seq 1 4); do echo "... attempting to add alias $i" until (mc alias set minio http://127.0.0.1:9000 minioadmin minioadmin); do echo "...waiting... for 5secs" && sleep 5 done done echo "Sleeping for nginx" sleep 20 } __init__() { sudo apt install curl -y export GOPATH=/tmp/gopath export PATH=${PATH}:${GOPATH}/bin go install github.com/minio/mc@latest
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Mon Apr 21 16:24:31 UTC 2025 - 2.8K bytes - Viewed (0) -
.github/workflows/containers.yml
name: containers on: push: branches: - master pull_request: types: [opened, labeled, unlabeled, synchronize] permissions: contents: read env: GRADLE_OPTS: "-Dorg.gradle.jvmargs=-Xmx4g -Dorg.gradle.daemon=false -Dkotlin.incremental=false" jobs: test_containers: permissions: checks: write # for actions/upload-artifact runs-on: ubuntu-latest
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Aug 21 07:15:58 UTC 2025 - 872 bytes - Viewed (0) -
cmd/storage-rest-server.go
rc io.ReadCloser done chan struct{} } func (c *closeNotifier) Read(p []byte) (n int, err error) { n, err = c.rc.Read(p) if err != nil { if c.done != nil { xioutil.SafeClose(c.done) c.done = nil } } return n, err } func (c *closeNotifier) Close() error { if c.done != nil { xioutil.SafeClose(c.done) c.done = nil } return c.rc.Close() }
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue May 27 15:19:03 UTC 2025 - 45.7K bytes - Viewed (0) -
guava/src/com/google/common/base/AbstractIterator.java
protected AbstractIterator() {} private enum State { READY, NOT_READY, DONE, FAILED, } private @Nullable T next; protected abstract @Nullable T computeNext(); @CanIgnoreReturnValue protected final @Nullable T endOfData() { state = State.DONE; return null; } @Override public final boolean hasNext() { checkState(state != State.FAILED);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.4K 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(
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Wed Jun 18 12:28:21 UTC 2025 - 3.2K bytes - Viewed (0) -
cmd/erasure.go
} // Start one scanner per disk var wg sync.WaitGroup wg.Add(len(disks)) for i := range disks { go func(i int) { defer wg.Done() disk := disks[i] for bucket := range bucketCh { select { case <-ctx.Done(): return default: } // Load cache for bucket cacheName := pathJoin(bucket.Name, dataUsageCacheName) cache := dataUsageCache{}
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 16.1K bytes - Viewed (0) -
src/test/java/org/codelibs/fess/it/admin/PluginTests.java
done = true; break; } assertTrue("plugin(" + target + ") is installed.", done); } // Delete { checkDeleteMethod(targetMap).then().body("response.status", equalTo(0)); boolean done = false; for (int i = 0; i < 60; i++) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Aug 07 03:06:29 UTC 2025 - 6.5K bytes - Viewed (0) -
android/guava/src/com/google/common/base/AbstractIterator.java
protected AbstractIterator() {} private enum State { READY, NOT_READY, DONE, FAILED, } private @Nullable T next; protected abstract @Nullable T computeNext(); @CanIgnoreReturnValue protected final @Nullable T endOfData() { state = State.DONE; return null; } @Override public final boolean hasNext() { checkState(state != State.FAILED);
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 2.4K bytes - Viewed (0)