Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 587 for dong (0.02 sec)

  1. 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)
  2. 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)
  3. 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)
  4. .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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top