Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 112 for Sleeps (0.03 sec)

  1. mockwebserver/src/main/kotlin/mockwebserver3/internal/MockWebServerSocket.kt

      }
    
      fun shutdownOutput() {
        javaNetSocket.shutdownOutput()
      }
    
      /** Sleeps [nanos], throwing if the socket is closed before that period has elapsed. */
      fun sleepWhileOpen(nanos: Long) {
        var ms = nanos / 1_000_000L
        val ns = nanos - (ms * 1_000_000L)
    
        while (ms > 100) {
          Thread.sleep(100)
          if (javaNetSocket.isClosed) throw InterruptedIOException("socket closed")
          ms -= 100L
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 3.3K bytes
    - Viewed (0)
  2. mockwebserver/src/main/kotlin/mockwebserver3/internal/ThrottledSink.kt

     * See the License for the specific language governing permissions and
     * limitations under the License.
     *
     */
    package mockwebserver3.internal
    
    import okio.Buffer
    import okio.Sink
    
    /**
     * A sink that sleeps [periodDelayNanos] every [bytesPerPeriod] bytes. Unlike [okio.Throttler],
     * this permits any interval to be used.
     */
    internal class ThrottledSink(
      private val socket: MockWebServerSocket,
      private val delegate: Sink,
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jul 29 12:43:16 UTC 2025
    - 1.5K bytes
    - Viewed (0)
  3. ci/official/utilities/setup_docker.sh

    if [[ "$TFCI_DOCKER_PULL_ENABLE" == 1 ]]; then
      # Simple retry logic for docker-pull errors. Sleeps if a pull fails.
      # Pulling an already-pulled container image will finish instantly, so
      # repeating the command costs nothing.
      docker pull "$TFCI_DOCKER_IMAGE" || sleep 15
      docker pull "$TFCI_DOCKER_IMAGE" || sleep 30
      docker pull "$TFCI_DOCKER_IMAGE" || sleep 60
      docker pull "$TFCI_DOCKER_IMAGE"
    fi 
    
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Thu Jan 09 18:37:25 UTC 2025
    - 2.6K bytes
    - Viewed (0)
  4. docs/site-replication/run-multi-site-oidc.sh

    sleep 5
    
    ./mc admin policy info minio2 projecta >/dev/null 2>&1
    if [ $? -ne 0 ]; then
    	echo "expecting the command to succeed, exiting.."
    	exit_1
    fi
    ./mc admin policy info minio3 projecta >/dev/null 2>&1
    if [ $? -ne 0 ]; then
    	echo "expecting the command to succeed, exiting.."
    	exit_1
    fi
    
    ./mc admin policy remove minio3 projecta
    
    sleep 10
    ./mc admin policy info minio1 projecta
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 24 08:03:58 UTC 2024
    - 8.5K bytes
    - Viewed (0)
  5. buildscripts/verify-build.sh

    	(cd "$WORK_DIR" && "$FUNCTIONAL_TESTS")
    	rv=$?
    
    	pkill minio
    	sleep 3
    
    	if [ "$rv" -ne 0 ]; then
    		cat "$WORK_DIR/fs-minio.log"
    	fi
    	rm -f "$WORK_DIR/fs-minio.log"
    
    	return "$rv"
    }
    
    function run_test_erasure_sets() {
    	start_minio_erasure_sets
    
    	(cd "$WORK_DIR" && "$FUNCTIONAL_TESTS")
    	rv=$?
    
    	pkill minio
    	sleep 3
    
    	if [ "$rv" -ne 0 ]; then
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 24 19:28:51 UTC 2024
    - 6.7K bytes
    - Viewed (0)
  6. docs/bucket/replication/sio-error.sh

    	./minio server --address "127.0.0.1:$((9100 + i))" ${args2[@]} & # | tee /tmp/minio/node.$i &
    done
    
    sleep 10
    
    ./mc alias set myminio1 http://localhost:9001 minioadmin minioadmin
    ./mc alias set myminio2 http://localhost:9101 minioadmin minioadmin
    
    ./mc ready myminio1
    ./mc ready myminio2
    sleep 1
    
    ./mc mb myminio1/testbucket/ --with-lock
    ./mc mb myminio2/testbucket/ --with-lock
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sat May 18 18:19:01 UTC 2024
    - 1.7K bytes
    - Viewed (0)
  7. src/test/java/org/codelibs/fess/suggest/concurrent/DeferredTest.java

        @Test
        public void test_doneBeforeResolve() throws Exception {
            final Deferred<SuggestResponse> deferred = new Deferred<>();
    
            Thread th = new Thread(() -> {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException ignore) {}
                deferred.resolve(new SuggestResponse("", 0, Collections.emptyList(), 0, null));
            });
            th.start();
    
    Registered: Fri Sep 19 09:08:11 UTC 2025
    - Last Modified: Sat Mar 15 06:51:20 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/core/timer/TimeoutManagerTest.java

            }, 1, true);
    
            assertNotNull(TimeoutManager.getInstance().thread);
            Thread.sleep(2000);
            assertTrue(expiredCount > 0);
            assertEquals(1, TimeoutManager.getInstance().getTimeoutTaskCount());
            TimeoutManager.getInstance().stop();
            assertNull(TimeoutManager.getInstance().thread);
            Thread.sleep(10);
            int count = expiredCount;
            task.stop();
    Registered: Fri Sep 05 20:58:11 UTC 2025
    - Last Modified: Sat May 10 01:32:17 UTC 2025
    - 2.1K bytes
    - Viewed (0)
  9. .github/workflows/multipart/migrate.sh

    docker-compose -f docker-compose-site2.yaml up -d
    
    sleep 30s
    
    ./mc alias set site1 http://site1-nginx:9001 minioadmin minioadmin --api s3v4
    ./mc alias set site2 http://site2-nginx:9002 minioadmin minioadmin --api s3v4
    
    ./mc ready site1/
    ./mc ready site2/
    
    ./mc admin replicate add site1 site2
    ./mc mb site1/testbucket/
    ./mc cp -r --quiet /usr/bin site1/testbucket/
    
    sleep 5
    
    ./s3-check-md5 -h
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 27 19:17:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  10. buildscripts/verify-healing-with-root-disks.sh

    	# /tmp/xxx/mnt/disk4 will be the same as '/' and it
    	# will be detected as root disk
    	while [ "$u" != "0" ]; do
    		sudo umount ${WORK_DIR}/mnt/disk4/
    		u=$?
    		sleep 1
    	done
    
    	# Wait until MinIO self heal kicks in
    	sleep 60
    
    	if [ -f ${WORK_DIR}/mnt/disk4/.minio.sys/format.json ]; then
    		echo "A root disk is formatted unexpectedely"
    		cat "${WORK_DIR}/server4.log"
    		exit -1
    	fi
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri May 26 05:07:25 UTC 2023
    - 2.2K bytes
    - Viewed (0)
Back to top