}

  /** The event bus this subscriber belongs to. */
  @Weak private final EventBus bus;

  /** The object with the subscriber method. */
  @VisibleForTesting final Object target;

  /** Subscriber method. */
  private final Method method;

  /** Executor to use for dispatching events to this subscriber. */
  private final Executor executor;

  private Subscriber(EventBus bus, Object target, Method method) {

 *
 * @author jflute
 */
public class FessCookieResourceProvider implements CookieResourceProvider {

    protected final FessConfig harborConfig;
    protected final InvertibleCryptographer cookieCipher;

    public FessCookieResourceProvider(final FessConfig harborConfig, final InvertibleCryptographer cookieCipher) {
        this.harborConfig = harborConfig;
        this.cookieCipher = cookieCipher;
    }

 *
 * @author higa
 */
public class IllegalAccessRuntimeException extends ClRuntimeException {

    private static final long serialVersionUID = -3649900343028907465L;

    /**
     * The target class.
     */
    private final Class<?> targetClass;

    /**
     * Creates a {@link IllegalAccessRuntimeException}.
     *
     * @param targetClass
     *            Target class

     */
    public WebConfigPager() {
        // Default constructor
    }

    private static final long serialVersionUID = 1L;

    /**
     * Default page size for pagination.
     */
    public static final int DEFAULT_PAGE_SIZE = 20;

    /**
     * Default current page number.
     */
    public static final int DEFAULT_CURRENT_PAGE_NUMBER = 1;

    /**
     * Total number of records.
     */

 */
public final class CrawlingParameterUtil {
    private static final ThreadLocal<UrlQueue<?>> URL_QUEUE_THREAD_LOCAL = new ThreadLocal<>();

    private static final ThreadLocal<CrawlerContext> ROBOT_CONTEXT_THREAD_LOCAL = new ThreadLocal<>();

    private static final ThreadLocal<UrlQueueService<UrlQueue<?>>> URL_QUEUE_SERVICE_THREAD_LOCAL = new ThreadLocal<>();

  private static final int ARRAY_SIZE = 0x10000;
  private static final int ARRAY_MASK = 0x0ffff;
  private static final Random randomSource = new Random(314159265358979L);
  private static final long[] longs = new long[ARRAY_SIZE];
  private static final long[] divisors = new long[ARRAY_SIZE];
  private static final String[] decimalStrings = new String[ARRAY_SIZE];
  private static final String[] binaryStrings = new String[ARRAY_SIZE];

 */
public class DuplicateHostPager implements Serializable {

    private static final long serialVersionUID = 1L;

    /** Default page size for pagination. */
    public static final int DEFAULT_PAGE_SIZE = 20;

    /** Default current page number (first page). */
    public static final int DEFAULT_CURRENT_PAGE_NUMBER = 1;

    /** Total number of records across all pages. */

 */

package jcifs.smb1.smb1;

abstract class SmbComNtTransaction extends SmbComTransaction {

    // relative to headerStart
    private static final int NTT_PRIMARY_SETUP_OFFSET = 69;
    private static final int NTT_SECONDARY_PARAMETER_OFFSET = 51;

    static final int NT_TRANSACT_QUERY_SECURITY_DESC = 6;

    int function;

    SmbComNtTransaction() {
        primarySetupOffset = NTT_PRIMARY_SETUP_OFFSET;

        return this.indexNumber;
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.Decodable#decode(byte[], int, int)
     */
    @Override
    public int decode(final byte[] buffer, final int bufferIndex, final int len) throws SMBProtocolDecodingException {
        this.indexNumber = SMBUtil.readInt8(buffer, bufferIndex);
        return 8;
    }

    /**
     * {@inheritDoc}
     *

     * </p>
     *
     * @param closeable the closeable object
     * @see Closeable#close()
     */
    public static void close(final Closeable closeable) {
        if (closeable == null) {
            return;
        }
        try {
            closeable.close();
        } catch (final IOException e) {
            logger.log(format("ECL0017", e.getMessage()), e);
        }
    }

    /**