data.write("0264".decodeHex()).write(bytes, 0, 100)
    data.write("8064".decodeHex()).write(bytes, 100, 100)
    clientReader.processNextFrame()
    callback.assertBinaryMessage(bytes)
  }

  @Test fun twoFrameNotContinuation() {
    val bytes = binaryData(200)
    data.write("0264".decodeHex()).write(bytes, 0, 100)
    data.write("8264".decodeHex()).write(bytes, 100, 100)
    assertFailsWith<ProtocolException> {

        // Arrange
        byte[] buffer = new byte[100];

        // Act & Assert
        assertEquals(0, response.readSetupWireFormat(buffer, 0, 100));
        assertEquals(0, response.readParametersWireFormat(buffer, 0, 100));
        assertEquals(0, response.readDataWireFormat(buffer, 0, 100));
    }

    @Test
    @DisplayName("Methods should handle null buffer without validation")
    void testMethodsWithNullBuffer() {

	if found {
		if cpuIdleMetric, ok := cpuResourceMetrics[getResourceKey(cpuIdle, nil)]; ok {
			avgVal := math.Round(cpuIdleMetric.Avg*100) / 100
			m.Set(sysCPUAvgIdle, avgVal)
		}
		if cpuIOWaitMetric, ok := cpuResourceMetrics[getResourceKey(cpuIOWait, nil)]; ok {
			avgVal := math.Round(cpuIOWaitMetric.Avg*100) / 100
			m.Set(sysCPUAvgIOWait, avgVal)
		}
	}
	return nil

        message.setFlag(0b0100, true);
        assertEquals(0b0101, message.getFlags(), "Flag 0b0100 should be added to existing flags.");

        // Test clearing a flag
        message.setFlag(0b0001, false);
        assertEquals(0b0100, message.getFlags(), "Flag 0b0001 should be cleared.");

        message.setFlag(0b0100, false);

	}

	if !reflect.DeepEqual([]interface{}{"jinzhu", "POINT(100 100)"}, stmt.Vars) {
		t.Errorf("generated vars is not equal, got %v", stmt.Vars)
	}

	stmt = dryRunDB.Model(UserWithPoint{}).Create(map[string]interface{}{
		"Name":  "jinzhu",
		"Point": clause.Expr{SQL: "ST_PointFromText(?)", Vars: []interface{}{"POINT(100 100)"}},
	}).Statement

  public void testThreshold() throws Exception {
    testThreshold(0, 100, true, false);
    testThreshold(10, 100, true, false);
    testThreshold(100, 100, true, false);
    testThreshold(1000, 100, true, false);
    testThreshold(0, 100, false, false);
    testThreshold(10, 100, false, false);
    testThreshold(100, 100, false, false);
    testThreshold(1000, 100, false, false);
  }

    }

    /**
     * Test if the PIPE_TYPE_CALL constant has the correct value.
     */
    @Test
    void testPipeTypeCall() {
        assertEquals(0x0100, SmbPipeResource.PIPE_TYPE_CALL, "PIPE_TYPE_CALL should be 0x0100");
    }

    /**
     * Test if the PIPE_TYPE_TRANSACT constant has the correct value.
     */
    @Test
    void testPipeTypeTransact() {

  public void testThreshold() throws Exception {
    testThreshold(0, 100, true, false);
    testThreshold(10, 100, true, false);
    testThreshold(100, 100, true, false);
    testThreshold(1000, 100, true, false);
    testThreshold(0, 100, false, false);
    testThreshold(10, 100, false, false);
    testThreshold(100, 100, false, false);
    testThreshold(1000, 100, false, false);
  }

    /**
     * Create new RDMA negotiation request
     */
    public RdmaNegotiateRequest() {
        // Initialize with default values
        this.minVersion = 0x0100; // SMB Direct 1.0
        this.maxVersion = 0x0100; // SMB Direct 1.0
        this.creditsRequested = RdmaCapabilities.DEFAULT_SEND_CREDIT_TARGET;
        this.preferredSendSize = RdmaCapabilities.DEFAULT_MAX_RECEIVE_SIZE;

        def gradleVersion = GradleVersion.version("9.2")
        def allVersions = [
            "7.8.0",
            "8.9.0-alpha01", "8.9.0-beta01", "8.9.0-rc01", "8.9.0", "8.9.1",
            "8.10.0-alpha01", "8.10.0-beta01", "8.10.0-rc01", "8.10.0", "8.10.1",
            "8.11.0-alpha01", "8.11.0-beta01", "8.11.0-rc01",
            "8.12.0-alpha01", "8.12.0-beta01",
            "8.13.0-alpha01",
            "9.0.0-alpha11"
        ].shuffled()