Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 381 - 390 of 1,805 for ready (0.03 seconds)

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

         * look at table entries if it is 0.
         *
         * - All (synchronized) write operations should write to the "count" field after structurally
         * changing any bin. The operations must not take any action that could even momentarily
         * cause a concurrent read operation to see inconsistent data. This is made easier by the
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 89.9K bytes
    - Click Count (0)
  2. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/BasicDerAdapter.kt

        result = 31 * result + defaultValue.hashCode()
        result = 31 * result + (if (typeHint) 1 else 0)
        return result
      }
    
      override fun toString(): String = "$name [$tagClass/$tag]"
    
      /** Reads and writes values without knowledge of the enclosing tag, length, or defaults. */
      interface Codec<T> {
        fun decode(reader: DerReader): T
    
        fun encode(
          writer: DerWriter,
          value: T,
        )
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Mon Jan 08 01:13:22 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/base/Stopwatch.java

       */
      @CanIgnoreReturnValue
      public Stopwatch start() {
        checkState(!isRunning, "This stopwatch is already running.");
        isRunning = true;
        startTick = ticker.read();
        return this;
      }
    
      /**
       * Stops the stopwatch. Future reads will return the fixed duration that had elapsed up to this
       * point.
       *
       * @return this {@code Stopwatch} instance
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 9.5K bytes
    - Click Count (0)
  4. src/main/java/jcifs/internal/smb1/AndXServerMessageBlock.java

                dstIndex += this.andx.byteCount;
            }
    
            return dstIndex - start;
        }
    
        /**
         * Reads the AndX wire format from buffer
         * @param buffer the buffer to read from
         * @param bufferIndex the starting index
         * @return the number of bytes read
         * @throws SMBProtocolDecodingException if decoding fails
         */
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  5. guava/src/com/google/common/base/Stopwatch.java

       */
      @CanIgnoreReturnValue
      public Stopwatch start() {
        checkState(!isRunning, "This stopwatch is already running.");
        isRunning = true;
        startTick = ticker.read();
        return this;
      }
    
      /**
       * Stops the stopwatch. Future reads will return the fixed duration that had elapsed up to this
       * point.
       *
       * @return this {@code Stopwatch} instance
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Oct 08 18:55:33 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  6. guava/src/com/google/common/cache/LocalCache.java

         * at table entries if it is 0.
         *
         * - All (synchronized) write operations should write to the "count" field after structurally
         * changing any bin. The operations must not take any action that could even momentarily cause a
         * concurrent read operation to see inconsistent data. This is made easier by the nature of the
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 148.9K bytes
    - Click Count (0)
  7. src/test/java/jcifs/internal/smb1/trans/nt/NtTransQuerySecurityDescResponseTest.java

            byte[] buffer = new byte[100];
            int result = response.readSetupWireFormat(buffer, 0, buffer.length);
    
            assertEquals(0, result);
        }
    
        @Test
        @DisplayName("Test readParametersWireFormat reads length correctly")
        void testReadParametersWireFormat() throws Exception {
            byte[] buffer = new byte[100];
            int expectedLength = 0x12345678;
    
            // Write length in little-endian format
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  8. internal/logger/target/kafka/kafka.go

    type Target struct {
    	status int32
    
    	totalMessages  int64
    	failedMessages int64
    
    	wg sync.WaitGroup
    
    	// Channel of log entries.
    	// Reading logCh must hold read lock on logChMu (to avoid read race)
    	// Sending a value on logCh must hold read lock on logChMu (to avoid closing)
    	logCh   chan any
    	logChMu sync.RWMutex
    
    	// store to persist and replay the logs to the target
    	// to avoid missing events when the target is down.
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 10.2K bytes
    - Click Count (0)
  9. src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeResponseTest.java

            assertEquals(TransPeekNamedPipeResponse.STATUS_LISTENING, response.getStatus());
            // Middle bytes were read but not used
        }
    
        @Test
        @DisplayName("Test consecutive reads update state correctly")
        void testConsecutiveReads() {
            // First read
            byte[] buffer1 = new byte[10];
            SMBUtil.writeInt2(100, buffer1, 0);
            SMBUtil.writeInt2(0, buffer1, 2);
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 15.8K bytes
    - Click Count (0)
  10. android/guava/src/com/google/common/base/Suppliers.java

        public T get() {
          // Another variant of Double Checked Locking.
          //
          // We use two volatile reads. We could reduce this to one by
          // putting our fields into a holder class, but (at least on x86)
          // the extra memory consumption and indirection are more
          // expensive than the extra volatile reads.
          long nanos = expirationNanos;
          long now = System.nanoTime();
          if (nanos == 0 || now - nanos >= 0) {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Mar 31 21:24:28 GMT 2026
    - 16.1K bytes
    - Click Count (0)
Back to Top