/**
* Copyright 2010-2023 JogAmp Community. All rights reserved.
*
* Redistribution and use in source and binary forms, with or without modification, are
* permitted provided that the following conditions are met:
*
* 1. Redistributions of source code must retain the above copyright notice, this list of
* conditions and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright notice, this list
* of conditions and the following disclaimer in the documentation and/or other materials
* provided with the distribution.
*
* THIS SOFTWARE IS PROVIDED BY JogAmp Community ``AS IS'' AND ANY EXPRESS OR IMPLIED
* WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
* FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL JogAmp Community OR
* CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR
* SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON
* ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
* NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
* ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
*
* The views and conclusions contained in the software and documentation are those of the
* authors and should not be interpreted as representing official policies, either expressed
* or implied, of JogAmp Community.
*/
package com.jogamp.common.nio;
import java.nio.ByteBuffer;
/**
* Hardware independent container holding an array of linearly aligned elements,
* while its {@link #getDirectBufferAddress()} is-a pointer-type value, i.e. the element-array address.
*
* An instance maps an array of linearly aligned elements, represented as bytes.
*
*/
public class ElementBuffer extends AbstractBuffer {
/** supports backup array */
ElementBuffer(final int elementSize, final ByteBuffer b) {
super(b, elementSize, b.capacity()/elementSize);
}
/** Returns a non direct PointerBuffer in native order, having a backup array */
public static ElementBuffer allocate(final int elementSize, final int elementCount) {
return new ElementBuffer(elementSize, ByteBuffer.allocate(elementCount * elementSize));
}
/** Returns a direct PointerBuffer in native order, w/o backup array */
public static ElementBuffer allocateDirect(final int elementSize, final int elementCount) {
return new ElementBuffer(elementSize, Buffers.newDirectByteBuffer(elementCount * elementSize));
}
public static ElementBuffer wrap(final int elementSize, final ByteBuffer src) {
return new ElementBuffer(elementSize, src);
}
public static ElementBuffer wrap(final int elementSize, final int elementCount, final ByteBuffer src, final int srcByteOffset) {
final int oldPos = src.position();
final int oldLimit = src.limit();
src.position(srcByteOffset);
src.limit(srcByteOffset + ( elementSize * elementCount ));
final ElementBuffer r = new ElementBuffer(elementSize, src.slice().order(src.order())); // slice and duplicate may change byte order
src.position(oldPos);
src.limit(oldLimit);
return r;
}
public static ElementBuffer derefPointer(final int elementSize, final int elementCount, final long aptr) {
if( 0 == aptr ) {
throw new NullPointerException("aptr is null");
}
final ByteBuffer bb = Buffers.getDirectByteBuffer(aptr, elementCount * elementSize);
if( null == bb ) {
throw new InternalError("Couldn't dereference aptr 0x"+Long.toHexString(aptr)+", size "+elementCount+" * "+elementSize);
}
return new ElementBuffer(elementSize, bb);
}
public static ElementBuffer derefPointer(final int elementSize, final int elementCount, final ByteBuffer ptrSrc, final int ptrSrcByteOffset) {
return derefPointer(elementSize, elementCount, PointerBuffer.wrap(ptrSrc, ptrSrcByteOffset, 1).get(0));
}
@Override
public final ElementBuffer put(final ElementBuffer src) {
if (remaining() < src.remaining()) {
throw new IndexOutOfBoundsException("remaining[this "+remaining()+" < src "+src.remaining()+"], this "+this+", src "+src);
}
if( this.elementSize() != src.elementSize() ) {
throw new IllegalArgumentException("Element-Size mismatch source "+src+", dest "+this);
}
final ByteBuffer tmp = ByteBuffer.allocate(elementSize);
while (src.hasRemaining()) {
put( src.get(tmp) );
}
return this;
}
/** Returns the ByteBuffer, i.e. {@link #getBuffer()} w/o casting. */
public final ByteBuffer getByteBuffer() {
return (ByteBuffer) buffer;
}
/**
* Returns a slice of this instance's ByteBuffer `[offset..offset+length)`, i.e. referencing the underlying bytes.
* @param offset starting element-index within this buffer
* @param length element count
* @return slice of this instance's ByteBuffer
*/
public final ByteBuffer slice(final int offset, final int length) {
if (0 > offset || offset + length > capacity) {
throw new IndexOutOfBoundsException("idx "+offset+" + elementCount "+length+" not within [0.."+capacity+"), "+this);
}
final ByteBuffer src = (ByteBuffer)buffer;
final int oldPos = src.position();
final int oldLimit = src.limit();
src.position(elementSize*offset);
src.limit(elementSize * (offset + length));
final ByteBuffer ref = src.slice().order(src.order()); // slice and duplicate may change byte order
src.position(oldPos);
src.limit(oldLimit);
return ref;
}
/** Absolute get method. Copy the element-bytes at the given index, storing them into `destElemBytes`. */
public final ByteBuffer get(final int idx, final ByteBuffer destElemBytes) {
if (0 > idx || idx >= capacity) {
throw new IndexOutOfBoundsException("idx "+idx+" not within [0.."+capacity+"), "+this);
}
final ByteBuffer bBuffer = (ByteBuffer)buffer;
for(int i=0; i [ position .. position+length [
* to the destination array [ destElements[offset] .. destElements[offset+length] [
* and increment the position by length
. */
public final ElementBuffer get(final ByteBuffer[] destElements, int offset, int length) {
if (destElements.length0) {
get(position++, destElements[offset++]);
length--;
}
return this;
}
/** Absolute put method. Put the element-bytes at the given element-index */
public final ElementBuffer put(final int idx, final ByteBuffer srcElemBytes) {
if (0 > idx || idx >= capacity) {
throw new IndexOutOfBoundsException("idx "+idx+" not within [0.."+capacity+"), "+this);
}
final ByteBuffer bBuffer = (ByteBuffer)buffer;
for(int i=0; i [ srcElements[offset] .. srcElements[offset+length] [
* at the current position and increment the position by length
. */
public final ElementBuffer put(final ByteBuffer[] srcElements, int offset, int length) {
if (srcElements.length0) {
put(position++, srcElements[offset++]);
length--;
}
return this;
}
@Override
public String toString() {
return "ElementBuffer"+toSubString();
}
}