}


    @Override
    public long getFilePointer () {
        return this.fp;
    }


    @Override
    public void seek ( long pos ) {
        this.fp = pos;
    }


    @Override
    public long length () throws SmbException {
        return this.file.length();
    }


    @Override
    public void setLength ( long newLength ) throws SmbException {

 * subsequent bytes.
 */
internal class TriggerSink(
  private val delegate: Sink,
  private val triggerByteCount: Long,
  private val trigger: () -> Unit,
) : Sink by delegate {
  private var bytesWritten = 0L

  override fun write(
    source: Buffer,
    byteCount: Long,
  ) {
    if (byteCount == 0L) return // Avoid double-triggering.

    if (bytesWritten == triggerByteCount) {

 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
 */

package jcifs.smb1.dcerpc.ndr;

public class NdrHyper extends NdrObject {

    public long value;

    public NdrHyper(long value) {
        this.value = value;
    }

    public void encode(NdrBuffer dst) throws NdrException {
        dst.enc_ndr_hyper(value);
    }

        if (crawlingInfoPager.id != null) {
            cb.query().docMeta().setId_Equal(crawlingInfoPager.id);
        }
        // TODO Long, Integer, String supported only.
        if (StringUtil.isNotBlank(crawlingInfoPager.sessionId)) {
            cb.query().setSessionId_Match(crawlingInfoPager.sessionId);
        }

  override val routePlanner: RoutePlanner,
  private val taskRunner: TaskRunner,
) : ExchangeFinder {
  private val connectDelayNanos = TimeUnit.MILLISECONDS.toNanos(250L)
  private var nextTcpConnectAtNanos = Long.MIN_VALUE

  /**
   * Plans currently being connected, and that will later be added to [connectResults]. This is
   * mutated by the call thread only. If is accessed by background connect threads.
   */

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.exception;

public class SsoLoginException extends FessSystemException {

    private static final long serialVersionUID = 1L;

    public SsoLoginException(final String message) {
        super(message);
    }

    public SsoLoginException(final String message, final Exception e) {
        super(message, e);
    }

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.exception;

public class SsoProcessException extends FessSystemException {

    private static final long serialVersionUID = 1L;

    public SsoProcessException(final String message) {
        super(message);
    }

    public SsoProcessException(final String message, final Exception e) {
        super(message, e);

import org.codelibs.fess.es.config.bsentity.BsElevateWordToLabel;

/**
 * @author ESFlute (using FreeGen)
 */
public class ElevateWordToLabel extends BsElevateWordToLabel {

    private static final long serialVersionUID = 1L;

 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.exception;

public class ContentNotFoundException extends FessSystemException {

    private static final long serialVersionUID = 1L;

    public ContentNotFoundException(final String parentUrl, final String url) {
        super("Not Found: " + url + " Parent: " + parentUrl, false, false);
    }

      }
    };

    abstract int nodeAggregate(AvlNode<?> node);

    abstract long treeAggregate(@CheckForNull AvlNode<?> root);
  }

  private long aggregateForEntries(Aggregate aggr) {
    AvlNode<E> root = rootReference.get();
    long total = aggr.treeAggregate(root);
    if (range.hasLowerBound()) {
      total -= aggregateBelowRange(aggr, root);
    }
    if (range.hasUpperBound()) {