assertEquals("FFFE807F", Hexdump.toHexString(data2, 0, 8)); // 8 chars = 4 bytes

        // Test odd size (should handle correctly)
        byte[] data3 = { 0x0A, 0x0B, 0x0C };
        assertEquals("0", Hexdump.toHexString(data3, 0, 1)); // 1 char = 0.5 bytes (rounds up to 1)
        assertEquals("0A", Hexdump.toHexString(data3, 0, 2)); // 2 chars = 1 byte

	return
}

// EncodeMsg implements msgp.Encodable
func (z *BatchKeyRotateFilter) EncodeMsg(en *msgp.Writer) (err error) {
	// map header, size 7
	// write "NewerThan"
	err = en.Append(0x87, 0xa9, 0x4e, 0x65, 0x77, 0x65, 0x72, 0x54, 0x68, 0x61, 0x6e)
	if err != nil {
		return
	}
	err = en.WriteDuration(z.NewerThan)
	if err != nil {
		err = msgp.WrapError(err, "NewerThan")
		return
	}
	// write "OlderThan"

		return
	}
	err = en.WriteBytes(z.ReplicationConfigXML)
	if err != nil {
		err = msgp.WrapError(err, "ReplicationConfigXML")
		return
	}
	// write "BucketTargetsConfigJSON"
	err = en.Append(0xb7, 0x42, 0x75, 0x63, 0x6b, 0x65, 0x74, 0x54, 0x61, 0x72, 0x67, 0x65, 0x74, 0x73, 0x43, 0x6f, 0x6e, 0x66, 0x69, 0x67, 0x4a, 0x53, 0x4f, 0x4e)
	if err != nil {
		return
	}
	err = en.WriteBytes(z.BucketTargetsConfigJSON)

        key8[1] = (byte) (((key7[0] & 0x01) << 6 | (key7[1] & 0xff) >> 2 & 0xff) & 0xff);
        key8[2] = (byte) (((key7[1] & 0x03) << 5 | (key7[2] & 0xff) >> 3 & 0xff) & 0xff);
        key8[3] = (byte) (((key7[2] & 0x07) << 4 | (key7[3] & 0xff) >> 4 & 0xff) & 0xff);
        key8[4] = (byte) (((key7[3] & 0x0F) << 3 | (key7[4] & 0xff) >> 5 & 0xff) & 0xff);
        key8[5] = (byte) (((key7[4] & 0x1F) << 2 | (key7[5] & 0xff) >> 6 & 0xff) & 0xff);

    
    // Common combinations
    public static final int SMB2_LEASE_READ_HANDLE    = 0x03;  // RH
    public static final int SMB2_LEASE_READ_WRITE     = 0x05;  // RW
    public static final int SMB2_LEASE_FULL           = 0x07;  // RWH
}
```

### 3.2 Lease Versions
- **Lease V1**: Basic lease support (SMB 3.0)
- **Lease V2**: Adds epoch support for better consistency (SMB 3.0.2+)

## 4. Data Structures

		return
	}
	err = en.WriteString(z.Endpoint)
	if err != nil {
		err = msgp.WrapError(err, "Endpoint")
		return
	}
	// write "TotalDowntime"
	err = en.Append(0xad, 0x54, 0x6f, 0x74, 0x61, 0x6c, 0x44, 0x6f, 0x77, 0x6e, 0x74, 0x69, 0x6d, 0x65)
	if err != nil {
		return
	}
	err = en.WriteDuration(z.TotalDowntime)
	if err != nil {
		err = msgp.WrapError(err, "TotalDowntime")
		return
	}
	// write "LastOnline"

	o = msgp.AppendBool(o, z.dependGlobalObjectAPI)
	// string "dependGlobalAuthNPlugin"
	o = append(o, 0xb7, 0x64, 0x65, 0x70, 0x65, 0x6e, 0x64, 0x47, 0x6c, 0x6f, 0x62, 0x61, 0x6c, 0x41, 0x75, 0x74, 0x68, 0x4e, 0x50, 0x6c, 0x75, 0x67, 0x69, 0x6e)
	o = msgp.AppendBool(o, z.dependGlobalAuthNPlugin)
	// string "dependGlobalSiteReplicationSys"

		err = msgp.WrapError(err, "BandWidthLimitInBytesPerSecond")
		return
	}
	// write "CurrentBandwidthInBytesPerSecond"
	err = en.Append(0xd9, 0x20, 0x43, 0x75, 0x72, 0x72, 0x65, 0x6e, 0x74, 0x42, 0x61, 0x6e, 0x64, 0x77, 0x69, 0x64, 0x74, 0x68, 0x49, 0x6e, 0x42, 0x79, 0x74, 0x65, 0x73, 0x50, 0x65, 0x72, 0x53, 0x65, 0x63, 0x6f, 0x6e, 0x64)
	if err != nil {
		return
	}
	err = en.WriteFloat64(z.CurrentBandwidthInBytesPerSecond)

            b[off] = 0x01;
            b[off + 1] = 0x02;
            b[off + 2] = 0x03;
            b[off + 3] = 0x04;
            b[off + 4] = 0x05;
            b[off + 5] = 0x06;
            b[off + 6] = 0x07;
            b[off + 7] = 0x08;
            return 8;
        }).when(raf).read(any(byte[].class), anyInt(), eq(8));
        assertEquals(0x0102030405060708L, raf.readLong());

        // float 1.0f -> 0x3F800000

            samr.SamrOpenDomain message = new samr.SamrOpenDomain(mockPolicyHandle, 123, mockSidT, mockPolicyHandle);

            // Then: Should have correct values
            assertEquals(0x07, message.getOpnum());
            assertEquals(mockPolicyHandle, message.handle);
            assertEquals(123, message.access_mask);
            assertEquals(mockSidT, message.sid);