if (userName != null && userName.length() != 0) {
                user = unicode ? userName.getBytes(UNI_ENCODING) : userName.toUpperCase().getBytes(oem);
            }
            final int userLength = user != null ? user.length : 0;
            final String workstationName = getWorkstation();
            byte[] workstation = null;
            if (workstationName != null && workstationName.length() != 0) {

    // test separators work
    for (int sepLength = 3; sepLength <= 5; sepLength++) {
      for (String separator : ImmutableList.of(",", "\n", ";;", "")) {
        testEncoding(
            encoding.withSeparator(separator, sepLength),
            decoded,
            Joiner.on(separator).join(Splitter.fixedLength(sepLength).split(encoded)));
      }
    }
  }

    // test separators work
    for (int sepLength = 3; sepLength <= 5; sepLength++) {
      for (String separator : ImmutableList.of(",", "\n", ";;", "")) {
        testEncoding(
            encoding.withSeparator(separator, sepLength),
            decoded,
            Joiner.on(separator).join(Splitter.fixedLength(sepLength).split(encoded)));
      }
    }
  }

        ndrBuffer.advance(10);
        assertEquals(10, ndrBuffer.getLength());

        ndrBuffer.setLength(20);
        assertEquals(20, ndrBuffer.getLength());

        // Test with derived buffer
        NdrBuffer derived = ndrBuffer.derive(0);
        derived.setLength(5);
        assertEquals(5, derived.getLength());

        when(tree.send(any(jcifs.internal.Request.class), any(RequestParam.class))).thenReturn(null);

        raf.setLength(100L);

        verify(tree, times(1)).send(any(Smb2SetInfoRequest.class), eq(RequestParam.NO_RETRY));
    }

    @Test
    @DisplayName("setLength(): NT SMBs capability uses Trans2SetFileInformation")
    void setLength_ntsmbs_usesTrans2() throws Exception {

        int notificationType = buf.dec_ndr_long();
        notification.setNotificationType(WitnessEventType.fromValue(notificationType));

        // Length
        int length = buf.dec_ndr_long();
        notification.setLength(length);

        // Number of messages
        int numberOfMessages = buf.dec_ndr_long();

        // Messages array
        List<WitnessNotificationMessage> messages = new ArrayList<>(numberOfMessages);

            //
            // LinkedList<IbvSge> sgeList = new LinkedList<>();
            // IbvSge sge = new IbvSge();
            // sge.setAddr(disniRegion.getAddress());
            // sge.setLength(data.remaining());
            // sge.setLkey(disniRegion.getLocalKey());
            // sgeList.add(sge);
            //
            // sendWR.setSg_list(sgeList);

                    } else {
                        logger.warn("[{}][{}] Failed to analyze a text(size:{}). {}", field, lang, buf.length(), e.getMessage());
                    }
                }
                buf.setLength(0);
            }
        }
        if (buf.length() > 0) {
            try {
                tokens.addAll(analyzer.analyze(buf.toString().trim(), field, lang));

        super.end();
        offsetAttr.setOffset(finalOffset, finalOffset);
    }

    @Override
    public void reset() throws IOException {
        super.reset();
        block.setLength(0);
        prevToken = null;
        readBufferIndex = BUFFER_SIZE;
        readBufferLen = 0;
        ch = 0;
        blkStart = 0;
        nextBlkStart = 0;

    }

    @Override
    public void run() {
        int nameTrnId;
        NameServicePacket response;

        try {
            while (thread == Thread.currentThread()) {
                in.setLength(RCV_BUF_SIZE);

                socket.setSoTimeout(closeTimeout);
                socket.receive(in);

                if (LogStream.level > 3) {