} catch (Exception e) {
            // It's ok if it fails, we just want to verify reset was called
        }

        // Request/response reset should happen on retry
        verify(req, atLeastOnce()).reset();
        verify(resp, atLeastOnce()).reset();
        // Verify disconnect was called on retry
        verify(c, atLeastOnce()).disconnect(eq(true));
    }

    @Test

                buffer.encode(dst, 0);

                // Verify SMBUtil.writeInt2 was called for referral level (with long parameter)
                mockedSMBUtil.verify(() -> SMBUtil.writeInt2(eq((long) maxReferralLevel), any(byte[].class), eq(0)));
                // Verify SMBUtil.writeInt2 was called for null terminator
                mockedSMBUtil.verify(() -> SMBUtil.writeInt2(eq(0L), any(byte[].class), anyInt()));
            }

        failover.handleFailure(failedChannel, error);

        // Verify pending operations were cleared from failed channel
        assertEquals(0, failedChannel.getRequestsPending());

        // Verify alternative channel was selected and operation added
        verify(mockLoadBalancer).selectChannel(mockOperation);
        verify(alternativeChannel).addPendingOperation(mockOperation);
    }

    @Test

        when(locator.handleDFSReferral(referral, reqPath)).thenReturn(resolved);

        String out = locator.handleDFSReferral(referral, reqPath);
        assertEquals(resolved, out);

        // Verify exact argument interaction
        verify(locator, times(1)).handleDFSReferral(referral, reqPath);
        verifyNoMoreInteractions(locator);
    }

    // Edge / invalid: null referral or empty/blank path
    @Test

func checkBucketAndObjectNames(ctx context.Context, bucket, object string) error {
	// Verify if bucket is valid.
	if !isMinioMetaBucketName(bucket) && s3utils.CheckValidBucketNameStrict(bucket) != nil {
		return BucketNameInvalid{Bucket: bucket}
	}
	// Verify if object is valid.
	if len(object) == 0 {
		return ObjectNameInvalid{Bucket: bucket, Object: object}
	}

        // Verify bytes written
        assertTrue(bytesWritten > 0);
        assertEquals(19, bytesWritten); // 2 + 13 + 2 + 2

        // Verify NET_SHARE_ENUM command (2 bytes)
        assertEquals(SmbComTransaction.NET_SHARE_ENUM, dst[0]);
        assertEquals(0, dst[1]);

        // Verify descriptor (WrLeh\0B13BWz\0 in ASCII - 13 bytes)

            // Verify that AllocInfo extends FileSystemInformation
            assertTrue(FileSystemInformation.class.isAssignableFrom(AllocInfo.class));
        }

        @Test
        @DisplayName("Should implement Decodable interface through FileSystemInformation")
        void shouldImplementDecodableInterface() {
            // Verify that AllocInfo indirectly implements Decodable

    }

    @Test
    void constructor_shouldInitializeFields() throws Exception {
        // Verify configuration is set
        Field configField = NameServicePacket.class.getDeclaredField("config");
        configField.setAccessible(true);
        assertSame(mockConfig, configField.get(response));

        // Verify queryAddress is set
        Field queryAddressField = NodeStatusResponse.class.getDeclaredField("queryAddress");

        doNothing().when(requestWithPath).setResolveInDfs(true);
        requestWithPath.setResolveInDfs(true);
        verify(requestWithPath, times(1)).setResolveInDfs(true);

        doNothing().when(requestWithPath).setResolveInDfs(false);
        requestWithPath.setResolveInDfs(false);
        verify(requestWithPath, times(1)).setResolveInDfs(false);

        // Test with implementation

        ns.encode(spy);
        // NdrShort passes its value (already masked to 0xFF) to enc_ndr_short
        verify(spy).enc_ndr_short(42);
    }

    /**
     * Verify that decode invokes NdrBuffer.dec_ndr_short.
     */
    @Test
    void decodeWithSpiedBufferCallsDecMethod() throws NdrException {
        NdrShort ns = new NdrShort(0); // value will be overwritten