* must be handed-off so as to preserve the immutability contract of {@code HashCode}.
   */
  static HashCode fromBytesNoCopy(byte[] bytes) {
    return new BytesHashCode(bytes);
  }

  private static final class BytesHashCode extends HashCode implements Serializable {
    final byte[] bytes;

    BytesHashCode(byte[] bytes) {

     *
     * @param bytes number of bytes written
     * @param durationNanos operation duration in nanoseconds
     */
    public void recordRdmaWrite(int bytes, long durationNanos) {
        rdmaWrites.incrementAndGet();
        bytesTransferred.addAndGet(bytes);
        totalWriteTime.addAndGet(durationNanos);
    }

    /**
     * Record an RDMA send operation
     *
     * @param bytes number of bytes sent

}

// Bytes provides a byte slice that can be serialized.
type Bytes []byte

// UnmarshalMsg deserializes b from the provided byte slice and returns the
// remainder of bytes.
func (b *Bytes) UnmarshalMsg(bytes []byte) ([]byte, error) {
	if b == nil {
		return bytes, errors.New("Bytes: UnmarshalMsg on nil pointer")
	}
	if bytes, err := msgp.ReadNilBytes(bytes); err == nil {
		if *b != nil {
			PutByteBuffer(*b)

        
        // StructureSize (2 bytes)
        structureSize = readInt2(buffer, offset);
        offset += 2;
        
        // Reserved (2 bytes)
        offset += 2;
        
        // Flags (4 bytes)
        flags = readInt4(buffer, offset);
        offset += 4;
        
        // LeaseKey (16 bytes)
        byte[] keyBytes = new byte[16];

            this.setupBytesWritten = bytes;
        }

        void setParameterBytesWritten(int bytes) {
            this.parameterBytesWritten = bytes;
        }

        void setDataBytesWritten(int bytes) {
            this.dataBytesWritten = bytes;
        }
    }

    @BeforeEach
    void setUp() {
        transaction = new TestSmbComTransaction();

  }

  MessageDigestHashFunction(String algorithmName, int bytes, String toString) {
    this.toString = checkNotNull(toString);
    this.prototype = getMessageDigest(algorithmName);
    int maxLength = prototype.getDigestLength();
    checkArgument(
        bytes >= 4 && bytes <= maxLength, "bytes (%s) must be >= 4 and < %s", bytes, maxLength);
    this.bytes = bytes;
    this.supportsClone = supportsClone(prototype);
  }

    }

    /**
     * Create a handle GUID from existing bytes
     * @param bytes the 16-byte GUID data in little-endian format (SMB wire format)
     */
    public HandleGuid(byte[] bytes) {
        if (bytes.length != 16) {
            throw new IllegalArgumentException("GUID must be 16 bytes");
        }

        // MS-SMB2 specifies little-endian byte ordering for GUID components

  internal const val OPCODE_FLAG_CONTROL = 8

  /**
   * Byte 1 flag for whether the payload data is masked.
   *
   * If this flag is set, the next four
   * bytes represent the mask key. These bytes appear after any additional bytes specified by [B1_MASK_LENGTH].
   */
  internal const val B1_FLAG_MASK = 128

  /**
   * Byte 1 mask for the payload length.
   *
   * If this value is [PAYLOAD_SHORT], the next two

                "Raw bytes for empty string should be empty");

        byte[] emptyBytes = new byte[0];
        AvTargetName avTargetNameFromBytes = new AvTargetName(emptyBytes);
        assertEquals(emptyString, avTargetNameFromBytes.getTargetName(),
                "Empty string should be handled correctly from raw bytes constructor");

app = FastAPI()

# =====================================================================================
# Without aliases


@app.post("/optional-bytes", operation_id="optional_bytes")
async def read_optional_bytes(p: Annotated[bytes | None, File()] = None):
    return {"file_size": len(p) if p else None}


@app.post("/optional-uploadfile", operation_id="optional_uploadfile")