import { AL_MASK, MAX_SIZE_32 } from "./allocator"; /** Size of an ArrayBuffer header. */ export const HEADER_SIZE: usize = (offsetof() + AL_MASK) & ~AL_MASK; /** Maximum byte length of an ArrayBuffer. */ export const MAX_BLENGTH: i32 = MAX_SIZE_32 - HEADER_SIZE; /** Computes an ArrayBuffer's size in memory. */ export function computeSize(byteLength: i32): usize { // round up to power of 2, with HEADER_SIZE=8: // 0 -> 2^3 = 8 // 1..8 -> 2^4 = 16 // 9..24 -> 2^5 = 32 // ... // MAX_LENGTH -> 2^30 = 0x40000000 (MAX_SIZE_32) return 1 << (32 - clz(byteLength + HEADER_SIZE - 1)); } /** Allocates a raw ArrayBuffer. Contents remain uninitialized. */ export function allocUnsafe(byteLength: i32): ArrayBuffer { assert(byteLength <= MAX_BLENGTH); var buffer = memory.allocate(computeSize(byteLength)); store(buffer, byteLength, offsetof("byteLength")); return changetype(buffer); } /** Reallocates an ArrayBuffer, resizing it as requested. Tries to modify the buffer in place. */ export function reallocUnsafe(buffer: ArrayBuffer, newByteLength: i32): ArrayBuffer { var oldByteLength = buffer.byteLength; if (newByteLength > oldByteLength) { assert(newByteLength <= MAX_BLENGTH); if (newByteLength <= (computeSize(oldByteLength) - HEADER_SIZE)) { // fast path: zero out additional space store(changetype(buffer), newByteLength, offsetof("byteLength")); memory.fill( changetype(buffer) + HEADER_SIZE + oldByteLength, 0, (newByteLength - oldByteLength) ); } else { // slow path: copy to new buffer let newBuffer = allocUnsafe(newByteLength); memory.copy( changetype(newBuffer) + HEADER_SIZE, changetype(buffer) + HEADER_SIZE, oldByteLength ); memory.fill( changetype(newBuffer) + HEADER_SIZE + oldByteLength, 0, (newByteLength - oldByteLength) ); return newBuffer; } } else if (newByteLength < oldByteLength) { // fast path: override size // TBD: worth to copy and release if size is significantly less than before? assert(newByteLength >= 0); store(changetype(buffer), newByteLength, offsetof("byteLength")); } return buffer; } @inline export function loadUnsafe(buffer: ArrayBuffer, index: i32): V { return load(changetype(buffer) + (index << alignof()), HEADER_SIZE); } @inline export function storeUnsafe(buffer: ArrayBuffer, index: i32, value: V): void { store(changetype(buffer) + (index << alignof()), value, HEADER_SIZE); } @inline export function loadUnsafeWithOffset(buffer: ArrayBuffer, index: i32, byteOffset: i32): V { return load(changetype(buffer) + byteOffset + (index << alignof()), HEADER_SIZE); } @inline export function storeUnsafeWithOffset(buffer: ArrayBuffer, index: i32, value: V, byteOffset: i32): void { store(changetype(buffer) + byteOffset + (index << alignof()), value, HEADER_SIZE); }