org.codehaus.wadi.dindex.impl
Class LocalPartition

java.lang.Object
  extended byorg.codehaus.wadi.dindex.impl.AbstractPartition
      extended byorg.codehaus.wadi.dindex.impl.LocalPartition
All Implemented Interfaces:
Partition, PMPartition, Serializable, SMPartition

public class LocalPartition
extends AbstractPartition
implements Serializable

See Also:
Serialized Form

Field Summary
protected  PartitionConfig _config
           
protected  Log _lockLog
           
protected  Log _log
           
protected  Map _map
           
 
Fields inherited from class org.codehaus.wadi.dindex.impl.AbstractPartition
_key
 
Constructor Summary
protected LocalPartition()
           
  LocalPartition(int key)
           
 
Method Summary
 ObjectMessage exchange(DIndexRequest request, long timeout)
           
 void init(PartitionConfig config)
           
 boolean isLocal()
           
 void onMessage(ObjectMessage message, DeleteIMToPM request)
           
 void onMessage(ObjectMessage message, DIndexForwardRequest request)
           
 void onMessage(ObjectMessage message, DIndexRelocationRequest request)
           
 void onMessage(ObjectMessage message, InsertIMToPM request)
           
 void onMessage(ObjectMessage message1, MoveIMToPM request)
           
 void put(String name, Destination destination)
           
 String toString()
           
 
Methods inherited from class org.codehaus.wadi.dindex.impl.AbstractPartition
getKey
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

_log

protected transient Log _log

_lockLog

protected transient Log _lockLog

_map

protected Map _map

_config

protected transient PartitionConfig _config
Constructor Detail

LocalPartition

public LocalPartition(int key)

LocalPartition

protected LocalPartition()
Method Detail

init

public void init(PartitionConfig config)

isLocal

public boolean isLocal()
Specified by:
isLocal in interface PMPartition

toString

public String toString()

put

public void put(String name,
                Destination destination)

onMessage

public void onMessage(ObjectMessage message,
                      InsertIMToPM request)
Specified by:
onMessage in interface Partition

onMessage

public void onMessage(ObjectMessage message,
                      DeleteIMToPM request)
Specified by:
onMessage in interface Partition

onMessage

public void onMessage(ObjectMessage message,
                      DIndexRelocationRequest request)
Specified by:
onMessage in interface Partition

onMessage

public void onMessage(ObjectMessage message,
                      DIndexForwardRequest request)
Specified by:
onMessage in interface Partition

onMessage

public void onMessage(ObjectMessage message1,
                      MoveIMToPM request)
Specified by:
onMessage in interface Partition

exchange

public ObjectMessage exchange(DIndexRequest request,
                              long timeout)
                       throws Exception
Specified by:
exchange in interface Partition
Throws:
Exception


Copyright © 2004-2006 Core Developers Network Ltd.. All Rights Reserved.