import org.simgrid.msg.Comm;
import org.simgrid.msg.Host;
-import org.simgrid.msg.Process;
import org.simgrid.msg.Msg;
import org.simgrid.msg.MsgException;
+import org.simgrid.msg.Process;
import org.simgrid.msg.Task;
-import org.simgrid.msg.Process;;
public class Master extends Process {
public Master(Host host, String name, String[]args) {
import org.simgrid.msg.Comm;
import org.simgrid.msg.Host;
import org.simgrid.msg.HostFailureException;
-import org.simgrid.msg.HostNotFoundException;
import org.simgrid.msg.Msg;
+import org.simgrid.msg.Process;
import org.simgrid.msg.Task;
import org.simgrid.msg.TaskCancelledException;
import org.simgrid.msg.TimeoutException;
import org.simgrid.msg.TransferFailureException;
-import org.simgrid.msg.Process;
public class Slave extends Process {
public Slave(Host host, String name, String[]args) {
package bittorrent;
import java.util.Arrays;
-import org.simgrid.msg.Msg;
public class Connection {
/**
* Remote peer id
import java.util.ArrayList;
import java.util.HashMap;
-import java.util.HashSet;
import java.util.Iterator;
import java.util.Map.Entry;
import org.simgrid.msg.Host;
import org.simgrid.msg.Msg;
import org.simgrid.msg.MsgException;
-import org.simgrid.msg.RngStream;
import org.simgrid.msg.Process;
+import org.simgrid.msg.RngStream;
import org.simgrid.msg.Task;
-import bittorrent.Connection;
-
/**
* Main class for peers execution
*/
*/
package bittorrent;
import java.util.ArrayList;
-import java.util.Iterator;
import org.simgrid.msg.Comm;
import org.simgrid.msg.Host;
-import org.simgrid.msg.Process;
import org.simgrid.msg.Msg;
import org.simgrid.msg.MsgException;
-import org.simgrid.msg.Task;
-
+import org.simgrid.msg.Process;
import org.simgrid.msg.RngStream;
+import org.simgrid.msg.Task;
/**
* Tracker, handle requests from peers.
*/
package commTime;
import org.simgrid.msg.Host;
-import org.simgrid.msg.HostNotFoundException;
import org.simgrid.msg.Msg;
import org.simgrid.msg.MsgException;
-import org.simgrid.msg.Task;
import org.simgrid.msg.Process;
+import org.simgrid.msg.Task;
public class Master extends Process {
public Master(Host host, String name, String[]args) {
Msg.info("Send Mail1!");
task.send("mail1");
- Task task2;
try {
- task2 = Task.receive("mail2");
+ Task.receive("mail2");
} catch (MsgException e) {
Msg.debug("Received failed");
return;
import org.simgrid.msg.Host;
import org.simgrid.msg.Msg;
import org.simgrid.msg.MsgException;
-import org.simgrid.msg.Task;
import org.simgrid.msg.Process;
public class Policeman extends Process {
import org.simgrid.msg.Msg;
import org.simgrid.msg.NativeException;
-import org.simgrid.msg.*;
-
public class MutexCentral {
/* This only contains the launcher. If you do nothing more than than you can run
package startKillTime;
import org.simgrid.msg.Host;
import org.simgrid.msg.HostFailureException;
-import org.simgrid.msg.HostNotFoundException;
-import org.simgrid.msg.TransferFailureException;
-import org.simgrid.msg.TimeoutException;
import org.simgrid.msg.Msg;
import org.simgrid.msg.Process;
+import org.simgrid.msg.TimeoutException;
+import org.simgrid.msg.TransferFailureException;
public class Master extends Process {
*/
package startKillTime;
import org.simgrid.msg.Host;
-import org.simgrid.msg.MsgException;
import org.simgrid.msg.HostFailureException;
-import org.simgrid.msg.HostNotFoundException;
-import org.simgrid.msg.TransferFailureException;
-import org.simgrid.msg.TimeoutException;
import org.simgrid.msg.Msg;
+import org.simgrid.msg.MsgException;
import org.simgrid.msg.Process;
+import org.simgrid.msg.TimeoutException;
+import org.simgrid.msg.TransferFailureException;
/**
* Lazy Guy Slave, suspends itself ASAP