networkmessageemulator.ucjava

High performance DB query

/*
 * @(#)$Id: NetworkMessageEmulator.ucjava,v 1.7 2005/04/27 20:56:38 huebsch Exp $
 *
 * Copyright (c) 2001-2004 Regents of the University of California.
 * All rights reserved.
 *
 * This file is distributed under the terms in the attached BERKELEY-LICENSE
 * file. If you do not find these files, copies can be found by writing to:
 * Computer Science Division, Database Group, Universite of California,
 * 617 Soda Hall #1776, Berkeley, CA 94720-1776. Attention: Berkeley License
 *
 * Copyright (c) 2003-2004 Intel Corporation. All rights reserved.
 *
 * This file is distributed under the terms in the attached INTEL-LICENSE file.
 * If you do not find these files, copies can be found by writing to:
 * Intel Research Berkeley, 2150 Shattuck Avenue, Suite 1300,
 * Berkeley, CA, 94704.  Attention:  Intel License Inquiry.
 */


package overlay.location.bamboo;

import java.nio.ByteBuffer;
import bamboo.lss.NioOutputBuffer;
import bamboo.lss.NioInputBuffer;
import ostore.util.CountBuffer;
import ostore.util.OutputBuffer;
import ostore.util.InputBuffer;
import ostore.util.QuickSerializable;
import ostore.util.QSException;
import services.network.Payload;
import util.network.serialization.DataByteBuffer;
import util.network.serialization.SerializationManager;

/**
 * Class NetworkMessageEmulator
 *
 */
public class NetworkMessageEmulator implements QuickSerializable {

    private Payload item;
    private static ByteBuffer temp;

    /**
     * Constructor NetworkMessageEmulator
     *
     * @param item
     */
    public NetworkMessageEmulator(Payload item) {
        this.item = item;
    }

    /**
     * Method getItem
     * @return
     */
    public Payload getItem() {
        return item;
    }

    /**
     * Method serialize
     *
     * @param outputBuffer
     */
    public void serialize(OutputBuffer outputBuffer) {
        if (outputBuffer instanceof NioOutputBuffer) {
            SerializationManager.serialize(
                new DataByteBuffer(((NioOutputBuffer) outputBuffer).bb), item);
        } else {
            if (outputBuffer instanceof CountBuffer) {
                outputBuffer.add(
                    new byte[SerializationManager.getPayloadSize(item)]);
            } else {
                throw new RuntimeException(
                    "Unable to serialize, incompatible output buffer:"
                    + outputBuffer.getClass().getName());
            }
        }
    }

    /**
     * Constructor NetworkMessageEmulator
     *
     * @param buffer
     * @throws QSException
     */
    public NetworkMessageEmulator(InputBuffer buffer) throws QSException {
        if (buffer instanceof NioInputBuffer) {
            item = SerializationManager.deSerialize(
                new DataByteBuffer(((NioInputBuffer) buffer).bb));
        } else {
            throw new RuntimeException(
                "Unable to serialize, incompatible input buffer:"
                + buffer.getClass().getName());
        }
    }

    /**
     * Method toString
     * @return
     */
    public String toString() {
        return "<NetworkMessageEmulator: Emulating: " + item + ">";
    }
}