}

  public void testCheckPositive_zeroLong() {
    assertThrows(IllegalArgumentException.class, () -> MathPreconditions.checkPositive("long", 0L));
  }

  public void testCheckPositive_maxLong() {
    MathPreconditions.checkPositive("long", Long.MAX_VALUE);
  }

  public void testCheckPositive_minLong() {
    assertThrows(

            }
            if (!doc.containsKey(indexFieldFavoriteCount)) {
                doc.put(indexFieldFavoriteCount, 0L);
            }
            if (!doc.containsKey(indexFieldClickCount)) {
                doc.put(indexFieldClickCount, 0L);
            }
            if (!doc.containsKey(indexFieldBoost)) {
                doc.put(indexFieldBoost, 1.0f);
            }

      }
    }

    if (isClient) {
      random.nextBytes(maskKey!!)
      sinkBuffer.write(maskKey)

      if (dataSize > 0L) {
        messageBuffer.readAndWriteUnsafe(maskCursor!!)
        maskCursor.seek(0L)
        toggleMask(maskCursor, maskKey)
        maskCursor.close()
      }
    }

    sinkBuffer.write(messageBuffer, dataSize)
    sink.emit()
  }

      }
      return bufferedSource;
    }

    private Source source(Source source) {
      return new ForwardingSource(source) {
        long totalBytesRead = 0L;

        @Override public long read(Buffer sink, long byteCount) throws IOException {
          long bytesRead = super.read(sink, byteCount);

    byteCount: Long,
  ) {
    var byteCount = byteCount
    while (byteCount > 0L) {
      val length = minOf(maxFrameSize.toLong(), byteCount)
      byteCount -= length
      frameHeader(
        streamId = streamId,
        length = length.toInt(),
        type = TYPE_CONTINUATION,
        flags = if (byteCount == 0L) FLAG_END_HEADERS else 0,
      )
      sink.write(hpackBuffer, length)
    }
  }

      addCode(i, CODES[i], CODE_BIT_COUNTS[i].toInt())
    }
  }

  @Throws(IOException::class)
  fun encode(
    source: ByteString,
    sink: BufferedSink,
  ) {
    var accumulator = 0L
    var accumulatorBitCount = 0

    for (i in 0 until source.size) {
      val symbol = source[i] and 0xff
      val code = CODES[symbol]
      val codeBitCount = CODE_BIT_COUNTS[symbol].toInt()

import org.opensearch.index.query.TermsQueryBuilder;

public class IndexingHelperTest extends UnitFessTestCase {
    private IndexingHelper indexingHelper;

    private long documentSizeByQuery = 0L;

    @Override
    public void setUp() throws Exception {
        super.setUp();
        ComponentUtil.register(new SystemHelper(), "systemHelper");
        indexingHelper = new IndexingHelper() {
            @Override

  /** Inflates [buffer] in place as described in RFC 7692 section 7.2.2. */
  @Throws(IOException::class)
  fun inflate(buffer: Buffer) {
    require(deflatedBytes.size == 0L)

    if (noContextTakeover) {
      inflater.reset()
    }

    deflatedBytes.writeAll(buffer)
    deflatedBytes.writeInt(OCTETS_TO_ADD_BEFORE_INFLATION)

public class DynamicProperties extends Properties {

    private static final long serialVersionUID = 1L;

    protected long checkInterval = 5000L;

    protected volatile long lastChecked = 0L;

    protected volatile long lastModified = 0L;

    protected volatile File propertiesFile;

    protected volatile Properties properties;

    public DynamicProperties(final String path) {

          .add("Content-Length", "0")
      this.trailers = Headers.Builder()
      this.throttleBytesPerPeriod = Long.MAX_VALUE
      this.throttlePeriodNanos = 0L
      this.socketPolicy = KeepOpen
      this.bodyDelayNanos = 0L
      this.headersDelayNanos = 0L
      this.pushPromises = mutableListOf()
      this.settings = Settings()
    }

    internal constructor(mockResponse: MockResponse) {