}

    public void test_getText() {
        final InputStream in = ResourceUtil.getResourceAsStream("extractor/csv/test.csv");
        final ExtractData extractData = csvExtractor.getText(in, null);
        CloseableUtil.closeQuietly(in);

        final String content = extractData.getContent();
        logger.info(content);

        // Verify header extraction

     * @see jcifs.internal.SMBSigningDigest#verify(byte[], int, int, int, jcifs.internal.CommonServerMessageBlock)
     */
    @Override
    public boolean verify(final byte[] data, final int offset, final int l, final int extraPad, final CommonServerMessageBlock m) {

        final ServerMessageBlock msg = (ServerMessageBlock) m;

        if ((msg.getFlags2() & SmbConstants.FLAGS2_SECURITY_SIGNATURES) == 0) {

synchronized class WrapperExecutor { public static final String DISTRIBUTION_URL_PROPERTY = distributionUrl; public static final String DISTRIBUTION_BASE_PROPERTY = distributionBase; public static final String ZIP_STORE_BASE_PROPERTY = zipStoreBase; public static final String DISTRIBUTION_PATH_PROPERTY = distributionPath; public static final String ZIP_STORE_PATH_PROPERTY = zipStorePath; private final java.util.Properties properties; private final java.io.File propertiesFile; private final Appendable...

    @Override
    int writeSetupWireFormat(final byte[] dst, final int dstIndex) {
        return 0;
    }

    @Override
    int writeParametersWireFormat(final byte[] dst, final int dstIndex) {
        return 0;
    }

    @Override
    int writeDataWireFormat(final byte[] dst, final int dstIndex) {
        return 0;
    }

    @Override

    }

    static String queryLookup(final String query, final String param) {
        final char in[] = query.toCharArray();
        int i, ch, st, eq;

        st = eq = 0;
        for (i = 0; i < in.length; i++) {
            ch = in[i];
            if (ch == '&') {
                if (eq > st) {
                    final String p = new String(in, st, eq - st);

     */
    protected String getOutputContent(final File outputFile, final String outExt) {
        final Extractor extractor = getExtractor(outExt);
        if (extractor != null) {
            final Map<String, String> params = new HashMap<>();
            params.put(ExtractData.RESOURCE_NAME_KEY, outputFile.getName());
            try (final FileInputStream in = new FileInputStream(outputFile)) {

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

    /** Queue of documents. */
    protected final Queue<Map<String, Object>> queue = new ConcurrentLinkedQueue<>();
    /** Flag indicating if reading is finished. */
    protected final AtomicBoolean isFinished = new AtomicBoolean(false);

    /** OpenSearch client. */
    protected final Client client;
    /** Suggest settings. */

        final SearchResponse mockScrollResponse = mock(SearchResponse.class);
        final SearchHits mockScrollHits = mock(SearchHits.class);
        final ActionFuture<SearchResponse> mockScrollFuture = mock(ActionFuture.class);

        final BulkRequestBuilder mockBulkBuilder = mock(BulkRequestBuilder.class);

public class SambaHelper {

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

    /**
     * SID type for an alias.
     */
    public static final int SID_TYPE_ALIAS = 4;

    /**
     * SID type for a deleted account.
     */
    public static final int SID_TYPE_DELETED = 6;

    /**
     * SID type for a domain group.
     */
    public static final int SID_TYPE_DOM_GRP = 2;

    /**

     * @param andx the next command in the AndX chain, or null
     */
    public SmbComTreeConnectAndX(final CIFSContext ctx, final ServerData server, final String path, final String service,
            final ServerMessageBlock andx) {
        super(ctx.getConfig(), SMB_COM_TREE_CONNECT_ANDX, andx);
        this.ctx = ctx;
        this.server = server;
        this.path = path;