import org.simgrid.msg.MsgException;
import org.simgrid.msg.NativeException;
import org.simgrid.msg.Host;
-import org.simgrid.msg.HostNotFoundException;
public class RelayRunner extends Process {
private static final int TASK_COMM_SIZE = 1000000; /* The token is 1MB long*/
- public RelayRunner(Host host, String name, String[]args) throws HostNotFoundException, NativeException{
+ public RelayRunner(Host host, String name, String[]args) throws NativeException {
super(host,name,args);
}
import org.simgrid.msg.Msg;
import org.simgrid.msg.Host;
-import org.simgrid.msg.NativeException;
-import org.simgrid.msg.HostNotFoundException;
+import org.simgrid.msg.MsgException;
class Main {
private Main() {
throw new IllegalAccessError("Utility class");
}
- public static void main(String[] args) throws NativeException, HostNotFoundException {
+ public static void main(String[] args) throws MsgException {
Msg.init(args);
String platform = "../platforms/small_platform.xml";
super(host,name);
}
+ @Override
public void main(String[] args) throws TransferFailureException, HostFailureException, TimeoutException {
Comm comm = Task.irecv(getHost().getName());
Msg.info("I started receiving on '"+ getHost().getName() +". Wait 0.1 second, and block on the communication.");
super(host,name);
}
+ @Override
public void main(String[] args) throws MsgException {
double taskComputeSize =0;
double taskCommunicateSize = 5000000;