A
lgorithmique
N
umérique
D
istribuée
Public GIT Repository
projects
/
simgrid.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
codacy
[simgrid.git]
/
examples
/
java
/
trace
/
pingpong
/
Receiver.java
diff --git
a/examples/java/trace/pingpong/Receiver.java
b/examples/java/trace/pingpong/Receiver.java
index 54f24df00fc44f22c2e0b225784cb252dc2b8c48..4a1f26e55ef87f8b4d7af749019e827373373f23 100644
(file)
--- a/
examples/java/trace/pingpong/Receiver.java
+++ b/
examples/java/trace/pingpong/Receiver.java
@@
-5,19
+5,18
@@
* under the terms of the license (GNU LGPL) which comes with this package. */
package trace.pingpong;
* under the terms of the license (GNU LGPL) which comes with this package. */
package trace.pingpong;
+import org.simgrid.msg.HostNotFoundException;
import org.simgrid.msg.Msg;
import org.simgrid.msg.MsgException;
import org.simgrid.msg.Msg;
import org.simgrid.msg.MsgException;
-import org.simgrid.msg.NativeException;
-import org.simgrid.msg.HostNotFoundException;
-import org.simgrid.msg.Task;
import org.simgrid.msg.Process;
import org.simgrid.msg.Process;
+import org.simgrid.msg.Task;
import org.simgrid.trace.Trace;
public class Receiver extends Process {
import org.simgrid.trace.Trace;
public class Receiver extends Process {
- private static final double
commSizeLat
= 1;
- private static final double
commSizeBw
= 100000000;
+ private static final double
COMM_SIZE_LAT
= 1;
+ private static final double
COMM_SIZE_BW
= 100000000;
- public Receiver(String hostname, String name, String[]args) throws HostNotFoundException
, NativeException
{
+ public Receiver(String hostname, String name, String[]args) throws HostNotFoundException
{
super(hostname,name,args);
}
super(hostname,name,args);
}
@@
-39,12
+38,12
@@
public class Receiver extends Process {
double communicationTime=timeGot - time;
Msg.info("Communication time : " + communicationTime);
double communicationTime=timeGot - time;
Msg.info("Communication time : " + communicationTime);
- Msg.info(" --- bw "+
commSizeBw
/communicationTime + " ----");
+ Msg.info(" --- bw "+
COMM_SIZE_BW
/communicationTime + " ----");
/* Send the pong */
Trace.hostPushState (getHost().getName(), "PM_STATE", "sendingPong");
double computeDuration = 0;
/* Send the pong */
Trace.hostPushState (getHost().getName(), "PM_STATE", "sendingPong");
double computeDuration = 0;
- PingPongTask pong = new PingPongTask("no name",computeDuration,
commSizeLat
);
+ PingPongTask pong = new PingPongTask("no name",computeDuration,
COMM_SIZE_LAT
);
pong.setTime(time);
pong.send(ping.getSource().getName());
pong.setTime(time);
pong.send(ping.getSource().getName());