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

Go to the documentation of this file.

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

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

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

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

public class IntString extends Value {

        public static final int NATIVE_TYPE_ID = 251;
        
        private static final int OFFSET_E2 = Value.SIZEOF_INT;
        
        private static final int SIZEOF_STRING_SIZE = Value.SIZEOF_SHORT;
        
        public IntString() {
                e2 = new String();
        }
        
        public IntString(int e1, String e2) {
                set(e1, e2);
        }
        
        public IntString(IntString value) {
                set(value.e1, value.e2);
        }
        
        public int getE1() {
                return e1;
        }

        public void setE1(int e1) {
                this.e1 = e1;
        }

        public String getE2() {
                return e2;
        }

        public void setE2(String e2) {
                A.CHECK_NOT_NULL(e2);
                this.e2 = e2;
        }
        
        public void set(int e1, String e2) {
                setE1(e1);
                setE2(e2);
        }

        @Override
        public void copyFrom(Pointer buffer) {
                e1 = buffer.getInt(0);
                short stringSize = buffer.getShort(OFFSET_E2);
                e2 = Native.toString(buffer.getByteArray(
                                OFFSET_E2 + SIZEOF_STRING_SIZE, stringSize));
        }

        @Override
        public void copyTo(Pointer buffer) {
                buffer.setInt(0, e1);
                byte[] bytes = Native.toByteArray(e2);
                A.CHECK(bytes.length <= Short.MAX_VALUE, "Too long string");
                buffer.setShort(OFFSET_E2, (short) bytes.length);
                buffer.write(OFFSET_E2 + SIZEOF_STRING_SIZE, bytes, 0, bytes.length);
        }

        @Override
        public boolean parseFrom(Scanner sc) {
                if (sc.hasNextInt()) e1 = sc.nextInt();
                else return false;
                if (sc.hasNext()) e2 = sc.next();
                else return false;
                return true;
        }
        
        @Override
        public PrintStream printTo(PrintStream stream) {
                A.CHECK(e2.indexOf('\t') == -1, "No tabulator allowed in string");
                stream.print(e1);
                stream.print(DELIMITER_C);
                stream.print(e2);
                return stream;
        }

        @Override
        public Memory getSharedMemory() {
                return new Memory(getSerializedSize());
        }
        
        @Override
        public int getSerializedSize() {
                return OFFSET_E2 + SIZEOF_STRING_SIZE + Native.toByteArray(e2).length;
        }
        
        @Override
        public int hashCode() {
                final int prime = 31;
                int result = 1;
                result = prime * result + e1;
                result = prime * result + ((e2 == null) ? 0 : e2.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;
                IntString other = (IntString) obj;
                if (e1 != other.e1)
                        return false;
                if (e2 == null) {
                        if (other.e2 != null)
                                return false;
                } else if (!e2.equals(other.e2))
                        return false;
                return true;
        }

        private int    e1;
        private String e2;
}

---