* Should correctly parse the raw bytes.
     */
    @Test
    void testAvSingleHostRawConstructor() {
        byte[] rawData = new byte[48]; // 8 (size/zero) + 8 (customData) + 32 (machineId)
        // Simulate some data
        rawData[0] = 48; // size
        rawData[16] = 0x01; // machineId start
        rawData[17] = 0x02;

        AvSingleHost avSingleHost = new AvSingleHost(rawData);

     */
    @Test
    void testResetUpdatesStateAndParameters() {
        // Given
        Trans2FindNext2 next = new Trans2FindNext2(0x0001, 0x0AAA0BBB, "old");
        next.flags2 = 0xFFFF; // simulate non-zero flags2

        // When
        next.reset(0x11121314, "last.dat");

        // Then
        assertEquals(0, next.flags2, "flags2 should be reset to 0");

      val sleepUntil = nanoTime + durationNanos
      yieldUntil { nanoTime >= sleepUntil }
    }
  }

  /**
   * Artificially stall until manually resumed by the test thread with [runTasks]. Use this to
   * simulate races in tasks that doesn't have a deterministic sequence.
   */
  fun yield() {
    taskRunner.assertLockNotHeld()
    taskRunner.withLock {
      yieldUntil()
    }
  }

        assertEquals(expected, result);
    }

    @Test
    void testReadString_Oem() {
        response.useUnicode = false;
        String expected = "test";
        // Simulate OEM encoding with a null terminator
        byte[] src = (expected + "\0").getBytes(StandardCharsets.UTF_8);
        String result = response.readString(src, 0, src.length);
        // The method should remove the null terminator

		fi.ModTime = basefi.ModTime.Add(time.Duration(i) * time.Second)
		if err := xl.AddVersion(fi); err != nil {
			t.Fatalf("%d: Failed to add version %v", i+1, err)
		}

		if i > 3 {
			// Simulate transition of a version
			transfi := fi
			transfi.TransitionStatus = lifecycle.TransitionComplete
			transfi.TransitionTier = "MINIO-TIER"
			transfi.TransitionedObjName = mustGetUUID()
			xl.DeleteVersion(transfi)

        @Override
        protected int writeHeaderWireFormat(byte[] dst, int dstIndex) {
            return 64; // Simulate header writing
        }

        @Override
        public int encode(byte[] dst, int dstIndex) {
            // We need to override the parent ServerMessageBlock2's encode
            // to properly simulate setting the length field
            int start = dstIndex;

    @Mock
    Handler handler;

    @Test
    @DisplayName("Interaction: handler called with each code/message pair")
    void interaction_with_mock_handler_is_as_expected() {
        // Interaction test: simulate passing each code/message to a collaborator
        for (int i = 0; i < WinError.WINERR_CODES.length; i++) {
            handler.handle(WinError.WINERR_CODES[i], WinError.WINERR_MESSAGES[i]);
        }

                        assertNotNull(buffer, "Buffer should not be null");
                        assertEquals(SmbComTransaction.TRANSACTION_BUF_SIZE, buffer.length, "Buffer should have correct size");

                        // Simulate some work
                        buffer[0] = (byte) i;

                        // Release buffer
                        BufferCache.releaseBuffer(buffer);
                        successCount.incrementAndGet();

        // Test exception in a more complex scenario
        InvalidAccessTokenException exception = null;
        String expectedType = "Bearer";
        String expectedMessage = "Token has expired";

        // Simulate a token validation scenario
        boolean tokenValid = false;
        if (!tokenValid) {
            exception = new InvalidAccessTokenException(expectedType, expectedMessage);
        }

        }

        @Override
        public void encode_in(NdrBuffer buf) throws NdrException {
            // Simulate encoding some data
            buf.enc_ndr_long(12345);
        }

        @Override
        public void decode_out(NdrBuffer buf) throws NdrException {
            // Simulate decoding some data
            buf.dec_ndr_long();
        }
    }

    @BeforeEach
    void setUp() {