Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 361 - 370 of 610 for necessarily (0.08 seconds)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/MultipartReader.kt

        @Throws(IOException::class)
        fun nextPart(): Part? {
          check(!closed) { "closed" }
    
          if (noMoreParts) return null
    
          // Read a boundary, skipping the remainder of the preceding part as necessary.
          if (partCount == 0 && source.rangeEquals(0L, dashDashBoundary)) {
            // This is the first part. Consume "--" followed by the boundary.
            source.skip(dashDashBoundary.size.toLong())
          } else {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 7.3K bytes
    - Click Count (0)
  2. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RouteSelector.kt

      }
    
      /** Prepares the socket addresses to attempt for the current proxy or host. */
      @Throws(IOException::class)
      private fun resetNextInetSocketAddress(proxy: Proxy) {
        // Clear the addresses. Necessary if getAllByName() below throws!
        val mutableInetSocketAddresses = mutableListOf<InetSocketAddress>()
        inetSocketAddresses = mutableInetSocketAddresses
    
        val socketHost: String
        val socketPort: Int
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed Oct 08 03:50:05 GMT 2025
    - 7.3K bytes
    - Click Count (2)
  3. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

        }
      }
    
      /**
       * Records the given exception using {@link #threadRecordFailure}, then rethrows the exception,
       * wrapping it in an AssertionFailedError if necessary.
       */
      final void threadUnexpectedException(Throwable t) {
        threadRecordFailure(t);
        t.printStackTrace();
        if (t instanceof RuntimeException) {
          throw (RuntimeException) t;
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sat Mar 07 02:20:33 GMT 2026
    - 8.8K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/collect/ContiguousSet.java

           */
          C afterLower = requireNonNull(range.lowerBound.leastValueAbove(domain));
          C beforeUpper = requireNonNull(range.upperBound.greatestValueBelow(domain));
          // Per class spec, we are allowed to throw CCE if necessary
          empty = Range.compareOrThrow(afterLower, beforeUpper) > 0;
        }
    
        return empty
            ? new EmptyContiguousSet<C>(domain)
            : new RegularContiguousSet<C>(effectiveRange, domain);
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 9.9K bytes
    - Click Count (0)
  5. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     * can't get by with the standard implementations, prefer to derive a new {@code Future} instance
     * with the methods in {@link Futures} or, if necessary, to extend {@link AbstractFuture}.
     *
     * <p>Occasionally, an API will return a plain {@code Future} and it will be impossible to change
     * the return type. For this case, we provide a more expensive workaround in {@code
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8K bytes
    - Click Count (0)
  6. android/guava/src/com/google/common/io/Files.java

        }
      }
    
      /**
       * Creates any necessary but nonexistent parent directories of the specified file. Note that if
       * this operation fails it may have succeeded in creating some (but not all) of the necessary
       * parent directories.
       *
       * @throws IOException if an I/O error occurs, or if any necessary but nonexistent parent
       *     directories of the specified file could not be created.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Jan 05 22:13:21 GMT 2026
    - 32.8K bytes
    - Click Count (0)
  7. src/main/java/jcifs/internal/smb2/Smb2TransformHeader.java

    package jcifs.internal.smb2;
    
    import jcifs.Encodable;
    import jcifs.internal.util.SMBUtil;
    
    /**
     * SMB2 Transform Header for encrypted messages
     *
     * This header is used to encrypt SMB2/SMB3 messages and provides the necessary
     * cryptographic parameters for decryption including the nonce, session ID, and
     * authentication tag.
     *
     * @author mbechler
     */
    public class Smb2TransformHeader implements Encodable {
    
        /**
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  8. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

        assertThat(pool.closeConnections(150L)).isEqualTo(0)
        assertThat(pool.connectionCount()).isEqualTo(0)
        assertThat(c1.socket().isClosed).isTrue()
    
        // Running again, the pool reports that no further runs are necessary.
        assertThat(pool.closeConnections(150L)).isEqualTo(-1)
        assertThat(pool.connectionCount()).isEqualTo(0)
        assertThat(c1.socket().isClosed).isTrue()
      }
    
      @Test fun inUseConnectionsNotEvicted() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Oct 07 21:55:03 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  9. guava-gwt/src-super/com/google/common/collect/super/com/google/common/collect/ImmutableSet.java

          default:
            return new RegularImmutableSet<E>(delegate);
        }
      }
    
      private static <E> ImmutableSet<E> create(E... elements) {
        // Create the set first, to remove duplicates if necessary.
        Set<E> set = Sets.newLinkedHashSet();
        Collections.addAll(set, elements);
        for (E element : set) {
          checkNotNull(element);
        }
    
        switch (set.size()) {
          case 0:
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Sep 22 21:07:18 GMT 2025
    - 8.2K bytes
    - Click Count (0)
  10. internal/config/identity/ldap/config.go

    	l.LDAP.GroupSearchFilter = getCfgVal(GroupSearchFilter)
    	l.LDAP.GroupSearchBaseDistName = getCfgVal(GroupSearchBaseDN)
    
    	// If enable flag was not explicitly set, we treat it as implicitly set at
    	// this point as necessary configuration is available.
    	if !isEnableFlagExplicitlySet && !l.LDAP.Enabled {
    		l.LDAP.Enabled = true
    	}
    	// Validate and test configuration.
    	valResult := l.LDAP.Validate()
    	if !valResult.IsOk() {
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Thu Sep 18 11:47:48 GMT 2025
    - 8.6K bytes
    - Click Count (0)
Back to Top