org.codehaus.wadi.location.partitionmanager.local
Class BasicLocalPartition

java.lang.Object
  extended by org.codehaus.wadi.location.partitionmanager.local.BasicLocalPartition
All Implemented Interfaces:
java.io.Serializable, LocalPartition, Partition

public class BasicLocalPartition
extends java.lang.Object
implements LocalPartition

Version:
$Revision:1815 $
Author:
Jules Gosnell
See Also:
Serialized Form

Constructor Summary
protected BasicLocalPartition()
           
  BasicLocalPartition(org.codehaus.wadi.group.Dispatcher dispatcher, int key)
           
  BasicLocalPartition(org.codehaus.wadi.group.Dispatcher dispatcher, LocalPartition prototype)
           
 
Method Summary
 org.codehaus.wadi.group.Envelope exchange(SessionRequestMessage request, long timeout)
          Send a message/request to the Partition and wait for a message/response...
 int getKey()
           
 java.util.Map<java.lang.Object,Location> getNameToLocation()
           
 boolean isLocal()
           
 void merge(LocalPartition content)
           
 void onMessage(org.codehaus.wadi.group.Envelope message, DeleteIMToPM request)
          A Peer has destroyed a Session...
 void onMessage(org.codehaus.wadi.group.Envelope message, EvacuateIMToPM request)
          A Peer wishes to evacuate a Session...
 void onMessage(org.codehaus.wadi.group.Envelope message, InsertIMToPM request)
          A Peer has created a Session...
 void onMessage(org.codehaus.wadi.group.Envelope message, MoveIMToPM request)
          A Peer has an Invocation for a Session of which it is not the owner...
 void put(java.util.Collection<java.lang.Object> names, org.codehaus.wadi.group.Peer peer)
           
 java.lang.String toString()
           
 void waitForClientCompletion()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

BasicLocalPartition

protected BasicLocalPartition()

BasicLocalPartition

public BasicLocalPartition(org.codehaus.wadi.group.Dispatcher dispatcher,
                           int key)

BasicLocalPartition

public BasicLocalPartition(org.codehaus.wadi.group.Dispatcher dispatcher,
                           LocalPartition prototype)
Method Detail

getKey

public int getKey()
Specified by:
getKey in interface Partition
Returns:
the Partition 'key' - a number between '0' and 'numPartitions-1'

isLocal

public boolean isLocal()
Specified by:
isLocal in interface Partition
Returns:
whether or not this is a LocalPartition

onMessage

public void onMessage(org.codehaus.wadi.group.Envelope message,
                      InsertIMToPM request)
Description copied from interface: Partition
A Peer has created a Session...

Specified by:
onMessage in interface Partition

onMessage

public void onMessage(org.codehaus.wadi.group.Envelope message,
                      DeleteIMToPM request)
Description copied from interface: Partition
A Peer has destroyed a Session...

Specified by:
onMessage in interface Partition

onMessage

public void onMessage(org.codehaus.wadi.group.Envelope message,
                      MoveIMToPM request)
Description copied from interface: Partition
A Peer has an Invocation for a Session of which it is not the owner...

Specified by:
onMessage in interface Partition

onMessage

public void onMessage(org.codehaus.wadi.group.Envelope message,
                      EvacuateIMToPM request)
Description copied from interface: Partition
A Peer wishes to evacuate a Session...

Specified by:
onMessage in interface Partition

exchange

public org.codehaus.wadi.group.Envelope exchange(SessionRequestMessage request,
                                                 long timeout)
                                          throws org.codehaus.wadi.group.MessageExchangeException
Description copied from interface: Partition
Send a message/request to the Partition and wait for a message/response...

Specified by:
exchange in interface Partition
Parameters:
request - The request
timeout - The number of milliseconds to wait for a response
Returns:
the response
Throws:
org.codehaus.wadi.group.MessageExchangeException

waitForClientCompletion

public void waitForClientCompletion()
Specified by:
waitForClientCompletion in interface LocalPartition

put

public void put(java.util.Collection<java.lang.Object> names,
                org.codehaus.wadi.group.Peer peer)
Specified by:
put in interface LocalPartition

getNameToLocation

public java.util.Map<java.lang.Object,Location> getNameToLocation()
Specified by:
getNameToLocation in interface LocalPartition

merge

public void merge(LocalPartition content)
Specified by:
merge in interface LocalPartition

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object


Copyright © 2008. All Rights Reserved.