Search Options

Results per page
Sort
Preferred Languages
Advance

Results 901 - 910 of 2,060 for must (0.02 sec)

  1. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

         * ensure that completed write operations performed by other threads are noticed. For most
         * purposes, the "count" field, tracking the number of elements, serves as that volatile
         * variable ensuring visibility. This is convenient because this field needs to be read in many
         * read operations anyway:
         *
         * - All (unsynchronized) read operations must first read the "count" field, and should not
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 90.8K bytes
    - Viewed (0)
  2. guava/src/com/google/common/collect/AbstractSetMultimap.java

    /**
     * Basic implementation of the {@link SetMultimap} interface. It's a wrapper around {@link
     * AbstractMapBasedMultimap} that converts the returned collections into {@code Sets}. The {@link
     * #createCollection} method must return a {@code Set}.
     *
     * @author Jared Levy
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    abstract class AbstractSetMultimap<K extends @Nullable Object, V extends @Nullable Object>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  3. cmd/ftp-server.go

    				logger.Fatal(fmt.Errorf("invalid arguments passed to --ftp=%s (%v)", arg, err), "unable to start FTP server")
    			}
    			if port < 1 || port > 65535 {
    				logger.Fatal(fmt.Errorf("invalid arguments passed to --ftp=%s, (port number must be between 1 to 65535)", arg), "unable to start FTP server")
    			}
    			publicIP = host
    		case "passive-port-range":
    			portRange = tokens[1]
    		case "tls-private-key":
    			tlsPrivateKey = tokens[1]
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Mar 09 03:07:08 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  4. android/guava-tests/benchmark/com/google/common/util/concurrent/FuturesGetCheckedBenchmark.java

        @Override
        public void validateClass(Class<? extends Exception> exceptionClass) {
          checkArgument(
              isCheckedException(exceptionClass),
              "Futures.getChecked exception type (%s) must not be a RuntimeException",
              exceptionClass);
        }
      }
    
      private static GetCheckedTypeValidator nonCachingWithConstructorCheckValidator() {
        return NonCachingWithConstructorCheckValidator.INSTANCE;
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Mar 22 03:01:34 UTC 2022
    - 6.5K bytes
    - Viewed (0)
  5. okhttp/src/main/kotlin/okhttp3/internal/ws/WebSocketWriter.kt

        opcode: Int,
        payload: ByteString,
      ) {
        if (writerClosed) throw IOException("closed")
    
        val length = payload.size
        require(length <= PAYLOAD_BYTE_MAX) {
          "Payload size must be less than or equal to $PAYLOAD_BYTE_MAX"
        }
    
        val b0 = B0_FLAG_FIN or opcode
        sinkBuffer.writeByte(b0)
    
        var b1 = length
        if (isClient) {
          b1 = b1 or B1_FLAG_MASK
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.9K bytes
    - Viewed (0)
  6. okhttp/src/main/kotlin/okhttp3/internal/connection/FastFallbackExchangeFinder.kt

        } finally {
          cancelInFlightConnects()
        }
    
        throw firstException!!
      }
    
      /**
       * Returns non-null if we don't need to wait for the launched result. In such cases, this result
       * must be processed before whatever is waiting in the queue because we may have already acquired
       * its connection.
       */
      private fun launchTcpConnect(): ConnectResult? {
        val plan =
          when {
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 5.8K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/collect/AbstractSetMultimap.java

    /**
     * Basic implementation of the {@link SetMultimap} interface. It's a wrapper around {@link
     * AbstractMapBasedMultimap} that converts the returned collections into {@code Sets}. The {@link
     * #createCollection} method must return a {@code Set}.
     *
     * @author Jared Levy
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    abstract class AbstractSetMultimap<K extends @Nullable Object, V extends @Nullable Object>
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/JdkFutureAdapters.java

       * returned future will emulate {@link ListenableFuture#addListener} by submitting a task to the
       * given executor at the first call to {@code addListener}. The task must be started by the
       * executor promptly, or else the returned {@code ListenableFuture} may fail to work. The task's
       * execution consists of blocking until the input future is {@linkplain Future#isDone() done}, so
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Dec 14 20:35:03 UTC 2023
    - 7.5K bytes
    - Viewed (0)
  9. guava/src/com/google/common/hash/Fingerprint2011.java

     * to unsigned arithmetic in all cases except:
     *
     * <ul>
     *   <li>comparisons (signed values can be negative)
     *   <li>division (avoided here)
     *   <li>shifting (right shift must be unsigned)
     * </ul>
     *
     * @author ******@****.*** (Kyle Maddison)
     * @author ******@****.*** (Geoff Pike)
     */
    @ElementTypesAreNonnullByDefault
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Dec 28 17:50:25 UTC 2021
    - 6.5K bytes
    - Viewed (0)
  10. cmd/streaming-v4-unsigned.go

    	for {
    		v, err := cr.reader.ReadByte()
    		if err != nil {
    			if err == io.EOF {
    				return io.ErrUnexpectedEOF
    			}
    		}
    		if v != '\r' {
    			valueBuffer.WriteByte(v)
    			continue
    		}
    		// Must end with \r\n\r\n
    		var tmp [3]byte
    		_, err = io.ReadFull(cr.reader, tmp[:])
    		if err != nil {
    			if err == io.EOF {
    				return io.ErrUnexpectedEOF
    			}
    		}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat May 06 02:53:12 UTC 2023
    - 6.1K bytes
    - Viewed (0)
Back to top