sum += segments[i].count;
    }
    return Ints.saturatedCast(sum);
  }

  @Override
  public @Nullable V get(@Nullable Object key) {
    if (key == null) {
      return null;
    }
    int hash = hash(key);
    return segmentFor(hash).get(key, hash);
  }

  /**
   * Returns the internal entry for the specified key. The entry may be computing or partially

    }

    /**
     * Returns the process ID associated with this lock range.
     *
     * @return the process ID
     */
    public int getPid() {
        return this.pid;
    }

    /**
     * Returns the starting byte offset of the lock range.
     *
     * @return the starting byte offset
     */
    public long getByteOffset() {
        return this.byteOffset;
    }

    /**

            iterators[i] = iterables[i].iterator();
        }
        return iterable(iterators);
    }

    /**
     * Returns an {@link Iterable} that wraps a {@link MultiIterator} for use in a for-each statement.
     *
     * @param <E> the element type
     * @param iterators the array of {@link Iterator} (must not be {@literal null})
     * @return an {@link Iterable} wrapping a {@link MultiIterator}
     */

    return newTypeVariableImpl(
        declaration, name, (bounds.length == 0) ? new Type[] {Object.class} : bounds);
  }

  /** Returns a new {@link WildcardType} with {@code upperBound}. */
  @VisibleForTesting
  static WildcardType subtypeOf(Type upperBound) {
    return new WildcardTypeImpl(new Type[0], new Type[] {upperBound});
  }

    /**
     * Test readParameterWordsWireFormat always returns 0
     */
    @Test
    public void testReadParameterWordsWireFormat() {
        SmbComWrite write = new SmbComWrite();
        byte[] buffer = new byte[10];
        int result = write.readParameterWordsWireFormat(buffer, 0);
        assertEquals(0, result, "readParameterWordsWireFormat should always return 0");
    }

    /**

            standardInfo.deletePending = false;
            standardInfo.directory = false;

            assertEquals(2048L, standardInfo.getSize()); // Size returns endOfFile
            assertEquals(0, standardInfo.getAttributes()); // Standard info always returns 0 for attributes
            assertFalse(standardInfo.deletePending);
            assertFalse(standardInfo.directory);
        }

        @Test

  )
  fun socketAddress(): InetSocketAddress = socketAddress

  /**
   * Returns true if this route tunnels HTTPS or HTTP/2 through an HTTP proxy.
   * See [RFC 2817, Section 5.2][rfc_2817].
   *
   * [rfc_2817]: http://www.ietf.org/rfc/rfc2817.txt
   */
  fun requiresTunnel(): Boolean {
    if (proxy.type() != Proxy.Type.HTTP) return false
    return (address.sslSocketFactory != null) ||

          block()
          return -1L
        }
      },
      delayNanos,
    )
  }

  /** Returns a latch that reaches 0 when the queue is next idle. */
  fun idleLatch(): CountDownLatch {
    taskRunner.withLock {
      // If the queue is already idle, that's easy.
      if (activeTask == null && futureTasks.isEmpty()) {
        return CountDownLatch(0)
      }

        }
    }

    /**
     * Returns the Kerberos ticket.
     *
     * @return the KerberosTicket object
     */
    public KerberosTicket getTicket() {
        return this.apRequest.getTicket();
    }

    /**
     * Returns the Kerberos AP request.
     *
     * @return the KerberosApRequest object
     */
    public KerberosApRequest getApRequest() {

### Per-bucket Metrics