}

    /**
     * Test if the PIPE_TYPE_WRONLY constant has the correct value.
     */
    @Test
    void testPipeTypeWronly() {
        assertEquals(SmbConstants.O_WRONLY, SmbPipeResource.PIPE_TYPE_WRONLY, "PIPE_TYPE_WRONLY should match SmbConstants.O_WRONLY");
    }

    /**

	f.buf.Write(data)
	// Flush to w until a potential match of exitRe
	b := f.buf.Bytes()
	match := f.exitRe.FindIndex(b)
	if match == nil {
		// Flush all of the buffer.
		_, err := f.w.Write(b)
		f.buf.Reset()
		if err != nil {
			return n, err
		}
	} else {
		// Flush up to the beginning of the (potential) match.
		_, err := f.w.Write(b[:match[0]])
		f.buf.Next(match[0])
		if err != nil {
			return n, err
		}

			return 1
		fi
	done

	return 0
}

assert_is_supported_arch() {
	case "${ARCH}" in
	x86_64 | amd64 | aarch64 | ppc64le | arm* | s390x | loong64 | loongarch64 | riscv64)
		return
		;;
	*)
		echo "Arch '${ARCH}' is not supported. Supported Arch: [x86_64, amd64, aarch64, ppc64le, arm*, s390x, loong64, loongarch64, riscv64]"
		exit 1
		;;
	esac
}

assert_is_supported_os() {

import jetbrains.buildServer.configs.kotlin.ParameterDisplay

class RerunFlakyTest(
    os: Os,
    arch: Arch = Arch.AMD64,
) : BuildType({
        val id = "Util_RerunFlakyTest${os.asName()}${arch.asName()}"
        name = "Rerun Flaky Test - ${os.asName()} ${arch.asName()}"
        description = "Allows you to rerun a selected flaky test 10 times"
        id(id)

        assertEquals(errorClass, exception.errorClass, "Error class should match the constructor argument");
        assertEquals(errorCode, exception.errorCode, "Error code should match the constructor argument");
        assertEquals(NbtException.getErrorString(errorClass, errorCode), exception.getMessage(),
                "Exception message should match getErrorString output");

        final UrlQueue<?> urlQueue = new UrlQueueImpl<>();
        urlQueue.setUrl("http://example.com/");
        urlQueue.setDepth(1);

        when(urlFilter.match(anyString())).thenReturn(true);

        // Use reflection to access protected method
        final java.lang.reflect.Method method = CrawlerThread.class.getDeclaredMethod("isValid", UrlQueue.class);

        return searchEngineClient.delete(fessConfig.getIndexDocumentUpdateIndex(), id);
    }

    /**
     * Deletes all documents that match the specified URL.
     *
     * @param searchEngineClient the search engine client to use for deletion
     * @param url the URL to match for document deletion
     * @return the number of documents that were deleted
     */

        // Verify resume key content
        for (int i = 0; i < 24; i++) {
            assertEquals((byte) (i + 1), resumeKey[i], "Resume key byte " + i + " should match");
        }
    }

    @Test
    @DisplayName("Test decode with non-zero buffer offset")
    void testDecodeWithOffset() throws SMBProtocolDecodingException {
        // Prepare test data with offset

        assertNotNull(region, "Memory region should not be null");
        assertEquals(buffer, region.getBuffer(), "Buffer should match");
        assertEquals(1024, region.getSize(), "Size should match buffer size");
        assertTrue(region.hasAccess(RdmaAccess.LOCAL_READ), "Should have local read access");

            getRuleCallCount++;
            if (responseData == null) {
                return null;
            }

            for (Rule rule : rules) {
                if (rule != null && rule.match(responseData)) {
                    return rule;
                }
            }
            return null;
        }

        @Override
        public void addRule(Rule rule) {
            if (rule != null) {