/*
 * $Id: DHTTransport.java 4259 2012-10-21 10:20:37Z kredel $
 */

package edu.jas.util;


import java.io.Serializable;
import java.io.IOException;
import java.rmi.MarshalledObject;


/**
 * Transport container for a distributed version of a HashTable. 
 * <b>Note:</b> Contains code for timing of marshalled versus plain 
 * object serialization which can be removed later.
 * @author Heinz Kredel
 */

public abstract class DHTTransport<K, V> implements Serializable {


    static long etime  = 0L; // encode marshalled
    static long dtime  = 0L; // decode marshalled
    static long ertime = 0L; // encode plain raw
    static long drtime = 0L; // decode plain raw


    public static enum Stor { // storage and transport class
        marshal, plain
    };


    public static final Stor stor = Stor.marshal; //Stor.plain; 


    /**
     * protected constructor.
     */
    protected DHTTransport() {
    }


    /**
     * Create a new DHTTransport Container.
     * @param key
     * @param value
     */
    public static <K,V> DHTTransport<K,V> create(K key, V value) throws IOException {
        switch (stor) {
        case marshal: return new DHTTransportMarshal<K,V>(key,value);
        case plain:   return new DHTTransportPlain<K,V>(key,value);
        default: throw new IllegalArgumentException("this should not happen");
        }
    }


    /**
     * Get the key from this DHTTransport Container.
     */
    public abstract K key() throws IOException, ClassNotFoundException;


    /**
     * Get the value from this DHTTransport Container.
     */
    public abstract V value() throws IOException, ClassNotFoundException;


    /**
     * toString.
     */
    @Override
    public String toString() {
        return this.getClass().getName();

    }

}


/**
 * Transport container to signal termination for a distributed version
 * of a HashTable. Contains no objects.
 * @author Heinz Kredel
 */

class DHTTransportTerminate<K, V> extends DHTTransport<K, V> {

    /**
     * Get the key from this DHTTransport Container.
     */
    public K key() throws IOException, ClassNotFoundException {
        throw new UnsupportedOperationException("this should not happen");
    }


    /**
     * Get the value from this DHTTransport Container.
     */
    public V value() throws IOException, ClassNotFoundException {
        throw new UnsupportedOperationException("this should not happen");
    }

}


/**
 * Transport container for a distributed version of a HashTable. Immutable
 * objects. Uses MarshalledObject to avoid deserialization on server side.
 * @author Heinz Kredel
 */

class DHTTransportMarshal<K, V> extends DHTTransport<K, V> {


    protected final MarshalledObject/*<K>*/ key;


    protected final MarshalledObject/*<V>*/ value;


    /**
     * Constructs a new DHTTransport Container.
     * @param key
     * @param value
     */
    public DHTTransportMarshal(K key, V value) throws IOException {
        long t = System.currentTimeMillis();
        this.key = new MarshalledObject/*<K>*/(key);
        this.value = new MarshalledObject/*<V>*/(value);
        t = System.currentTimeMillis() - t;
        synchronized( DHTTransport.class ) {
            etime += t;
        }
        //System.out.println("         marshal time = " + t);
    }


    /**
     * Get the key from this DHTTransport Container.
     */
    public K key() throws IOException, ClassNotFoundException {
        long t = System.currentTimeMillis();
        K k = (K) this.key.get();
        t = System.currentTimeMillis() - t;
        synchronized( DHTTransport.class ) {
            dtime += t;
        }
        return k;
    }


    /**
     * Get the value from this DHTTransport Container.
     */
    public V value() throws IOException, ClassNotFoundException {
        long t = System.currentTimeMillis();
        V v = (V) this.value.get();
        t = System.currentTimeMillis() - t;
        synchronized( DHTTransport.class ) {
            dtime += t;
        }
        return v;
    }


    /**
     * toString.
     */
    @Override
    public String toString() {
        return super.toString() + "(" + key + "," + value + ")";
    }


    private void writeObject(java.io.ObjectOutputStream out) throws IOException {
        long t = System.currentTimeMillis();
        out.defaultWriteObject();
        t = System.currentTimeMillis() - t;
        synchronized( DHTTransport.class ) {
            ertime += t;
        }
    }

    private void readObject(java.io.ObjectInputStream in) throws IOException, ClassNotFoundException {
        long t = System.currentTimeMillis();
        in.defaultReadObject();
        t = System.currentTimeMillis() - t; // not meaningful, includes waiting time
        synchronized( DHTTransport.class ) {
            drtime += t;
        }
    }

}


/**
 * Transport container for a distributed version of a HashTable. Immutable
 * objects. Uses plain objects.
 * @author Heinz Kredel
 */

class DHTTransportPlain<K, V> extends DHTTransport<K, V> {


    protected final K key;


    protected final V value;


    /**
     * Constructs a new DHTTransport Container.
     * @param key
     * @param value
     */
    public DHTTransportPlain(K key, V value) throws IOException {
        this.key = key;
        this.value = value;
    }


    /**
     * Get the key from this DHTTransport Container.
     */
    public K key() throws IOException, ClassNotFoundException {
        return this.key;
    }


    /**
     * Get the value from this DHTTransport Container.
     */
    public V value() throws IOException, ClassNotFoundException {
        return this.value;
    }


    /**
     * toString.
     */
    @Override
    public String toString() {
        return super.toString() + "(" + key + "," + value + ")";
    }


    private void writeObject(java.io.ObjectOutputStream out) throws IOException {
        long t = System.currentTimeMillis();
        out.defaultWriteObject();
        t = System.currentTimeMillis() - t;
        synchronized( DHTTransport.class ) {
            ertime += t;
        }
    }

    private void readObject(java.io.ObjectInputStream in) throws IOException, ClassNotFoundException {
        long t = System.currentTimeMillis();
        in.defaultReadObject();
        t = System.currentTimeMillis() - t;
        synchronized( DHTTransport.class ) {
            drtime += t;
        }
    }

}