if (len <= 0) {
            return 0;
        }
        final long start = this.fp;

        try (SmbFileHandleImpl fh = ensureOpen(); SmbTreeHandleImpl th = fh.getTree()) {

            int r, n;
            final SmbComReadAndXResponse response = new SmbComReadAndXResponse(th.getConfig(), b, off);
            do {
                r = len > this.readSize ? this.readSize : len;

        if (!this.handle.isValid()) {
            throw new SmbException("Watch was broken by tree disconnect");
        }
        try (SmbTreeHandleImpl th = this.handle.getTree()) {

            CommonServerMessageBlockRequest req;
            NotifyResponse resp = null;
            if (th.isSMB2()) {

    @Override
    public int sendrecv(final byte[] buf, final int off, final int length, final byte[] inB, final int maxRecvSize) throws IOException {
        try (SmbFileHandleImpl fh = ensureOpen(); SmbTreeHandleImpl th = fh.getTree()) {

            if (th.isSMB2()) {
                final Smb2IoctlRequest req =
                        new Smb2IoctlRequest(th.getConfig(), Smb2IoctlRequest.FSCTL_PIPE_TRANSCEIVE, fh.getFileId(), inB);

    void setUp() throws Exception {
        // Common, safe defaults for collaborators
        when(mockHandle.isValid()).thenReturn(true);
        when(mockHandle.acquire()).thenReturn(mockHandle);
        when(mockHandle.getTree()).thenReturn(mockTree);
        when(mockHandle.getFileId()).thenReturn(new byte[16]);

        when(mockTree.getReceiveBufferSize()).thenReturn(0x10000);
        when(mockTree.getMaximumBufferSize()).thenReturn(0x10000);

            return;
        }

        if (this.tmp == null) {
            throw new IOException("Bad file descriptor");
        }

        try (SmbFileHandleImpl fh = ensureOpen(); SmbTreeHandleImpl th = fh.getTree()) {
            if (log.isDebugEnabled()) {
                log.debug("write: fid=" + fh + ",off=" + off + ",len=" + len + ",fp=" + this.fp);
            }

            int w;
            do {

    private Smb2WriteResponse mockWriteResponse;

    private SmbFileOutputStream outputStream;

    @BeforeEach
    void setUp() {
        // Common setup for most tests
        lenient().when(mockFileHandle.getTree()).thenReturn(mockTreeHandle);
        lenient().when(mockTreeHandle.getConfig()).thenReturn(mockConfig);
    }

    @Test
    void testWriteSingleByte() throws IOException, CIFSException {
        // Given

        if (this.tmp == null) {
            throw new IOException("Bad file descriptor");
        }
        // ensure file is open
        try (SmbFileHandleImpl fd = ensureOpen(); SmbTreeHandleImpl th = fd.getTree()) {

            if (log.isTraceEnabled()) {
                log.trace("read: fid=" + fd + ",off=" + off + ",len=" + len);
            }

            final int type = this.file.getType();
            int r, n;

The links and the invocations' status can then be printed out, or output in the
form of JUnit-based XML.
"""
import argparse
import datetime
import os
import re
from typing import Dict, Union
import xml.etree.ElementTree as ElemTree


ResultDictType = Dict[str, Dict[str, Union[str, int]]]

RESULT_STORE_LINK_RE = re.compile(
    r'^INFO: Streaming build results to: (https://[\w./\-]+)')

                    request.setWatchTree(false);  // Non-recursive for now
                    
                    Smb2ChangeNotifyResponse response = (Smb2ChangeNotifyResponse) 
                        handle.directoryFile.getTree().send(request);
                    
                    if (response.isSuccess()) {
                        processChangeNotification(handle, response);
                    }
                    

        if (type == TYPE_SHARE) {
            size = response.info.getCapacity();
            sizeExpiration = System.currentTimeMillis() + attrExpirationPeriod;
        }

        return response.info.getFree();
    }

    /**
     * Creates a directory with the path specified by this
     * <code>SmbFile</code>. For this method to be successful, the target
     * must not already exist. This method will fail when