System.arraycopy(fid, 0, buf, pos, 16);
        pos += 16;

        // Calculate offsets relative to start of SMB2 header
        int inputOffsetField = inputCount > 0 ? payloadStart : 0;
        int outputOffsetField = outputCount > 0 ? payloadStart + inputCount : 0;

        // inputOffset (relative to header start)
        SMBUtil.writeInt4(inputOffsetField, buf, pos);
        pos += 4;
        // inputCount

## Edit PR Titles

* Edit the PR title to start with an emoji from [gitmoji](https://gitmoji.dev/).
    * Use the emoji character, not the GitHub code. So, use `🐛` instead of `:bug:`. This is so that it shows up correctly outside of GitHub, for example in the release notes.
    * For translations use the `🌐` emoji ("globe with meridians").

        final int start = dstIndex;
        SMBUtil.writeInt2(24, dst, dstIndex);
        dstIndex += 2;
        dstIndex += 2; // Reserved1
        dstIndex += 4; // Reserved2

        System.arraycopy(this.fileId, 0, dst, dstIndex, 16);
        dstIndex += 16;

        return dstIndex - start;
    }

    /**
     * {@inheritDoc}
     *

        if (len < 20) {
            throw new SMBProtocolDecodingException("Invalid RDMA Transform Capabilities context length: " + len);
        }

        int start = bufferIndex;

        transformCount = SMBUtil.readInt2(buffer, bufferIndex);
        bufferIndex += 2;
        reserved1 = SMBUtil.readInt2(buffer, bufferIndex);
        bufferIndex += 2;

}

// UnmarshalXML - decodes XML data.
func (l *ObjectLegalHold) UnmarshalXML(d *xml.Decoder, start xml.StartElement) (err error) {
	switch start.Name.Local {
	case "LegalHold", "ObjectLockLegalHold":
	default:
		return xml.UnmarshalError(fmt.Sprintf("expected element type <LegalHold>/<ObjectLockLegalHold> but have <%s>",
			start.Name.Local))
	}
	for {
		// Read tokens from the XML document in a stream.
		t, err := d.Token()

    // Test default state of not started.
    assertEquals(1, listenerLatch.getCount());
    assertFalse(task.isDone());
    assertFalse(task.isCancelled());

    // Start the task to put it in the RUNNING state.  Have to use a separate
    // thread because the task will block on the task latch after unblocking
    // the run latch.
    exec.execute(task);
    runLatch.await();

        writeInt4(dst, dstIndex, shareAccessHint);
        dstIndex += 4;
        
        return dstIndex - start;
    }
    
    @Override
    protected int readPayload(byte[] buffer, int offset) throws SMBProtocolDecodingException {
        int start = offset;
        
        // StructureSize (2 bytes)
        structureSize = readInt2(buffer, offset);
        offset += 2;
        

    }

    @Test
    public void test_execute_2instanceTx() throws Exception {
        final CrawlerWebServer server1 = new CrawlerWebServer(0);
        server1.start();
        final CrawlerWebServer server2 = new CrawlerWebServer(0);
        server2.start();

        final String url1 = "http://localhost:" + server1.getPort() + "/";
        final String url2 = "http://localhost:" + server2.getPort() + "/";
        try {

            this.transportContext = SingletonContext.getInstance();
        }
        return this.transportContext;
    }

    @Override
    protected void parseURL(final URL u, String spec, final int start, int limit) {
        final String host = u.getHost();
        String path, ref;
        int port;

        if (spec.equals("smb://")) {
            spec = "smb:////";
            limit += 2;

func (o *listPathOptions) parseMarker() {
	s := o.Marker
	if !strings.Contains(s, "[minio_cache:"+markerTagVersion) {
		return
	}
	start := strings.LastIndex(s, "[")
	o.Marker = s[:start]
	end := strings.LastIndex(s, "]")
	tag := strings.Trim(s[start:end], "[]")
	tags := strings.SplitSeq(tag, ",")
	for tag := range tags {
		kv := strings.Split(tag, ":")
		if len(kv) < 2 {