/home/palakars/workspace-inprogress/code-in-progress/aitools3/aitools3-aq-invertedindex2-java/src/de/aitools/aq/value/single/SingleBuffer.java

Go to the documentation of this file.

// Copyright (C) 2011 webis.de. All rights reserved.
package de.aitools.aq.value.single;

import java.io.PrintStream;
import java.nio.ByteBuffer;
import java.util.Scanner;

import com.sun.jna.Memory;
import com.sun.jna.Pointer;

import de.aitools.aq.check.A;
import de.aitools.aq.value.Value;

public class SingleBuffer extends Value {

        public static final int NATIVE_TYPE_ID = 104;
        
        private static final int SIZEOF_BUFFER_SIZE = Value.SIZEOF_SHORT;
        
        public SingleBuffer() {
                reallocate(0);
        }
        
        public SingleBuffer(byte[] bytes) {
                A.CHECK_NOT_NULL(bytes);
                e = ByteBuffer.wrap(bytes);
        }
        
        public SingleBuffer(SingleBuffer array) {
                e = array.e;
        }
        
        public SingleBuffer(ByteBuffer buffer) {
                A.CHECK_NOT_NULL(buffer);
                e = buffer;
        }
        
        public SingleBuffer(int capacity) {
                reallocate(capacity);
        }
        
        public ByteBuffer getBuffer() {
                return e;
        }
        
        public void setBuffer(ByteBuffer buffer) {
                A.CHECK_NOT_NULL(buffer);
                e = buffer;
        }
        
        @Override
        public void copyFrom(Pointer buffer) {
                short arraySize = buffer.getShort(0);
                // do not use Pointer.getByteBuffer, b/c it does not return a copy
                e = ByteBuffer.wrap(buffer.getByteArray(SIZEOF_BUFFER_SIZE, arraySize));
        }

        @Override
        public void copyTo(Pointer buffer) {
                A.CHECK(e.capacity() <= Short.MAX_VALUE, "Too long byte array");
                buffer.setShort(0, (short) e.capacity());
                buffer.write(SIZEOF_BUFFER_SIZE, e.array(), 0, e.capacity());
        }

        @Override
        public boolean parseFrom(Scanner sc) {
                throw new UnsupportedOperationException("Cannot parse raw byte array");
        }
        
        @Override
        public PrintStream printTo(PrintStream stream) {
                throw new UnsupportedOperationException("Cannot print raw byte array");
        }

        @Override
        public Memory getSharedMemory() {
                return new Memory(getSerializedSize());
        }

        @Override
        public int getSerializedSize() {
                return SIZEOF_BUFFER_SIZE + e.capacity();
        }
        
        @Override
        public int hashCode() {
                final int prime = 31;
                int result = 1;
                result = prime * result + ((e == null) ? 0 : e.hashCode());
                return result;
        }

        @Override
        public boolean equals(Object obj) {
                if (this == obj)
                        return true;
                if (obj == null)
                        return false;
                if (getClass() != obj.getClass())
                        return false;
                SingleBuffer other = (SingleBuffer) obj;
                if (e == null) {
                        if (other.e != null)
                                return false;
                } else if (!e.equals(other.e))
                        return false;
                return true;
        }

        public void reallocate(int capacity) {
                // do not use ByteBuffer.allocateDirect here
                e = ByteBuffer.allocate(capacity);
        }

        private ByteBuffer e;
}

---