* Handles little-endian byte order and data alignment requirements of PAC structures.
 */
public class PacDataInputStream {

    private final DataInputStream dis;
    private final int size;

    /**
     * Constructs a PAC data input stream from the given input stream.
     * @param in the underlying input stream
     * @throws IOException if an I/O error occurs
     */

/**
 * Job for pinging search engine.
 */
public class PingSearchEngineJob {

    /**
     * Default constructor.
     */
    public PingSearchEngineJob() {
        // Default constructor
    }

    private static final Logger logger = LogManager.getLogger(PingSearchEngineJob.class);

    /**
     * Executes the ping job.
     *
     * @return the execution result
     */
    public String execute() {

import org.dbflute.utflute.mocklet.MockletHttpServletRequest;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.TestInfo;

public class RateLimitHelperTest extends UnitFessTestCase {

    private RateLimitHelper rateLimitHelper;

    @Override
    protected void setUp(TestInfo testInfo) throws Exception {
        super.setUp(testInfo);
        rateLimitHelper = new RateLimitHelper();

        provider.adjustActionResponseHeaders("application/json", (k, v) -> headerMap.put(k, v));
        assertEquals(1, headerMap.size());
        assertEquals("def", headerMap.get("X-Def"));
    }

    private FessConfig createFessConfigWithResponseHeaders(final String text) {
        return new FessConfig.SimpleImpl() {
            @Override
            public String getResponseHeaders() {
                return text;

  public void testToString_formatting() {
    assertEquals(
        "map.toString() incorrect", expectedToString(getMap().entrySet()), getMap().toString());
  }

  private String expectedToString(Set<Entry<K, V>> entries) {
    Map<K, V> reference = new LinkedHashMap<>();
    for (Entry<K, V> entry : entries) {
      reference.put(entry.getKey(), entry.getValue());
    }

    }
    return false;
  }

  @Override
  public String toString() {
    return forwardOrder + ".reverse()";
  }

  @GwtIncompatible @J2ktIncompatible private static final long serialVersionUID = 0;

/**
 * Basher test for {@link AtomicLongMap}.
 *
 * @author mike nonemacher
 */
@J2ktIncompatible // threads
@GwtIncompatible // threads
@NullUnmarked
public class AtomicLongMapBasherTest extends TestCase {
  private final Random random = new Random(301);

  public void testModify_basher() throws Exception {
    int nTasks = 3000;
    int nThreads = 100;
    int getsPerTask = 1000;
    int deltaRange = 10000;

 * </p>
 *
 * @author koichik
 * @param <K> the key type
 * @param <V> the value type
 */
public class LruHashMap<K, V> extends LinkedHashMap<K, V> {

    private static final long serialVersionUID = 1L;

    /**
     * Default initial capacity.
     */
    protected static final int DEFAULT_INITIAL_CAPACITY = 16;

    /**
     * Default load factor.
     */

 * This class implements the SMB1 transaction to retrieve a list of available shares
 * from the target server, including share names, types, and descriptions.
 */
public class NetShareEnum extends SmbComTransaction {

    private static final String DESCR = "WrLeh\u0000B13BWz\u0000";

    /**
     * Constructs a NetShareEnum request
     * @param config
     *            the configuration to use
     */

     */
    public static final int TYPE_ROOT_TARGETS = 0x0;
    /**
     * Indicates non-root targets in the DFS referral.
     */
    public static final int TYPE_NON_ROOT_TARGETS = 0x1;

    private final DfsReferralResponseBuffer dfsResponse = new DfsReferralResponseBuffer();

    /**
     * Constructs a Trans2GetDfsReferralResponse with the specified configuration.
     *
     * @param config the SMB configuration