/**
     * Following the contract of {@link AbstractQueuedSynchronizer} we create a private subclass to
     * hold the synchronizer. This synchronizer is used to implement the blocking and waiting calls
     * as well as to handle state changes in a thread-safe manner. The current state of the future
     * is held in the Sync state, and the lock is released whenever the state changes to {@link
     * #COMPLETED}, {@link #CANCELLED}, or {@link #INTERRUPTED}

        assertEquals(0x00, dst[13]);

        // Check security information
        assertEquals(0x12345678, SMBUtil.readInt4(dst, 14));
    }

    @Test
    @DisplayName("Test with negative FID value (should handle as unsigned)")
    void testNegativeFidValue() {
        int fid = -1; // Will be treated as 0xFFFF in unsigned 16-bit
        querySecurityDesc = new NtTransQuerySecurityDesc(mockConfig, fid, OWNER_SECURITY_INFORMATION);

// toAPIErrorCode - Converts embedded errors. Convenience
// function written to handle all cases where we have known types of
// errors returned by underlying layers.
func toAPIErrorCode(ctx context.Context, err error) (apiErr APIErrorCode) {
	if err == nil {
		return ErrNone
	}

	// Errors that are generated by net.Conn and any context errors must be handled here.

X25519MLKEM768 by default. The default can be reverted using the
[`tlsmlkem` setting](/pkg/crypto/tls/#Config.CurvePreferences).
This can be useful when dealing with buggy TLS servers that do not handle large records correctly,
causing a timeout during the handshake (see [TLS post-quantum TL;DR fail](https://tldr.fail/)).
Go 1.24 also removed X25519Kyber768Draft00 and the Go 1.23 `tlskyber` setting.

        DataStoreFactory testFactory = new DataStoreFactory() {
            @Override
            protected List<String> loadDataStoreNameList() {
                // Will handle exception and log warning
                return super.loadDataStoreNameList();
            }
        };

        List<String> names = testFactory.loadDataStoreNameList();
        assertNotNull(names);

        System.arraycopy(buffer, offset + 8, copiedFileId, 0, 16);
        assertArrayEquals(testFileId, copiedFileId);
    }

    @Test
    @DisplayName("writeBytesWireFormat with null file ID should handle gracefully")
    void testWriteBytesWireFormatWithNullFileId() {
        Smb2FlushRequest requestWithNull = new Smb2FlushRequest(mockConfig, null);
        byte[] buffer = new byte[256];

        assertThrows(PACDecodingException.class, () -> {
            unicodeString.check("");
        });

        // The implementation has a bug - it doesn't handle null properly
        // It throws NullPointerException instead of returning null
        // This is a known issue in the production code
        assertThrows(NullPointerException.class, () -> {

        d.parameterCount = 0;
        d.dataCount = 0;
        d.headerStart = 0;

        byte[] buf = new byte[100];
        int result = d.readBytesWireFormat(buf, 0);

        // Should handle empty read gracefully
        assertEquals(0, result, "Should return 0 for no data");
        assertTrue(d.getParametersDone(), "parametersDone should be true when total is 0");

					relation, ok := db.Statement.Schema.Relationships.Relations[join.Name]
					if ok {
						isRelations = true
						relations = append(relations, relation)
					} else {
						// handle nested join like "Manager.Company"
						nestedJoinNames := strings.Split(join.Name, ".")
						if len(nestedJoinNames) > 1 {
							isNestedJoin := true

	for _, format := range formats {
		if format == nil {
			continue
		}
		// NOTE: This code is specifically needed when migrating version
		// V1 to V2 to V3, in a scenario such as this we only need to handle
		// single sets since we never used to support multiple sets in releases
		// with V1 format version.
		if len(format.Erasure.Sets) > 1 {
			continue
		}
		if format.Erasure.This == "" {
			return true