providermessage.java

High performance DB query

/*
 * @(#)$Id: ProviderMessage.java,v 1.8 2004/07/02 23:59:20 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.provider.basic;

import services.network.Payload;
import util.BitID;
import util.network.serialization.GenericByteBuffer;
import util.network.serialization.SerializationManager;
import util.network.serialization.SerializeString;

/**
 * Class ProviderMessage
 *
 */
public class ProviderMessage implements Payload {

    public static long serialVersionUID =
        SerializationManager.getSerialUID(
            "overlay.provider.basic.ProviderMessage");

    // the message ID (unique along with sender)
    protected Integer messageID;

    // the namespace of the item
    protected String ns;

    // the resource ID of the item
    protected String rid;

    // the location id for this object, used only for performance of simulator
    protected BitID locationID;

    // store the size so it only is calculated once
    protected int size;

    /**
     * DeSerialize the object from the provided GenericByteBuffer.
     *
     * @param inputBuffer
     */
    public ProviderMessage(GenericByteBuffer inputBuffer) {
        this.messageID = new Integer(inputBuffer.getInt());
        this.ns = SerializeString.deSerialize(inputBuffer);
        this.rid = SerializeString.deSerialize(inputBuffer);
        this.locationID = new BitID(inputBuffer);
        this.size = 1 + Payload.INT_SIZE + ns.length() + rid.length();
    }

    /**
     * Serialize the object into the provided GenericByteBuffer.
     *
     * @param outputBuffer
     * @return
     */
    public long serialize(GenericByteBuffer outputBuffer) {
        outputBuffer.putInt(messageID.intValue());
        SerializeString.serialize(outputBuffer, ns);
        SerializeString.serialize(outputBuffer, rid);
        locationID.serialize(outputBuffer);

        return serialVersionUID;
    }

    /**
     * Constructor ProviderMessage
     */
    protected ProviderMessage() {}

    /**
     * Method init
     *
     * @param messageID
     * @param ns
     * @param rid
     * @param locationID
     */
    protected void init(Integer messageID, String ns, String rid,
                        BitID locationID) {
        this.messageID = messageID;
        this.ns = ns;
        this.rid = rid;
        this.locationID = locationID;

        // set the size
        size = 1 + Payload.INT_SIZE + ns.length() + rid.length();
    }

    /**
     * Method getSize
     * @return
     */
    public int getSize() {
        return size;
    }

    /**
     * Method getID
     * @return
     */
    public Integer getID() {
        return messageID;
    }

    /**
     * Method getNS
     * @return
     */
    public String getNS() {
        return ns;
    }

    /**
     * Method getRID
     * @return
     */
    public String getRID() {
        return rid;
    }

    /**
     * Method getLocationID
     * @return
     */
    public BitID getLocationID() {
        return locationID;
    }
}