public void main(String[] args) throws MsgException {
while(true) {
Msg.info("Receiving on " + "slave_" + number);
- Task task = Task.receive("slave_"+number);
-
+ Task task;
+ try {
+ task = Task.receive("slave_"+number);
+ } catch (MsgException e) {
+ Msg.debug("Received failed. I'm done. See you!");
+ break;
+ }
if (task instanceof FinalizeTask) {
+ Msg.info("Received Finalize. I'm done. See you!");
break;
}
Msg.info("Received \"" + task.getName() + "\". Processing it.");
Msg.info("\"" + task.getName() + "\" done ");
}
- Msg.info("Received Finalize. I'm done. See you!");
}
}
\ No newline at end of file
import org.simgrid.msg.HostFailureException;
import org.simgrid.msg.HostNotFoundException;
import org.simgrid.msg.Msg;
+import org.simgrid.msg.MsgException;
import org.simgrid.msg.Task;
import org.simgrid.msg.TimeoutException;
import org.simgrid.msg.TransferFailureException;
Msg.info("Send Mail1!");
task.send("mail1");
- Task task2 = Task.receive("mail2");
- Msg.info("Receive Mail2!");
+ Task task2;
+ try {
+ task2 = Task.receive("mail2");
+ } catch (MsgException e) {
+ Msg.debug("Received failed");
+ return;
+ }
+ Msg.info("Receive Mail2!");
}
}
*/
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;
}
public void main(String[] args) throws TransferFailureException, HostFailureException, TimeoutException {
Msg.info("Hello!");
- waitFor(10.0);
- Msg.info("OK, goodbye now.");
+ try {
+ waitFor(10.0);
+ Msg.info("OK, goodbye now.");
+ } catch (MsgException e) {
+ Msg.debug("Wait cancelled.");
+ }
}
}