Search Options

Results per page
Sort
Preferred Languages
Advance

Results 61 - 70 of 1,079 for while (0.04 sec)

  1. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

                  }
                }
              }
              oldHead = waitersField; // re-read and loop.
            } while (oldHead != Waiter.TOMBSTONE);
          }
          // re-read valueField, if we get here then we must have observed a TOMBSTONE while trying to
          // add a waiter.
          // requireNonNull is safe because valueField is always set before TOMBSTONE.
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 34.8K bytes
    - Viewed (0)
  2. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt

        set("a", "a", "a")
        set("b", "b", "b")
        while (taskFaker.isIdle()) {
          assertValue("a", "a", "a")
          assertValue("b", "b", "b")
        }
      }
    
      @ParameterizedTest
      @ArgumentsSource(FileSystemParamProvider::class)
      fun rebuildJournalOnRepeatedEdits(parameters: Pair<FileSystem, Boolean>) {
        setUp(parameters.first, parameters.second)
        while (taskFaker.isIdle()) {
          set("a", "a", "a")
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 75.7K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/base/AndroidIncompatible.java

     *       Guava while continuing to run it internally, as we do with many other tests. This would
     *       suffice because we our Android users and tests are using the open-source version, which
     *       would no longer have the problematic test. But why bother when we can instead strip it with
     *       a more precisely named annotation?
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 07 15:40:13 UTC 2023
    - 3.9K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/LinkedListMultimap.java

        // Replace existing values, if any.
        while (keyValues.hasNext() && newValues.hasNext()) {
          keyValues.next();
          keyValues.set(newValues.next());
        }
    
        // Remove remaining old values, if any.
        while (keyValues.hasNext()) {
          keyValues.next();
          keyValues.remove();
        }
    
        // Add remaining new values, if any.
        while (newValues.hasNext()) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 26.6K bytes
    - Viewed (0)
  5. tensorflow/c/c_api_macros_internal.h

                                    "set to " #SIZE_VALUE_NAME                \
                                    ". Found `struct_size` = 0.");            \
        }                                                                     \
      } while (0)
    
    // Macro to verify that the field NAME of STRUCT_OBJ is not null.
    #define TF_VALIDATE_NOT_NULL(STRUCT_NAME, STRUCT_OBJ, NAME)            \
      do {                                                                 \
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Mon Mar 13 17:40:56 UTC 2023
    - 2.5K bytes
    - Viewed (0)
  6. docs/resiliency/resiliency-initial-script.sh

    MINIO_SERVER_URL="http://127.0.0.1:9000"
    ALIAS_NAME=myminio
    BUCKET="test-bucket"
    SRC_DIR="/tmp/data"
    INLINED_DIR="/tmp/inlined"
    DEST_DIR="/tmp/dest"
    
    TIMEOUT=10
    while true; do
    	if [[ ${TIMEOUT} -le 0 ]]; then
    		echo retry: timeout while running: mc alias set
    		exit 1
    	fi
    	eval ./mc alias set "${ALIAS_NAME}" "${MINIO_SERVER_URL}" minioadmin minioadmin && break
    	TIMEOUT=$((TIMEOUT - 1))
    	sleep 1
    done
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sat Dec 21 04:24:45 UTC 2024
    - 1.5K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http2/Huffman.kt

          val code = CODES[symbol]
          val codeBitCount = CODE_BIT_COUNTS[symbol].toInt()
    
          accumulator = (accumulator shl codeBitCount) or code.toLong()
          accumulatorBitCount += codeBitCount
    
          while (accumulatorBitCount >= 8) {
            accumulatorBitCount -= 8
            sink.writeByte((accumulator shr accumulatorBitCount).toInt())
          }
        }
    
        if (accumulatorBitCount > 0) {
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 11K bytes
    - Viewed (0)
  8. buildscripts/verify-healing-empty-erasure-set.sh

    	while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].state | select(. != "ok")' | wc -l) -gt 0 ]; do sleep 1; done
    	# Wait for all drives to be healed
    	while [ $(/tmp/mc admin info --json myminio | jq '.info.servers[].drives[].healing | select(. != null) | select(. == true)' | wc -l) -gt 0 ]; do sleep 1; done
    
    	# Wait for Status: in MinIO output
    	while true; do
    		rv=$(check_online)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/Queues.java

       * @param numElements the number of elements to be waited for
       * @param timeout how long to wait before giving up
       * @return the number of elements transferred
       * @throws InterruptedException if interrupted while waiting
       * @since 28.0 (but only since 33.4.0 in the Android flavor)
       */
      @CanIgnoreReturnValue
      @J2ktIncompatible
      @GwtIncompatible // BlockingQueue
      public static <E> int drain(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  10. src/main/java/jcifs/SmbFileHandle.java

        /**
         * Closes this file handle and optionally sets the last write time
         *
         * @param lastWriteTime the last write time to set, or 0 to leave unchanged
         * @throws CIFSException if an error occurs while closing the file
         */
        void close(long lastWriteTime) throws CIFSException;
    
        /**
         * {@inheritDoc}
         *
         * @see java.lang.AutoCloseable#close()
         */
        @Override
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 2K bytes
    - Viewed (0)
Back to top