parallel/thread/DataServerThread.java

package appl.parallel.thread;

import appl.parallel.ComputingResourceProperties;
import appl.parallel.event.CommEventSink;
import appl.parallel.event.CommEvent.CommType;
import appl.parallel.server.PartitionDataServer;

/**
 * @author Dominik Appl
 */
public abstract class DataServerThread extends ExecutionThread {
        
        public DataServerThread(PartitionDataServer dataServer,ComputingResourceProperties resourceInfos, Object argument,CommType type, CommEventSink sink){
                super(dataServer,resourceInfos,argument,type,sink,false);
        }
        
        public DataServerThread(PartitionDataServer dataServer,ComputingResourceProperties resourceInfos, Object argument,CommType type, CommEventSink sink, boolean disableTransferEvents){
                super(dataServer,resourceInfos,argument,type,sink,disableTransferEvents);
        }
        
        protected PartitionDataServer getServer(){
                return (PartitionDataServer) server;
        }
        
}
1	package appl.parallel.thread;
2
3	import appl.parallel.ComputingResourceProperties;
4	import appl.parallel.event.CommEventSink;
5	import appl.parallel.event.CommEvent.CommType;
6	import appl.parallel.server.PartitionDataServer;
7
8	/**
9	* @author Dominik Appl
10	*/
11	public abstract class DataServerThread extends ExecutionThread {
12
13	public DataServerThread(PartitionDataServer dataServer,ComputingResourceProperties resourceInfos, Object argument,CommType type, CommEventSink sink){
14	super(dataServer,resourceInfos,argument,type,sink,false);
15	}
16
17	public DataServerThread(PartitionDataServer dataServer,ComputingResourceProperties resourceInfos, Object argument,CommType type, CommEventSink sink, boolean disableTransferEvents){
18	super(dataServer,resourceInfos,argument,type,sink,disableTransferEvents);
19	}
20
21	protected PartitionDataServer getServer(){
22	return (PartitionDataServer) server;
23	}
24
25	}