Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 594 for ensures (0.21 sec)

  1. guava/src/com/google/common/collect/RegularImmutableMap.java

          new RegularImmutableMap<>((Entry<Object, Object>[]) ImmutableMap.EMPTY_ENTRY_ARRAY, null, 0);
    
      /**
       * Closed addressing tends to perform well even with high load factors. Being conservative here
       * ensures that the table is still likely to be relatively sparse (hence it misses fast) while
       * saving space.
       */
      @VisibleForTesting static final double MAX_LOAD_FACTOR = 1.2;
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue May 28 18:11:09 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/http2/Http2Connection.kt

      //
      // Certain operations (like SYN_STREAM) need to synchronize on both the frameWriter (to do
      // blocking I/O) and this (to create streams). Such operations must synchronize on 'this' last.
      // This ensures that we never wait for a blocking operation while holding 'this'.
    
      /** True if this peer initiated the connection. */
      internal val client: Boolean = builder.client
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 32.6K bytes
    - Viewed (0)
  3. okhttp/src/test/java/okhttp3/KotlinDeprecationErrorTest.kt

    /**
     * Access every declaration that is deprecated with [DeprecationLevel.ERROR]. Although new Kotlin
     * code shouldn't use these, they're necessary for clients migrating from OkHttp 3.x and this test
     * ensures the symbols remain available and with the expected parameter and return types.
     */
    @Suppress(
      "DEPRECATION_ERROR",
      "UNUSED_VALUE",
      "UNUSED_VARIABLE",
      "VARIABLE_WITH_REDUNDANT_INITIALIZER",
    )
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       * calling thread wait for that time.
       *
       * The simplest way to maintain a rate of QPS is to keep the timestamp of the last granted
       * request, and ensure that (1/QPS) seconds have elapsed since then. For example, for a rate of
       * QPS=5 (5 tokens per second), if we ensure that a request isn't granted earlier than 200ms after
       * the last one, then we achieve the intended rate. If a request comes and the last request was
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  5. cmd/erasure-decode.go

    				// Subsequent reads will reuse this buffer.
    				p.buf[bufIdx] = make([]byte, p.shardSize)
    			}
    			// For the last shard, the shardsize might be less than previous shard sizes.
    			// Hence the following statement ensures that the buffer size is reset to the right size.
    			p.buf[bufIdx] = p.buf[bufIdx][:p.shardSize]
    			n, err := rr.ReadAt(p.buf[bufIdx], p.offset)
    			if err != nil {
    				switch {
    				case errors.Is(err, errFileNotFound):
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 29 01:40:52 UTC 2024
    - 9.5K bytes
    - Viewed (0)
  6. guava/src/com/google/common/base/FinalizableReferenceQueue.java

     *   // You might also share this between several objects.
     *
     *   private static final Set<Reference<?>> references = Sets.newConcurrentHashSet();
     *   // This ensures that the FinalizablePhantomReference itself is not garbage-collected.
     *
     *   private final ServerSocket serverSocket;
     *
     *   private MyServer(...) {
     *     ...
     *     this.serverSocket = new ServerSocket(...);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Jul 11 20:51:36 UTC 2024
    - 13.1K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/SmbRandomAccessFile.java

                return this.handle;
            }
            return this.handle.acquire();
        }
    
    
        /**
         * Ensures that the file descriptor is openend
         * 
         * @throws CIFSException
         */
        public void open () throws CIFSException {
            try ( SmbFileHandleImpl fh = ensureOpen() ) {}
        }
    
    
        @Override
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Wed Jan 08 12:01:33 UTC 2020
    - 18.5K bytes
    - Viewed (0)
  8. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/DefaultRepositoryMetadataManager.java

                throw new RepositoryMetadataReadException(
                        "Cannot read metadata from '" + mappingFile + "': " + e.getMessage(), e);
            }
        }
    
        /**
         * Ensures the last updated timestamp of the specified metadata does not refer to the future and fixes the local
         * metadata if necessary to allow proper merging/updating of metadata during deployment.
         */
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 18.9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/CompactHashSet.java

        }
        Set<E> delegate = delegateOrNull();
        return (delegate != null)
            ? delegate.toArray(a)
            : ObjectArrays.toArrayImpl(requireElements(), 0, size, a);
      }
    
      /**
       * Ensures that this {@code CompactHashSet} has the smallest representation in memory, given its
       * current size.
       */
      public void trimToSize() {
        if (needsAllocArrays()) {
          return;
        }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 20:24:49 UTC 2024
    - 24K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

        // newFuture's lifetime is determined by taskFuture, which can't complete before oldFuture
        // unless taskFuture is cancelled, in which case it falls back to oldFuture. This ensures that
        // if the future we return is cancelled, we don't begin execution of the next task until after
        // oldFuture completes.
        Runnable listener =
            () -> {
              if (taskFuture.isDone()) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Feb 01 21:46:34 UTC 2024
    - 22.1K bytes
    - Viewed (0)
Back to top