|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.rmi.server.RemoteObject
java.rmi.server.RemoteServer
java.rmi.server.UnicastRemoteObject
appl.parallel.server.PartitionDataManager
public class PartitionDataManager
Manages the all data for the XuluServer
. This includes retrieval of
partitions from connected resources like the DataServer
or, as part
of the update of neighborhood regions, from other
XuluServers
.
Field Summary |
---|
Fields inherited from class java.rmi.server.RemoteObject |
---|
ref |
Constructor Summary | |
---|---|
PartitionDataManager(String[] IPs,
CommEventSink remoteEventReceiver,
int registryPort)
Creates and inits a new PartitionDataserver. |
|
PartitionDataManager(String[] IPs,
RemoteEventProxy remoteEventReceiver,
int registryport,
ClientDataServer localSPMDClient)
Same as PartitionDataManager(String[], CommEventSink, int) , but uses
a local SPMDClient. |
Method Summary | |
---|---|
void |
addData(DataPartition partition)
Adds a Partition to the server |
void |
addMultiDataInfos(HashMap<String,MultiDataInfo> newMultiDataInfos)
Adds MultiDataInfo s to the server. |
void |
addPartitionInfos(Vector<SinglePartitionInfo> singlePartitionInfos)
Adds PartitionInfo s to the server. |
void |
destroyMultiPartition(String name,
int idx)
|
Object |
getBaseParameter(String name)
returns the baseParameter by name |
DataPartition |
getData(int id)
Returns the DataPartition associated with the given ID |
DataPartition |
getData(String name)
Gets a partition by name |
PartitionInfo |
getInfo(int id)
Returns the partition info with the specified id |
DataPartition[] |
getMultiData(String name)
Gets a partition of a multi-data element. |
DataPartition |
getMultiData(String name,
int pos)
Gets a partition of a multi-data element. |
MultiDataInfo |
getMultiDataInfo(String name)
|
MultiDataPartitionObject |
getMultiDataObject(String name)
|
DataPartition |
getPartition(int id,
Rectangle bounds)
gets the data with the id of a SplittableRessource |
SinglePartitionInfo |
getPartitionInfo(int rootID)
|
void |
removeData(int id)
Removes the partition with the specified id. |
void |
removeData(String name)
Removes the partition from the database |
void |
removePartition(DataPartition partition)
Removes the partition from the database |
void |
stop()
unbinds the server from the registry, removes all data and runs the garbage collector |
void |
unloadToSource(int rootID)
Unloads the specified resource to the source it was loaded from |
void |
updateBaseParameter(HashMap<String,Object> newParameters)
Adds or updates BaseParameters |
void |
updateFromNeighbors(int id)
Updates the specified partition. |
void |
updateFromNeighbors(String name)
Does the same as updateFromNeighbors(int) |
void |
updatePartition(int id,
DataPartition partition,
Rectangle bounds)
sets the data with the id of a SplittableRessource |
Methods inherited from class java.rmi.server.UnicastRemoteObject |
---|
clone, exportObject, exportObject, exportObject, unexportObject |
Methods inherited from class java.rmi.server.RemoteServer |
---|
getClientHost, getLog, setLog |
Methods inherited from class java.rmi.server.RemoteObject |
---|
equals, getRef, hashCode, toString, toStub |
Methods inherited from class java.lang.Object |
---|
finalize, getClass, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public PartitionDataManager(String[] IPs, CommEventSink remoteEventReceiver, int registryPort) throws RemoteException
IPs
- the IPs of participating Servers for neighborhood updates(may
include port specification)remoteEventReceiver
- generated events are forwarded to the receiverregistryPort
- port of the registry to which the PartitionDataManager
should be bound
RemoteException
- if a connection to a participating server failspublic PartitionDataManager(String[] IPs, RemoteEventProxy remoteEventReceiver, int registryport, ClientDataServer localSPMDClient) throws RemoteException
PartitionDataManager(String[], CommEventSink, int)
, but uses
a local SPMDClient.
IPs
- the IPs of participating Servers for neighborhood updates(may
include port specification)remoteEventReceiver
- generated events are forwarded to the receiverregistryport
- port of the registry to which the PartitionDataManager
should be boundlocalSPMDClient
- a ClientDataServer
for fast local access
RemoteException
Method Detail |
---|
public void addData(DataPartition partition) throws RemoteException
DataServer
addData
in interface DataServer
partition
- the partition to add
RemoteException
public void addMultiDataInfos(HashMap<String,MultiDataInfo> newMultiDataInfos) throws RemoteException
PartitionDataServer
MultiDataInfo
s to the server.
addMultiDataInfos
in interface PartitionDataServer
RemoteException
public void addPartitionInfos(Vector<SinglePartitionInfo> singlePartitionInfos) throws RemoteException
PartitionDataServer
PartitionInfo
s to the server. They are submitted in a
vector to avoid multiple remote calls.
addPartitionInfos
in interface PartitionDataServer
RemoteException
public void destroyMultiPartition(String name, int idx)
name
- idx
- public Object getBaseParameter(String name)
name
- the name of the parameter
public DataPartition getData(int id) throws RemoteException
DataPartition
associated with the given ID
getData
in interface DataServer
id
- the id of the data
RemoteException
- if the connection to the server failspublic DataPartition getData(String name)
name
- the name of the resource (probably given by the programmer)
public PartitionInfo getInfo(int id)
id
- the id of the partition
public DataPartition[] getMultiData(String name)
name
- the name of the resource (probably given by the programmer)
SPMDClientController.addToMultiDataSplitControl(Object[], String)
public DataPartition getMultiData(String name, int pos)
name
- the name of the resource (probably given by the programmer)pos
- the index of the requested element
SPMDClientController.addToMultiDataSplitControl(Object[], String)
public MultiDataInfo getMultiDataInfo(String name) throws RemoteException
getMultiDataInfo
in interface PartitionDataServer
name
- the name of the associated multi data
MultiDataInfo
info
RemoteException
public MultiDataPartitionObject getMultiDataObject(String name) throws RemoteException
getMultiDataObject
in interface PartitionDataServer
name
- the name of the multiDataObject
RemoteException
public DataPartition getPartition(int id, Rectangle bounds) throws RemoteException
PartitionDataServer
getPartition
in interface DataServer
getPartition
in interface PartitionDataServer
id
- the ID
of a the base databounds
- the bounds of the partition to retrieve (using global
coordinates)
RemoteException
public SinglePartitionInfo getPartitionInfo(int rootID) throws RemoteException
getPartitionInfo
in interface PartitionDataServer
rootID
- the id of the according partition
PartitionInfo
RemoteException
public void removeData(int id)
DataServer
removeData
in interface DataServer
id
- id of the partition to removepublic void removeData(String name)
name
- the name of the partition to removepublic void removePartition(DataPartition partition)
partition
- the Partition to removepublic void stop()
public void unloadToSource(int rootID) throws RemoteException
PartitionDataServer
unloadToSource
in interface PartitionDataServer
rootID
-
RemoteException
public void updateBaseParameter(HashMap<String,Object> newParameters) throws RemoteException
PartitionDataServer
updateBaseParameter
in interface PartitionDataServer
RemoteException
public void updateFromNeighbors(int id)
SplitMap
of the
SinglePartitionInfo
.
updateFromNeighbors
in interface PartitionDataServer
id
- public void updateFromNeighbors(String name)
updateFromNeighbors(int)
name
- the name of the resourcepublic void updatePartition(int id, DataPartition partition, Rectangle bounds) throws RemoteException
PartitionDataServer
updatePartition
in interface DataServer
updatePartition
in interface PartitionDataServer
id
- the ID
of a the base datapartition
- the updateData (which may only a partitial update, depending
on the bounds set with the last parameter)bounds
- the locatition where the partition is to be updated (using
global coordinates)
RemoteException
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |