Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 131 - 140 of 360 for Sleeps (0.04 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava-testlib/src/com/google/common/collect/testing/testers/ListAddAtIndexTester.java

      }
    
      @ListFeature.Require(absent = SUPPORTS_ADD_WITH_INDEX)
      @CollectionSize.Require(absent = ZERO)
      /*
       * absent = ZERO isn't required, since unmodList.add() must
       * throw regardless, but it keeps the method name accurate.
       */
      public void testAddAtIndex_unsupportedPresent() {
        assertThrows(UnsupportedOperationException.class, () -> getList().add(0, e0()));
        expectUnchanged();
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 5.5K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/ImmutableSortedMap.java

       * IllegalArgumentException} if passed a {@code fromKey} less than an earlier {@code fromKey}.
       * However, this method doesn't throw an exception in that situation, but instead keeps the
       * original {@code fromKey}. Similarly, this method keeps the original {@code toKey}, instead of
       * throwing an exception, if passed a {@code toKey} greater than an earlier {@code toKey}.
       */
      @Override
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Mon Sep 22 21:07:18 GMT 2025
    - 52.9K bytes
    - Click Count (0)
  3. README.md

    // Configure for background execution
    crawler.setBackground(true);
    String sessionId = crawler.execute();
    
    // Check crawling status
    while (crawler.crawlerContext.getStatus() == CrawlerStatus.RUNNING) {
        Thread.sleep(1000);
        System.out.println("Crawling in progress...");
    }
    
    // Wait for completion
    crawler.awaitTermination();
    System.out.println("Crawling completed");
    ```
    
    ### Custom Content Extractor
    
    Created: Sat Dec 20 11:21:39 GMT 2025
    - Last Modified: Sun Aug 31 05:32:52 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  4. android/guava-testlib/src/com/google/common/collect/testing/testers/ListAddTester.java

        expectAdded(e0());
      }
    
      @CollectionFeature.Require(absent = SUPPORTS_ADD)
      @CollectionSize.Require(absent = ZERO)
      /*
       * absent = ZERO isn't required, since unmodList.add() must
       * throw regardless, but it keeps the method name accurate.
       */
      public void testAdd_unsupportedPresent() {
        assertThrows(UnsupportedOperationException.class, () -> getList().add(e0()));
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 3.4K bytes
    - Click Count (0)
  5. docs/iam/policies/pbac-tests.sh

    		chmod +x kes
    fi
    
    if ! openssl version &>/dev/null; then
    	apt install openssl || sudo apt install opensssl
    fi
    
    # Start KES Server
    (./kes server --dev 2>&1 >kes-server.log) &
    kes_pid=$!
    sleep 5s
    API_KEY=$(grep "API Key" <kes-server.log | awk -F" " '{print $3}')
    (openssl s_client -connect 127.0.0.1:7373 2>/dev/null 1>public.crt)
    
    export CI=true
    export MINIO_KMS_KES_ENDPOINT=https://127.0.0.1:7373
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Tue Jun 25 01:15:27 GMT 2024
    - 2.5K bytes
    - Click Count (0)
  6. src/main/java/jcifs/internal/smb2/lease/DirectoryChangeNotifier.java

                        // 4. Notify the lease manager
    
                        // Use adaptive polling interval based on activity
                        long pollInterval = determinePollInterval(handle);
                        Thread.sleep(pollInterval);
    
                        // Check if still active
                        if (!handle.isActive()) {
                            break;
                        }
    
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 13.7K bytes
    - Click Count (0)
  7. tests/prepared_stmt_test.go

    	user := *GetUser("prepared_stmt", Config{})
    
    	txCtx.Create(&user)
    
    	var result1 User
    	if err := txCtx.Find(&result1, user.ID).Error; err != nil {
    		t.Fatalf("no error should happen but got %v", err)
    	}
    
    	time.Sleep(time.Second)
    
    	var result2 User
    	if err := tx.Find(&result2, user.ID).Error; err != nil {
    		t.Fatalf("no error should happen but got %v", err)
    	}
    
    	user2 := *GetUser("prepared_stmt2", Config{})
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Fri Apr 25 08:22:26 GMT 2025
    - 8K bytes
    - Click Count (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

        checkNotNull(methodName);
        checkNotNull(arguments);
        assertEquals(false, invokeMethod("hasQueuedThread", this));
        sendRequest(methodName, arguments);
        Thread.sleep(DUE_DILIGENCE_MILLIS);
        assertEquals(true, invokeMethod("hasQueuedThread", this));
        assertThat(responseQueue.poll()).isNull();
      }
    
      /**
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 21:00:51 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  9. helm-releases/minio-5.4.0.tgz

    in the event of a failed command. {{- if .Values.configPathmc }} MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # connectToMinio # Use a check-sleep-check loop to wait for MinIO service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 LIMIT=29 # Allow 30 attempts set -e # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) SECRET=$(cat /config/rootPassword) set +e # The connections...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Jan 03 05:34:47 GMT 2025
    - 21.7K bytes
    - Click Count (0)
  10. helm-releases/minio-3.6.2.tgz

    in the event of a failed command. {{- if .Values.configPathmc }} MC_CONFIG_DIR="{{ .Values.configPathmc }}" MC="/usr/bin/mc --insecure --config-dir ${MC_CONFIG_DIR}" {{- else }} MC="/usr/bin/mc --insecure" {{- end }} # connectToMinio # Use a check-sleep-check loop to wait for MinIO service to be available connectToMinio() { SCHEME=$1 ATTEMPTS=0 ; LIMIT=29 ; # Allow 30 attempts set -e ; # fail if we can't read the keys. ACCESS=$(cat /config/rootUser) ; SECRET=$(cat /config/rootPassword) ; set +e ;...
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Thu Mar 17 18:30:55 GMT 2022
    - 17.9K bytes
    - Click Count (0)
Back to Top