parallel/spmd/MultiDataPartitionObject.java

package appl.parallel.spmd;

import java.io.Serializable;
import java.rmi.RemoteException;
import java.util.Vector;

import appl.parallel.client.DataServer;
import appl.parallel.data.PartitionDataHandler;
import appl.parallel.server.PartitionDataServer;
import appl.parallel.server.PartitionDataManager;
import appl.parallel.spmd.split.DataPartition;
import appl.parallel.spmd.split.PartitionInfo;
import appl.parallel.spmd.split.SinglePartitionInfo;

/**
 *  A extension of the {@link MultiDataObject} for storing {@link DataPartition DataPartitions}.
 *    
 * @author Dominik Appl
 */
public class MultiDataPartitionObject extends MultiDataObject {

        private final PartitionDataServer partitionDataServer;
        private final MultiDataInfo info;

        public MultiDataPartitionObject(MultiDataInfo info, PartitionDataServer dataServer) {
                super(info, dataServer);
                this.info = info;
                partitionDataServer = dataServer;
        }

        /**
         * Adds an element to the PartitionObject as {@link MultiDataObject} does. Also 
         * adds the needed {@link PartitionInfo} Object for the new Element
         * to the {@link PartitionDataServer}.
         * 
         * @return the index of the last element
         */
        @Override
        public int addElement() {
                int lastIdx = super.addElement();
                int newID = this.getMultiInfo().getMultiID(lastIdx);
                //get PartitionInfo of the first grid and duplicate it
                try {
                        SinglePartitionInfo partitionInfo = (SinglePartitionInfo) partitionDataServer.getPartitionInfo(info.getMultiID(0)).clone(newID);
                        //add the new PartitionInfo to the server
                        Vector<SinglePartitionInfo> partitionVector = new Vector<SinglePartitionInfo>();
                        partitionVector.add(partitionInfo);
                        partitionDataServer.addPartitionInfos(partitionVector);
                } catch (RemoteException e) {
                        // TODO Auto-generated catch block
                        e.printStackTrace();
                }
                
                return lastIdx;
        }
        

}
1	mojays	2	package appl.parallel.spmd;
2
3			import java.io.Serializable;
4			import java.rmi.RemoteException;
5			import java.util.Vector;
6
7			import appl.parallel.client.DataServer;
8			import appl.parallel.data.PartitionDataHandler;
9			import appl.parallel.server.PartitionDataServer;
10			import appl.parallel.server.PartitionDataManager;
11			import appl.parallel.spmd.split.DataPartition;
12			import appl.parallel.spmd.split.PartitionInfo;
13			import appl.parallel.spmd.split.SinglePartitionInfo;
14
15			/**
16			* A extension of the {@link MultiDataObject} for storing {@link DataPartition DataPartitions}.
17			*
18			* @author Dominik Appl
19			*/
20			public class MultiDataPartitionObject extends MultiDataObject {
21
22			private final PartitionDataServer partitionDataServer;
23			private final MultiDataInfo info;
24
25			public MultiDataPartitionObject(MultiDataInfo info, PartitionDataServer dataServer) {
26			super(info, dataServer);
27			this.info = info;
28			partitionDataServer = dataServer;
29			}
30
31			/**
32			* Adds an element to the PartitionObject as {@link MultiDataObject} does. Also
33			* adds the needed {@link PartitionInfo} Object for the new Element
34			* to the {@link PartitionDataServer}.
35			*
36			* @return the index of the last element
37			*/
38			@Override
39			public int addElement() {
40			int lastIdx = super.addElement();
41			int newID = this.getMultiInfo().getMultiID(lastIdx);
42			//get PartitionInfo of the first grid and duplicate it
43			try {
44			SinglePartitionInfo partitionInfo = (SinglePartitionInfo) partitionDataServer.getPartitionInfo(info.getMultiID(0)).clone(newID);
45			//add the new PartitionInfo to the server
46			Vector<SinglePartitionInfo> partitionVector = new Vector<SinglePartitionInfo>();
47			partitionVector.add(partitionInfo);
48			partitionDataServer.addPartitionInfos(partitionVector);
49			} catch (RemoteException e) {
50			// TODO Auto-generated catch block
51			e.printStackTrace();
52			}
53
54			return lastIdx;
55			}
56
57
58			}