79 lines
2.6 KiB
JavaScript
79 lines
2.6 KiB
JavaScript
|
|
||
|
|
TIMEOUT(2400000); /* 40 minutes */
|
||
|
|
|
||
|
|
var NR_FEATHERS = mote.getSimulation().getMotesCount() - 1;
|
||
|
|
|
||
|
|
/* conf */
|
||
|
|
var travis = java.lang.System.getenv().get("TRAVIS");
|
||
|
|
if (travis == null) {
|
||
|
|
/* Instant Contiki */
|
||
|
|
CMD_TUNNEL = "echo '-vj' > ~/.slirprc && make Connect.class && java Connect 'nc localhost 60001' 'script -t -f -c slirp'";
|
||
|
|
CMD_PING = "ping -c 5 8.8.8.8";
|
||
|
|
CMD_DIR = "../../wpcapslip";
|
||
|
|
} else {
|
||
|
|
/* Travis */
|
||
|
|
CMD_TUNNEL = "cd $TRAVIS_BUILD_DIR/tools/wpcapslip && sudo apt-get install slirp && echo '-vj' > ~/.slirprc && make Connect.class && java Connect 'nc localhost 60001' 'script -t -f -c slirp'";
|
||
|
|
CMD_PING = "ping -c 5 8.8.8.8";
|
||
|
|
CMD_DIR = ".";
|
||
|
|
}
|
||
|
|
|
||
|
|
/* delay */
|
||
|
|
GENERATE_MSG(1000, "continue");
|
||
|
|
YIELD_THEN_WAIT_UNTIL(msg.equals("continue"));
|
||
|
|
|
||
|
|
/* realtime speed */
|
||
|
|
sim.setSpeedLimit(2.0);
|
||
|
|
|
||
|
|
/* tunnel interface */
|
||
|
|
log.log("opening tunnel interface: " + CMD_TUNNEL + "\n");
|
||
|
|
launcher = new java.lang.ProcessBuilder["(java.lang.String[])"](['sh','-c',CMD_TUNNEL]);
|
||
|
|
launcher.directory(new java.io.File(CMD_DIR));
|
||
|
|
launcher.redirectErrorStream(true);
|
||
|
|
tunProcess = launcher.start();
|
||
|
|
tunRunnable = new Object();
|
||
|
|
tunRunnable.run = function() {
|
||
|
|
var stdIn = new java.io.BufferedReader(new java.io.InputStreamReader(tunProcess.getInputStream()));
|
||
|
|
while ((line = stdIn.readLine()) != null) {
|
||
|
|
if (line != null && !line.trim().equals("")) {
|
||
|
|
//log.log("TUN> " + line + "\n");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
tunProcess.destroy();
|
||
|
|
}
|
||
|
|
new java.lang.Thread(new java.lang.Runnable(tunRunnable)).start();
|
||
|
|
|
||
|
|
GENERATE_MSG(1000, "continue");
|
||
|
|
YIELD_THEN_WAIT_UNTIL(msg.equals("continue"));
|
||
|
|
|
||
|
|
/* ping */
|
||
|
|
log.log("pinging: " + CMD_PING + "\n");
|
||
|
|
launcher = new java.lang.ProcessBuilder["(java.lang.String[])"](['sh','-c',CMD_PING]);
|
||
|
|
launcher.directory(new java.io.File(CMD_DIR));
|
||
|
|
launcher.redirectErrorStream(true);
|
||
|
|
tunProcess = launcher.start();
|
||
|
|
tunRunnable = new Object();
|
||
|
|
tunRunnable.run = function() {
|
||
|
|
var stdIn = new java.io.BufferedReader(new java.io.InputStreamReader(tunProcess.getInputStream()));
|
||
|
|
while ((line = stdIn.readLine()) != null) {
|
||
|
|
if (line != null && !line.trim().equals("")) {
|
||
|
|
log.log("PING> " + line + "\n");
|
||
|
|
}
|
||
|
|
}
|
||
|
|
tunProcess.destroy();
|
||
|
|
}
|
||
|
|
new java.lang.Thread(new java.lang.Runnable(tunRunnable)).start();
|
||
|
|
|
||
|
|
var completed = {};
|
||
|
|
while(Object.keys(completed).length < NR_FEATHERS) {
|
||
|
|
if (!msg.startsWith("#L") && !msg.startsWith("E")) {
|
||
|
|
//log.log(mote + ": " + msg + "\n");
|
||
|
|
}
|
||
|
|
if (id != 1 && msg.startsWith("HTTP socket closed")) {
|
||
|
|
completed[id] = id;
|
||
|
|
log.log("Data compelete " + id + ", heard " + Object.keys(completed).length + " in total\n");
|
||
|
|
}
|
||
|
|
YIELD();
|
||
|
|
}
|
||
|
|
|
||
|
|
log.testOK();
|