return array;
        } catch (final IndexNotFoundException e) {
            return new Map[0];
        }
    }

    /**
     * Add a value to array index.
     * @param index Index
     * @param type Type
     * @param id ID
     * @param source Source
     */
    protected void addToArrayIndex(final String index, final String type, final String id, final Map<String, Object> source) {

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

    /** Constant for JavaBin serializer type. */
    protected static final String JAVABIN = "javabin";

    /** Constant for Kryo serializer type. */
    protected static final String KRYO = "kryo";

    /** ThreadLocal container for Kryo instances to ensure thread safety. */
    protected final ThreadLocal<Kryo> kryoThreadLocal;

     */

    @Override
    public int read(final byte[] b) throws IOException {
        return read(b, 0, b.length);
    }

    /**
     * Reads up to len bytes of data from this input stream into an array of bytes.
     *
     * @throws IOException if a network error occurs
     */

    @Override
    public int read(final byte[] b, final int off, final int len) throws IOException {

    private static final long serialVersionUID = 1L;

    /**
     * Constructs a new FessSystemException with the specified detail message and cause.
     *
     * @param message the detail message describing the exception
     * @param cause the cause of this exception
     */
    public FessSystemException(final String message, final Throwable cause) {
        super(message, cause);
    }

@Tag("it")
public class SchedulerTests extends CrudTestBase {

    private static final String NAME_PREFIX = "schedulerTest_";
    private static final String API_PATH = "/api/admin/scheduler";
    private static final String LIST_ENDPOINT_SUFFIX = "settings";
    private static final String ITEM_ENDPOINT_SUFFIX = "setting";

    private static final String KEY_PROPERTY = "name";

    @Override
    protected String getNamePrefix() {

 *
 * @author Jesse Wilson
 */
@NullUnmarked
public class ReentrantEventsTest extends TestCase {

  static final String FIRST = "one";
  static final Double SECOND = 2.0d;

  final EventBus bus = new EventBus();

  public void testNoReentrantEvents() {
    ReentrantEventsHater hater = new ReentrantEventsHater();
    bus.register(hater);

    bus.post(FIRST);

     * @param machineId the machine identifier (32 bytes)
     */
    public AvSingleHost(final byte[] customData, final byte[] machineId) {
        this(encode(customData, machineId));
    }

    private static byte[] encode(final byte[] customData, final byte[] machineId) {
        final int size = 8 + 8 + 32;
        final byte[] enc = new byte[size];
        SMBUtil.writeInt4(size, enc, 0);
        SMBUtil.writeInt4(0, enc, 4);

     */
    public static byte[] getLMv2Response(final String domain, final String user, final String password, final byte[] challenge,
            final byte[] clientChallenge) {
        try {
            final byte[] hash = new byte[16];
            final byte[] response = new byte[24];
            // The next 2-1/2 lines of this should be placed with nTOWFv1 in place of password
            final MD4 md4 = new MD4();

     *            The message ID of the request to cancel
     * @param asyncId
     *            The async ID for asynchronous operations (0 for synchronous)
     */
    public Smb2CancelRequest(final Configuration config, final long mid, final long asyncId) {
        super(config, SMB2_CANCEL);
        setMid(mid);
        setAsyncId(asyncId);
        if (asyncId != 0) {
            addFlags(SMB2_FLAGS_ASYNC_COMMAND);
        }
    }

    private final String[] stopwords;

    private final boolean ignoreCase;

    public StopTokenPrefixFilterFactory(final IndexSettings indexSettings, final Environment environment, final String name,
            final Settings settings) {
        super(indexSettings, name, settings);