}

again:
	nextOut, ok := w.buffer[w.nextOffset]
	if ok {
		n, err = w.w.Write(nextOut)
		delete(w.buffer, w.nextOffset)
		w.nextOffset += int64(n)
		if n != len(nextOut) {
			return 0, fmt.Errorf("expected write size %d but wrote %d bytes", len(nextOut), n)
		}
		if err != nil {
			return 0, err
		}
		goto again
	}

	return len(b), nil
}

constraints.AssertTrue.message = {item} must be true.
constraints.DecimalMax.message = {item} must be less than {value}.
constraints.DecimalMin.message = {item} must be greater than {value}.
constraints.Digits.message = {item} must be a number. (expected: <number>.<number>)
constraints.Future.message = {item} must be a future value.
constraints.Max.message = {item} must be less than or equal to {value}.
constraints.Min.message = {item} must be greater than or equal to {value}.

constraints.AssertTrue.message = {item} must be true.
constraints.DecimalMax.message = {item} must be less than {value}.
constraints.DecimalMin.message = {item} must be greater than {value}.
constraints.Digits.message = {item} must be a number. (expected: <number>.<number>)
constraints.Future.message = {item} must be a future value.
constraints.Max.message = {item} must be less than or equal to {value}.
constraints.Min.message = {item} must be greater than or equal to {value}.

        try {
            matchAllQueryCommand.execute(context, query, boost);
            fail("Should throw IllegalArgumentException for negative boost");
        } catch (IllegalArgumentException e) {
            // Expected exception
            assertTrue(e.getMessage().contains("negative [boost] are not allowed"));
        }
    }

    public void test_execute_multipleInvocations() {

        // Decode
        smbInfoAllocation.decode(buffer, 0, buffer.length);

        // Test toString
        String result = smbInfoAllocation.toString();

        // Verify string contains expected values
        assertTrue(result.contains("SmbInfoAllocation"));
        assertTrue(result.contains("alloc=" + alloc));
        assertTrue(result.contains("free=" + free));

        SmbComClose closeReq = mock(SmbComClose.class);
        SmbResourceLocator res = c.ensureDFSResolved(loc, closeReq);
        assertSame(loc, res);
        // No connect attempts expected
        verify(c, never()).connectWrapException(any());
    }

    @Test
    @DisplayName("send retries on transport errors and restores request/response state")

	if len(buf) <= 8 {
		return payload, 0, 0, fmt.Errorf("xlMeta: no data")
	}

	if !bytes.Equal(buf[:4], xlHeader[:]) {
		return payload, 0, 0, fmt.Errorf("xlMeta: unknown XLv2 header, expected %v, got %v", xlHeader[:4], buf[:4])
	}

	if bytes.Equal(buf[4:8], []byte("1   ")) {
		// Set as 1,0.
		major, minor = 1, 0
	} else {

     *
     * @param <T> the response type
     * @param request the request being processed
     * @param response the intermediate response
     * @return true if more responses are expected, false otherwise
     */
    protected <T extends Response> boolean handleIntermediate(final Request request, final T response) {
        return false;
    }

    /**

        when(readResponse.getOffset()).thenReturn(0);

        boolean result = digest.verify(data, 0, data.length, 0, readResponse);
        assertTrue(result); // Signature mismatch expected
    }

    @Test
    @DisplayName("Test verify method with invalid signature")
    void testVerifyWithInvalidSignature() {
        SMB1SigningDigest digest = new SMB1SigningDigest(testMacSigningKey);

        assertNotNull(validHost);

        // Invalid entries should not be found or may have incorrect parsing
        // Note: The actual Lmhosts parser may accept "192.168.1" and parse it differently
        // than expected, so we're not asserting null for HOST1
    }

    @Test
    void testPopulateWithLongHostname() throws Exception {
        // Create a temporary lmhosts file with long hostname