assertTrue(region.hasAccess(RdmaAccess.LOCAL_READ), "Should have local read access");
        assertTrue(region.hasAccess(RdmaAccess.LOCAL_WRITE), "Should have local write access");
        assertFalse(region.hasAccess(RdmaAccess.REMOTE_READ), "Should not have remote read access");

        // Test cleanup
        region.close();

  # https://github.com/ossf/scorecard/blob/main/docs/checks.md#maintained
  schedule:
    - cron: '45 9 * * 0'
  push:
    branches: [ "master" ]

# Declare default permissions as read only.
permissions: read-all

jobs:
  analysis:
    name: Scorecard analysis
    runs-on: ubuntu-latest
    permissions:
      # Needed to upload the results to code-scanning dashboard.
      security-events: write

    /**
     * Lock and read operation is supported capability.
     */
    int CAP_LOCK_AND_READ = 0x0100;
    /**
     * NT find operations are supported capability.
     */
    int CAP_NT_FIND = 0x0200;
    /**
     * DFS operations are supported capability.
     */
    int CAP_DFS = 0x1000;
    /**
     * Large read operations are supported capability.
     */

            beg_idx = (beg_idx + 1) % pipe_buf.length;
        }
        return result;
    }

    @Override
    public int read(final byte[] b) throws IOException {
        return read(b, 0, b.length);
    }

    @Override
    public int read(final byte[] b, int off, final int len) throws IOException {
        int result = -1;
        int i;

        if (len <= 0) {
            return 0;

 *       block indefinitely or fail if the source creates an infinite stream.
 *   <li><b>Non-destructive:</b> A <i>destructive</i> stream will consume or otherwise alter the
 *       bytes of the source as they are read from it. A source that provides such streams will not
 *       be reusable, and operations that read from the stream (including {@link #size()}, in some

        trans2QueryPathInfo = new Trans2QueryPathInformation(config, TEST_FILENAME, TEST_INFO_LEVEL);

        byte[] buffer = new byte[256];
        int read = trans2QueryPathInfo.readSetupWireFormat(buffer, 0, buffer.length);

        // Should read nothing (returns 0)
        assertEquals(0, read);
    }

    @Test
    void testReadParametersWireFormat() {

        // Flags should not be set for partial read
        assertFalse(d.getParametersDone(), "parametersDone should be false for partial read");
        assertFalse(d.getDataDone(), "dataDone should be false for partial read");
        assertTrue(d.getHasMore(), "hasMore should remain true for partial read");
    }

    /**
     * Test scenario with no data to read
     */
    @Test

) {
  private val countingSource: CountingSource = CountingSource(source)
  private val source: BufferedSource = countingSource.buffer()

  /** Total bytes read thus far. */
  private val byteCount: Long
    get() = countingSource.bytesRead - source.buffer.size

  /** How many bytes to read before [peekHeader] should return false, or -1L for no limit. */
  private var limit = -1L

            assertEquals(49, SMBUtil.readInt2(buffer, 0)); // Structure size
            assertEquals(2, buffer[2]); // Padding
            assertEquals(0x01, buffer[3]); // Read flags
            assertEquals(4096, SMBUtil.readInt4(buffer, 4)); // Read length
            assertEquals(8192L, SMBUtil.readInt8(buffer, 8)); // Offset
            assertArrayEquals(testFileId, Arrays.copyOfRange(buffer, 16, 32)); // File ID

        }
    }

    /**
     * Returns an InputStream to read the content from the cache.
     * If the content is stored in a file, a FileInputStream is returned.
     * Otherwise, a ByteArrayInputStream is returned to read the data from memory.
     *
     * @return an InputStream to read the cached content
     * @throws IOException if an I/O error occurs while creating the InputStream
     */