1 |
package appl.parallel.spmd; |
package appl.parallel.spmd; |
2 |
|
|
|
import java.net.InetAddress; |
|
3 |
import java.rmi.RemoteException; |
import java.rmi.RemoteException; |
4 |
import java.util.HashMap; |
import java.util.HashMap; |
5 |
import java.util.Vector; |
import java.util.Vector; |
|
import java.util.concurrent.Callable; |
|
6 |
import java.util.concurrent.ExecutionException; |
import java.util.concurrent.ExecutionException; |
7 |
import java.util.concurrent.ExecutorService; |
import java.util.concurrent.ExecutorService; |
8 |
import java.util.concurrent.Executors; |
import java.util.concurrent.Executors; |
9 |
import java.util.concurrent.Future; |
import java.util.concurrent.Future; |
|
import java.util.concurrent.TimeUnit; |
|
10 |
|
|
11 |
import org.apache.log4j.LogManager; |
import org.apache.log4j.LogManager; |
12 |
import org.apache.log4j.Logger; |
import org.apache.log4j.Logger; |
13 |
|
|
|
import edu.bonn.xulu.plugin.data.grid.MultiGrid; |
|
|
import appl.data.DataLoader; |
|
14 |
import appl.ext.XuluConfig; |
import appl.ext.XuluConfig; |
|
import appl.parallel.ComputingResource; |
|
15 |
import appl.parallel.ComputingResourceContainer; |
import appl.parallel.ComputingResourceContainer; |
16 |
import appl.parallel.ComputingResourceProperties; |
import appl.parallel.ComputingResourceProperties; |
|
import appl.parallel.client.RemoteEventHandler; |
|
17 |
import appl.parallel.client.ClientDataServer; |
import appl.parallel.client.ClientDataServer; |
18 |
|
import appl.parallel.client.RemoteEventHandler; |
19 |
import appl.parallel.data.PartitionDataHandler; |
import appl.parallel.data.PartitionDataHandler; |
20 |
import appl.parallel.data.PartitionHandlerFactory; |
import appl.parallel.data.PartitionHandlerFactory; |
|
import appl.parallel.data.XuluClientLoader; |
|
|
import appl.parallel.event.CommEvent; |
|
21 |
import appl.parallel.event.CommEventSink; |
import appl.parallel.event.CommEventSink; |
|
import appl.parallel.event.TimeEvent; |
|
|
import appl.parallel.event.TimeMonitor; |
|
|
import appl.parallel.event.TransferEvent; |
|
|
import appl.parallel.event.TransferMonitor; |
|
22 |
import appl.parallel.event.CommEvent.CommType; |
import appl.parallel.event.CommEvent.CommType; |
23 |
|
import appl.parallel.model.AbstractParallelStepModel; |
24 |
import appl.parallel.server.PartitionDataServer; |
import appl.parallel.server.PartitionDataServer; |
25 |
import appl.parallel.server.SPMDResource; |
import appl.parallel.server.SPMDResource; |
26 |
import appl.parallel.spmd.split.AbstractSplitMap; |
import appl.parallel.spmd.split.AbstractSplitMap; |
|
import appl.parallel.spmd.split.DataPartition; |
|
27 |
import appl.parallel.spmd.split.SinglePartitionInfo; |
import appl.parallel.spmd.split.SinglePartitionInfo; |
28 |
import appl.parallel.spmd.split.SplitMap; |
import appl.parallel.spmd.split.SplitMap; |
29 |
import appl.parallel.spmd.split.SplittableResource; |
import appl.parallel.spmd.split.SplittableResource; |
30 |
import appl.parallel.spmd.split.AbstractSplitMap.NeighborhoodBoxingMode; |
import appl.parallel.spmd.split.AbstractSplitMap.NeighborhoodBoxingMode; |
31 |
import appl.parallel.thread.ComputingResourceThread; |
import appl.parallel.thread.ComputingResourceThread; |
32 |
import appl.parallel.thread.DataServerThread; |
import appl.parallel.thread.DataServerThread; |
33 |
import appl.parallel.model.AbstractParallelStepModel; |
import edu.bonn.xulu.plugin.data.grid.MultiGrid; |
34 |
|
|
35 |
/** |
/** |
36 |
* This class controls all the parallelization action on the client side and is |
* This class controls all the parallelization action on the client side and is |