*
     * @param src the source data array
     * @param soff the offset in the source array
     * @param slen the length of data to process
     * @param dst the destination array for the result
     * @param doff the offset in the destination array
     */
    public void update(final byte[] src, int soff, final int slen, final byte[] dst, int doff) {

import java.net.HttpURLConnection.HTTP_UNAVAILABLE
import java.util.concurrent.BlockingQueue
import java.util.concurrent.LinkedBlockingQueue
import java.util.logging.Logger

/**
 * Default dispatcher that processes a script of responses. Populate the script by calling
 * [enqueue].
 */
public open class QueueDispatcher : Dispatcher() {
  protected val responseQueue: BlockingQueue<MockResponse> = LinkedBlockingQueue()

     * If the session ID contains a hyphen, returns the portion before the first hyphen.
     * Otherwise, returns the original session ID.
     *
     * @param sessionId the session ID to process
     * @return the canonical session ID (portion before first hyphen, or original if no hyphen)
     */
    public String getCanonicalSessionId(final String sessionId) {
        final int idx = sessionId.indexOf('-');

            }
            item = newItem;
        }

        /**
         * Writes a character mapping item to the temporary file.
         *
         * @param oldItem the existing mapping item to process
         * @return the mapping item that was written, or null if the item was deleted
         */
        public CharMappingItem write(final CharMappingItem oldItem) {
            try {

        buffer[7] = 0x00;
        buffer[8] = 0x00;

        // Flags
        buffer[9] = 0x00;

        // Flags2 (2 bytes)
        buffer[10] = 0x00;
        buffer[11] = 0x00;

        // Process ID High (2 bytes)
        buffer[12] = 0x00;
        buffer[13] = 0x00;

        // Signature (8 bytes)
        for (int i = 14; i < 22; i++) {
            buffer[i] = 0x00;
        }

                || exception.getMessage().toLowerCase().contains("used") || exception.getMessage().toLowerCase().contains("being used")
                || exception.getMessage().toLowerCase().contains("process"));
    }

    @Test
    @DisplayName("Should handle DOS error codes")
    void testDOSErrorCodes() {
        // Given
        int dosError = 0x00020002; // File not found from DOS_ERROR_CODES

issue if there is one) requesting the feature and describing specific use cases
for it.

If we decide to pursue a feature request, it will go through a thorough process
of API design and review. Any code should come after this.

[APIs]: https://en.wikipedia.org/wiki/API
[issue]: https://github.com/google/guava/issues

Pull requests
-------------

import jcifs.internal.CommonServerMessageBlockRequest;
import jcifs.internal.util.SMBUtil;

/**
 * SMB2 Cancel request message.
 *
 * This command is used to cancel a previously sent command
 * that is still being processed by the server.
 *
 * @author mbechler
 */
public class Smb2CancelRequest extends ServerMessageBlock2 implements CommonServerMessageBlockRequest {

    /**
     * Constructs a SMB2 cancel request
     *

 * the access mask of the ACE, the access check is successful. Otherwise,
 * more ACEs are evaluated until all desired access bits (combined)
 * are "allowed". If all of the desired access bits are not "allowed"
 * the then same process is repeated for inherited ACEs.
 * <p>
 * For example, if user <code>WNET\alice</code> tries to open a file
 * with desired access bits <code>0x00000003</code> (<code>FILE_READ_DATA |

        // Then - Session should be in consistent state
        // The double-check pattern should prevent inconsistent cleanup
        assertTrue(releaseCount.get() > 0 || acquireCount.get() > 0, "Release and acquire counts should be processed");
    }

    /**
     * Test that trees collection is properly cleared during cleanup.
     */
    @Test
    public void testTreesCollectionCleanup() {
        // Given