Search Options

Results per page
Sort
Preferred Languages
Advance

Results 51 - 60 of 303 for reached (0.14 sec)

  1. src/main/java/jcifs/smb/SmbFileInputStream.java

                            } catch (final SmbException e) {
                                if (e.getNtStatus() == 0xC0000011) { // NT_STATUS_END_OF_FILE
                                    log.debug("Reached end of file", e);
                                    n = -1;
                                } else {
                                    throw e;
                                }
                            }
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/base/Converter.java

         * non-legacy behavior; it just needs to let the behavior of the backing converter shine
         * through. So, we override the correctedDo* methods, after which the do* methods should never
         * be reached.
         */
    
        @Override
        protected A doForward(B b) {
          throw new AssertionError();
        }
    
        @Override
        protected B doBackward(A a) {
          throw new AssertionError();
        }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jun 18 21:43:06 UTC 2025
    - 22.8K bytes
    - Viewed (0)
  3. tensorflow/c/c_api_experimental.h

    // from a placeholder node "arg_tensor_enqueue_<tensor_id>".
    //
    // `tensor` is still owned by the caller. This call will be blocked if the queue
    // has reached its capacity, and will be unblocked when the queued tensors again
    // drop below the capacity due to dequeuing.
    //
    // Tensors are dequeued via the corresponding TF dequeue op.
    // TODO(hongm): Add support for `timeout_ms`.
    Registered: Tue Sep 09 12:39:10 UTC 2025
    - Last Modified: Thu Apr 27 21:07:00 UTC 2023
    - 15.1K bytes
    - Viewed (0)
  4. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

            throw e
          }
    
        /**
         * Closes the cache entry and makes the socket available for reuse. This should be invoked when
         * the end of the body has been reached.
         */
        fun responseBodyComplete(trailers: Headers) {
          if (state == STATE_CLOSED) return
          if (state != STATE_READING_RESPONSE_BODY) throw IllegalStateException("state: $state")
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 17.5K bytes
    - Viewed (7)
  5. cmd/metacache-server-pool.go

    		// Marker not common with prefix is not implemented. Send an empty response
    		if !HasPrefix(o.Marker, o.Prefix) {
    			return entries, io.EOF
    		}
    	}
    
    	// With max keys of zero we have reached eof, return right here.
    	if o.Limit == 0 {
    		return entries, io.EOF
    	}
    
    	// For delimiter and prefix as '/' we do not list anything at all
    	// along // with the prefix. On a flat namespace with 'prefix'
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  6. src/main/java/jcifs/internal/smb2/lease/LeaseManager.java

                entry.updateState(newState);
    
                // Flush any cached data if losing write cache
                if (Smb2LeaseState.hasWriteCaching(oldState) && !Smb2LeaseState.hasWriteCaching(newState)) {
                    flushCachedWrites(entry.getPath());
                }
    
                // Invalidate cached data if losing read cache
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  7. guava-gwt/pom.xml

                  <validateOnly>true</validateOnly>
                  <sourceLevel>1.8</sourceLevel>
                  <!--
                    To avoid "java.io.IOException: User limit of inotify watches reached" under JDK10.
                    Presumably we don't need inotify, since we don't intend to change files during the
                    build?
                    -->
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Sep 04 21:35:58 UTC 2025
    - 19.4K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        //
        // Also count the evictable connections to find out if we must close an EVICTABLE connection
        // before its keepAliveDurationNs is reached.
        var earliestOldIdleAtNs = (now - keepAliveDurationNs) + 1
        var earliestOldConnection: RealConnection? = null
        var earliestEvictableIdleAtNs = Long.MAX_VALUE
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue Jun 03 17:10:08 UTC 2025
    - 16.1K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/collect/MinMaxPriorityQueueTest.java

        MinMaxPriorityQueue<Integer> mmHeap = MinMaxPriorityQueue.create();
        mmHeap.addAll(Lists.newArrayList(1, 2));
        Iterator<Integer> it = mmHeap.iterator();
        assertTrue("Iterator has reached end prematurely", it.hasNext());
        it.next();
        it.next();
        assertThrows(NoSuchElementException.class, () -> it.next());
      }
    
      public void testIteratorConcurrentModification() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 36K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/escape/UnicodeEscaper.java

       *   <li>If the first character was a high surrogate value, then an attempt is made to read the
       *       next character.
       *       <ol>
       *         <li><b>If the end of the sequence was reached, the negated value of the trailing high
       *             surrogate is returned.</b>
       *         <li><b>If the next character was a valid low surrogate, the code point value of the
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Feb 13 15:45:16 UTC 2025
    - 13.2K bytes
    - Viewed (0)
Back to top