/** True if the caller has closed this stream. */
    internal var closed: Boolean = false

    @Throws(IOException::class)
    override fun read(
      sink: Buffer,
      byteCount: Long,
    ): Long {
      require(byteCount >= 0L) { "byteCount < 0: $byteCount" }

      while (true) {
        var tryAgain = false
        var readBytesDelivered = -1L

  private static final long SMALL_TIMEOUT_MILLIS = 10;

  /** How long to wait when determining that a thread is blocked if we expect it to be blocked. */
  private static final long EXPECTED_HANG_DELAY_MILLIS = 75;

  /**
   * How long to wait when determining that a thread is blocked if we DON'T expect it to be blocked.
   */
  private static final long UNEXPECTED_HANG_DELAY_MILLIS = 10000;

  /**

    private final AbstractFuture<?> future;
    private final long timeout;
    private final TimeUnit unit;
    private Exception exception;
    private volatile long startTime;
    private long timeSpentBlocked;

    TimedWaiterThread(AbstractFuture<?> future, long timeout, TimeUnit unit) {
      this.future = future;
      this.timeout = timeout;
      this.unit = unit;

            false, "keyword", 0, 0, null, null, false, null, null, null, null, null, false);
    protected final ColumnInfo _columnCreatedTime = cci("createdTime", "createdTime", null, null, Long.class, "createdTime", null, false,
            false, false, "Long", 0, 0, null, null, false, null, null, null, null, null, false);
    protected final ColumnInfo _columnDepth = cci("depth", "depth", null, null, Integer.class, "depth", null, false, false, false,

      "preferredLanguage" : {
        "type" : "keyword"
      },
      "departmentNumber" : {
        "type" : "keyword"
      },
      "uidNumber" : {
        "type" : "long"
      },
      "gidNumber" : {
        "type" : "long"
      },
      "homeDirectory" : {
        "type" : "keyword"
      },
      "groups": {
        "type": "keyword"
      },
      "roles": {

 */
package org.codelibs.fess.exception;

import org.codelibs.fess.crawler.exception.CrawlingAccessException;

public class DataStoreCrawlingException extends CrawlingAccessException {

    private static final long serialVersionUID = 1L;

    private final String url;

    private final boolean abort;

    public DataStoreCrawlingException(final String url, final String message, final Exception e) {

    public String id;

    @Required
    @Size(max = 20)
    public String sessionId;

    @Size(max = 20)
    public String name;

    public String expiredTime;

    @ValidateTypeFailure
    public Long createdTime;

    public void initialize() {

        id = null;
        sessionId = null;
        name = null;
        expiredTime = null;
        createdTime = null;

    }

import jcifs.CIFSException;


/**
 * @author mbechler
 *
 */
public class SMBProtocolDecodingException extends CIFSException {

    /**
     * 
     */
    private static final long serialVersionUID = 4862398838709265475L;


    /**
     * 
     */
    public SMBProtocolDecodingException () {
        super();
    }


    /**
     * @param message
     * @param cause

/**
 * Base for all checked exceptions used by this library
 * 
 * @author mbechler
 *
 */
public class CIFSException extends IOException {

    /**
     * 
     */
    private static final long serialVersionUID = 7806460518865806784L;


    /**
     * 
     */
    public CIFSException () {
        super();
    }


    /**
     * 
     * @param message
     * @param cause

/**
 * Base class for all maven exceptions.
 *
 * @since 4.0.0
 */
@Experimental
public class MavenException extends RuntimeException {

    @Serial
    private static final long serialVersionUID = 9027638326336093132L;

    public MavenException() {}

    public MavenException(String message) {
        super(message);
    }

    public MavenException(String message, Throwable cause) {