parallel/spmd/MultiDataPartitionObject.java

package appl.parallel.spmd;

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

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