Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 140 for reached (0.31 sec)

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

      void awaitRunning();
    
      /**
       * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no more
       * than the given time.
       *
       * @param timeout the maximum time to wait
       * @throws TimeoutException if the service has not reached the given state within the deadline
       * @throws IllegalStateException if the service reaches a state from which it is not possible to
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 12.2K bytes
    - Viewed (0)
  2. src/main/java/jcifs/smb1/smb1/SmbRandomAccessFile.java

            fp = 0L;
        }
    
        /**
         * Reads a single byte from the file at the current file pointer position.
         *
         * @return the byte read as an integer (0-255), or -1 if end of file is reached
         * @throws SmbException if an I/O error occurs
         */
        public int read() throws SmbException {
            if (read(tmp, 0, 1) == -1) {
                return -1;
            }
            return tmp[0] & 0xFF;
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 14.1K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/Service.java

      /**
       * Waits for the {@link Service} to reach the {@linkplain State#RUNNING running state} for no more
       * than the given time.
       *
       * @param timeout the maximum time to wait
       * @param unit the time unit of the timeout argument
       * @throws TimeoutException if the service has not reached the given state within the deadline
       * @throws IllegalStateException if the service reaches a state from which it is not possible to
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Dec 21 03:10:51 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  4. guava/src/com/google/common/io/ByteStreams.java

       * @throws EOFException if this stream reaches the end before reading all the bytes.
       * @throws IOException if an I/O error occurs.
       */
      public static void readFully(InputStream in, byte[] b, int off, int len) throws IOException {
        int read = read(in, b, off, len);
        if (read != len) {
          throw new EOFException(
              "reached end of stream after reading " + read + " bytes; " + len + " bytes expected");
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Jul 17 15:26:41 UTC 2025
    - 31.1K bytes
    - Viewed (0)
  5. okhttp-tls/src/main/kotlin/okhttp3/tls/internal/der/DerReader.kt

       *
       * This returns null if:
       *
       *  * The stream is exhausted.
       *  * We've read all of the bytes of an object whose length is known.
       *  * We've reached the [DerHeader.TAG_END_OF_CONTENTS] of an object whose length is unknown.
       */
      fun peekHeader(): DerHeader? {
        var result = peekedHeader
    
        if (result == null) {
          result = readHeader()
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 10.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/ServiceManager.java

      /**
       * Waits for the {@link ServiceManager} to become {@linkplain #isHealthy() healthy}. The manager
       * will become healthy after all the component services have reached the {@linkplain State#RUNNING
       * running} state.
       *
       * @throws IllegalStateException if the service manager reaches a state from which it cannot
       *     become {@linkplain #isHealthy() healthy}.
       */
      public void awaitHealthy() {
        state.awaitHealthy();
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 33.2K bytes
    - Viewed (1)
  7. src/test/java/jcifs/smb/SmbTransportPoolImplTest.java

        void testSessionLimitPreventsReuse() throws Exception {
            // Given: Config with session limit of 1
            when(config.getSessionLimit()).thenReturn(1);
    
            // Create first connection
            SmbTransportImpl first = pool.getSmbTransport(ctx, address, 445, false);
    
            // Mock that session limit is reached
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 19.2K bytes
    - Viewed (0)
  8. cmd/metacache-stream.go

    	_, err := r.peek()
    	if err != nil {
    		r.err = err
    		return r.err == io.EOF
    	}
    	return false
    }
    
    // forwardTo will forward to the first entry that is >= s.
    // Will return io.EOF if end of stream is reached without finding any.
    func (r *metacacheReader) forwardTo(s string) error {
    	r.checkInit()
    	if r.err != nil {
    		return r.err
    	}
    
    	if s == "" {
    		return nil
    	}
    	if r.current.name != "" {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed May 07 15:37:12 UTC 2025
    - 19.5K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/base/Strings.java

       *     which case the input string is always returned.
       * @param padChar the character to insert at the beginning of the result until the minimum length
       *     is reached
       * @return the padded string
       */
      public static String padStart(String string, int minLength, char padChar) {
        checkNotNull(string); // eager for GWT.
        if (string.length() >= minLength) {
          return string;
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Aug 27 17:53:41 UTC 2025
    - 12.2K bytes
    - Viewed (0)
  10. cmd/bucket-replication-metrics.go

    	LastFailedCount uint64 `json:"failedCount_last5min"`
    	// Count of unreplicated entries that were dropped after MRF retry limit reached since cluster start.
    	TotalDroppedCount uint64 `json:"droppedCount_since_uptime"`
    	// Bytes of unreplicated entries that were dropped after MRF retry limit reached since cluster start.
    	TotalDroppedBytes uint64 `json:"droppedBytes_since_uptime"`
    }
    
    // SMA struct for calculating simple moving average
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
Back to top