High performance DB query
源代码在线查看: lookup.java
/* * @(#)$Id: Lookup.java,v 1.9 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.location.chord.payload; import java.net.InetSocketAddress; import services.network.Payload; import util.BitID; import util.FreeList; import util.FreeListFactory; import util.network.serialization.GenericByteBuffer; import util.network.serialization.SerializationManager; /** * Class Lookup * */ public class Lookup extends ChordMessage { public static long serialVersionUID = SerializationManager.getSerialUID( "overlay.location.chord.payload.Lookup"); private BitID searchID; private long applicationID; private static FreeList freeList = new FreeList(new LookupFactory()); /** * DeSerialize the object from the provided GenericByteBuffer. * * @param inputBuffer */ public Lookup(GenericByteBuffer inputBuffer) { super(inputBuffer); this.searchID = new BitID(inputBuffer); this.applicationID = inputBuffer.getLong(); } /** * Serialize the object into the provided GenericByteBuffer. * * @param outputBuffer * @return */ public long serialize(GenericByteBuffer outputBuffer) { super.serialize(outputBuffer); searchID.serialize(outputBuffer); outputBuffer.putLong(applicationID); return serialVersionUID; } /** * Constructor Lookup */ protected Lookup() {} private void init(int messageID, InetSocketAddress sourceSocketAddress, BitID searchID, long applicationID) { super.init(messageID, sourceSocketAddress); this.searchID = searchID; this.applicationID = applicationID; } /** * Method getSize * @return */ public int getSize() { return super.getSize() + searchID.getSize() + Payload.LONG_SIZE; } /** * Method getSearchID * @return */ public BitID getSearchID() { return searchID; } /** * Method getApplicationID * @return */ public long getApplicationID() { return applicationID; } /** * Method allocate * * @param messageID * @param sourceSocketAddress * @param searchID * @param applicationID * @return */ public static Lookup allocate(int messageID, InetSocketAddress sourceSocketAddress, BitID searchID, long applicationID) { Lookup message = (Lookup) freeList.allocate(); message.init(messageID, sourceSocketAddress, searchID, applicationID); return message; } /** * Method allocate * * @param oldMessage * @return */ public static Lookup allocate(Lookup oldMessage) { Lookup message = (Lookup) freeList.allocate(); message.init(oldMessage.messageID, oldMessage.sourceSocketAddress, oldMessage.searchID, oldMessage.applicationID); return message; } /** * Method free * * @param message */ public static void free(Lookup message) { freeList.free(message); } } /** * Class LookupFactory * */ class LookupFactory implements FreeListFactory { /** * Method create * @return */ public Object create() { return new Lookup(); } }