*/
    public long getProjectWeight(MavenProject project) {
        // First check if weight is already calculated
        Long existingWeight = projectWeights.get(project);
        if (existingWeight != null) {
            return existingWeight;
        }

        // Calculate weight without using computeIfAbsent to avoid recursive update issues
        long weight = calculateWeight(project);

  int[] xInts;
  int[] yInts;

  long[] xLongs;
  long[] yLongs;

  int[] constant;

  private static final long NONNEGATIVE_LONG_MASK = 0x7FFFFFFFFFFFFFFFL;

  @BeforeExperiment
  void setUp() {
    Random random = new Random(randomSeed);
    xInts = new int[SAMPLE_SIZE];
    yInts = new int[SAMPLE_SIZE];
    xLongs = new long[SAMPLE_SIZE];
    yLongs = new long[SAMPLE_SIZE];
    constant = new int[SAMPLE_SIZE];

   * @param start the starting bytes encoded as a long as big-endian
   * @param lim the limit of bytes to process encoded as a long as big-endian, or -1 to mean the max
   *     limit for numBytes
   */
  @GwtIncompatible // java.nio.charset.Charset
  private static void testBytes(int numBytes, long expectedCount, long start, long lim) {
    byte[] bytes = new byte[numBytes];
    if (lim == -1) {

@VmOptions({"-Xms12g", "-Xmx12g", "-d64"})
@NullUnmarked
public class CharStreamsCopyBenchmark {
  enum CopyStrategy {
    OLD {
      @Override
      long copy(Readable from, Appendable to) throws IOException {
        CharBuffer buf = CharStreams.createBuffer();
        long total = 0;
        while (from.read(buf) != -1) {
          ((Buffer) buf).flip();
          to.append(buf);
          total += buf.remaining();

            threads[ti].start();
        }

        while (t.numComplete < t.numThreads) {
            long delay;

            do {
                delay = 2L;

                synchronized (t) {
                    final long expire = t.ltime + t.delay;
                    final long ctime = System.currentTimeMillis();

                    if (expire > ctime) {

        return this;
    }

    public void setCreatedTime_Equal(Long createdTime) {
        setCreatedTime_Term(createdTime, null);
    }

    public void setCreatedTime_Equal(Long createdTime, ConditionOptionCall<TermQueryBuilder> opLambda) {
        setCreatedTime_Term(createdTime, opLambda);
    }

    public void setCreatedTime_Term(Long createdTime) {
        setCreatedTime_Term(createdTime, null);
    }

    }

    // Test class for basic testing
    private static class TestScoreBooster extends ScoreBooster {
        private final long returnValue;

        public TestScoreBooster(long returnValue) {
            this.returnValue = returnValue;
        }

        @Override
        public long process() {
            return returnValue;
        }
    }

    // Test class that throws exception

    public long getBytesTransferred() {
        return bytesTransferred.get();
    }

    /**
     * Get total number of operation errors
     *
     * @return error count
     */
    public long getOperationErrors() {
        return operationErrors.get();
    }

    /**
     * Get total number of connections created
     *
     * @return connection count
     */

     */
    static class TestableTransport extends Transport {
        private long nextKey = 1;
        private Long peekedKey = null;
        private IOException sendException = null;
        private IOException recvException = null;
        private boolean connectFails = false;
        private boolean disconnectResult = false;

        @Override
        protected long makeKey(Request request) throws IOException {
            return nextKey++;

    @Override
    public final long getLastAccessTime() {
        return this.lastAccessTime;
    }

    /**
     * @return the lastWriteTime
     */
    @Override
    public final long getLastWriteTime() {
        return this.lastWriteTime;
    }

    /**
     * Gets the allocation size.
     *
     * @return the allocationSize
     */
    public final long getAllocationSize() {