class TransactNamedPipeInputStream extends SmbFileInputStream {

    private static final int INIT_PIPE_SIZE = 4096;

    private byte[] pipe_buf = new byte[INIT_PIPE_SIZE];
    private int beg_idx, nxt_idx, used;
    private final boolean dcePipe;

    Object lock;

    TransactNamedPipeInputStream(final SmbNamedPipe pipe) throws SmbException, MalformedURLException, UnknownHostException {

    private static final String VALID_UUID_STRING = "00112233-4455-6677-8899-AABBCCDDEEFF";
    private static final String VALID_UUID_STRING_LOWERCASE = "00112233-4455-6677-8899-aabbccddeeff";

    // Corresponding values for the valid UUID string
    private static final int TIME_LOW = 0x00112233;
    private static final short TIME_MID = (short) 0x4455;
    private static final short TIME_HI_AND_VERSION = (short) 0x6677;

    public void setTid(final int t) {
        setTreeId(t);
    }

    /**
     * {@inheritDoc}
     *
     * @see jcifs.internal.smb2.ServerMessageBlock2#encode(byte[], int)
     */
    @Override
    public int encode(final byte[] dst, final int dstIndex) {
        final int len = super.encode(dst, dstIndex);
        final int exp = size();
        final int actual = getLength();
        if (exp != actual) {

import java.util.regex.Pattern;

/**
 * Utility class for parsing CSV text
 */
public final class KuromojiCSVUtil {
    private static final char QUOTE = '"';

    private static final char COMMA = ',';

    private static final Pattern QUOTE_REPLACE_PATTERN = Pattern.compile("^\"([^\"]+)\"$");

    private static final String ESCAPED_QUOTE = "\"\"";

    private KuromojiCSVUtil() {
    } // no instance!!!

    /**

public class ChannelManager {
    private final CIFSContext context;
    private final SmbSession session;
    private final Map<String, ChannelInfo> channels;
    private final List<NetworkInterfaceInfo> localInterfaces;
    private final List<NetworkInterfaceInfo> remoteInterfaces;
    private final ScheduledExecutorService scheduler;
    private final ChannelLoadBalancer loadBalancer;

     * @param in the input stream to read the mapping data from
     */
    protected void reload(final MappingUpdater updater, final InputStream in) {
        final Pattern parsePattern = Pattern.compile("(.*?)\\s*+=>\\s*+(.*?)\\s*+$");
        final List<CharMappingItem> itemList = new ArrayList<>();
        try (BufferedReader reader = new BufferedReader(new InputStreamReader(in, Constants.UTF_8))) {

     * @return An optional entity of a data config.
     */
    public static OptionalEntity<DataConfig> getDataConfig(final CreateForm form) {
        final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
        final String username = systemHelper.getUsername();
        final long currentTime = systemHelper.getCurrentTimeAsLong();
        return getEntity(form, username, currentTime).map(entity -> {

     *
     * @param args command-line arguments
     */
    public static void main(final String[] args) {
        final Options options = new Options();

        final CmdLineParser parser = new CmdLineParser(options);
        try {
            parser.parseArgument(args);
        } catch (final CmdLineException e) {
            System.err.println(e.getMessage());

     * @param config the CIFS configuration
     */
    public SmbComBlankResponse(final Configuration config) {
        super(config);
    }

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

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

    @Override

     * Gets the expanded names array for this referral.
     *
     * @return the expandedNames
     */
    public final String[] getExpandedNames() {
        return this.expandedNames;
    }

    @Override
    public int decode(final byte[] buffer, int bufferIndex, final int len) {
        final int start = bufferIndex;

        this.version = SMBUtil.readInt2(buffer, bufferIndex);