Untested basic new cortex.js and basicClient.html
This commit is contained in:
parent
a0200c208c
commit
1123dc8d0e
|
|
@ -146,6 +146,9 @@ class ResManager {
|
|||
putSite("shell.html", readURL(new URL(baseurl + "shell.html")));
|
||||
putSite("ajax.js", readURL(new URL(baseurl + "ajax.js")));
|
||||
|
||||
putSite("cortex.js", readURL(new URL(baseurl + "cortex.js")));
|
||||
putSite("basicClient.html", readURL(new URL(baseurl + "basicClient.html")));
|
||||
|
||||
|
||||
|
||||
} catch (Exception e) {
|
||||
|
|
|
|||
|
|
@ -0,0 +1,52 @@
|
|||
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
|
||||
<html xmlns="http://www.w3.org/1999/xhtml">
|
||||
<head>
|
||||
<title>Client</title>
|
||||
|
||||
<style type="text/css">
|
||||
.page {
|
||||
visibility: hidden;
|
||||
position: absolute;
|
||||
top: 40px;
|
||||
left: 10px;
|
||||
border: 1px solid black;
|
||||
padding: 5px;
|
||||
width: 550px;
|
||||
}
|
||||
|
||||
td, th {
|
||||
border: 1px solid black;
|
||||
margin: 0px;
|
||||
}
|
||||
|
||||
tr {
|
||||
padding: 0px;
|
||||
margin: 0px;
|
||||
}
|
||||
|
||||
table {
|
||||
padding: 0px;
|
||||
border: 1px solid black;
|
||||
}
|
||||
|
||||
</style>
|
||||
|
||||
<script src="cortex.js" ></script>
|
||||
|
||||
</head>
|
||||
<body>
|
||||
|
||||
<div id="statusLabel"></div>
|
||||
<div id="numberOfNodes">Number of nodes: <script> document.write(numberOfNodes); </script></div>
|
||||
<div id="connections">Connected to:</div>
|
||||
<div id="dlc">DLC:</div>
|
||||
<input id="networkAddr"><input type="button" value="Join Network" onClick="join_network(document.getElementById('networkAddr').value);"><br/>
|
||||
<br />
|
||||
<b>Log:</b> <input type="checkbox" value="log" id="logCheck"/>Log?<br/>
|
||||
<textarea rows="7" cols="60" id="cortexLog" readonly="true"></textarea>
|
||||
<br/>
|
||||
<input type="button" value="Reload HTML" onclick="reloadHTML()" />
|
||||
<br/><br/>
|
||||
<input type="button" value="Kill Server" onClick="killServer()" />
|
||||
|
||||
<script language="javascript">cortex_start()</script>
|
||||
465
client.html
465
client.html
|
|
@ -35,11 +35,6 @@
|
|||
|
||||
<script>
|
||||
|
||||
var localNodeAddr = '';
|
||||
var originURL = 'Unknown Source';
|
||||
var connected = false;
|
||||
var numberOfNodes = 0;
|
||||
var connections = new Array();
|
||||
|
||||
var tests = new Array();
|
||||
var testLocks = new Array();
|
||||
|
|
@ -54,104 +49,16 @@ var doneStage = 0;
|
|||
|
||||
var runTry = null;
|
||||
|
||||
var dlc = 0;
|
||||
var msgQ = new Array();
|
||||
|
||||
function error(msg) {
|
||||
log("ERROR: " + msg);
|
||||
alert("ERROR: " + msg);
|
||||
clearInterval(cronID);
|
||||
}
|
||||
|
||||
/* basic ping function for local node
|
||||
* if successful,
|
||||
* if we haven't greeted the server, we do,
|
||||
* otherwise nothing (just a heartbeat)
|
||||
* if it fails, lets the user know we have lost
|
||||
* connection to the node server
|
||||
*/
|
||||
function ping() {
|
||||
var http = ajaxConnect();
|
||||
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
if (!connected) {
|
||||
connected = true;
|
||||
greet();
|
||||
}
|
||||
},
|
||||
function(resp) {
|
||||
connected = false;
|
||||
var html = "Connection to local Node failed. Try reloading from <a href=\"" + originURL + "\" target=\"window\">" + originURL + "</a>";
|
||||
document.getElementById('statusLabel').innerHTML = html;
|
||||
|
||||
}
|
||||
|
||||
);
|
||||
|
||||
ajaxSend(http, "cmd=ping\n\n", retfn);
|
||||
}
|
||||
|
||||
/* Greets the server
|
||||
* so far just gets the server's IP and origin URL
|
||||
*/
|
||||
function greet() {
|
||||
var http = ajaxConnect();
|
||||
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
var arr = resp.split(" ");
|
||||
localNodeAddr = arr[0];
|
||||
originURL = arr[1];
|
||||
document.getElementById('statusLabel').innerHTML = "I am <b>" + localNodeAddr + "</b>";
|
||||
init();
|
||||
}
|
||||
);
|
||||
ajaxSend(http, "cmd=greet\n\n", retfn);
|
||||
}
|
||||
|
||||
function killServer() {
|
||||
announceDead(localNodeAddr);
|
||||
var http = ajaxConnect();
|
||||
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
// got a resp, server not dead
|
||||
killServer();
|
||||
});
|
||||
ajaxSend(http, "cmd=kill\n\n", retfn);
|
||||
}
|
||||
|
||||
function getLog() {
|
||||
var http = ajaxConnect();
|
||||
|
||||
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
var log = document.getElementById('log');
|
||||
//alert("getLog() resp: " + resp);
|
||||
log.value = resp + log.value;
|
||||
// Since getLog returns (a call back is called later)
|
||||
// this is tail recursive friendly
|
||||
getLog();
|
||||
});
|
||||
ajaxSend(http, "cmd=getLog\n\n", retfn);
|
||||
}
|
||||
|
||||
// two digits
|
||||
function d2(str) {
|
||||
if (str <10)
|
||||
return "0"+str;
|
||||
else
|
||||
return str;
|
||||
}
|
||||
|
||||
function getTime() {
|
||||
var date = new Date();
|
||||
return d2(date.getHours()) + ":" + d2(date.getMinutes()) + ":" + d2(date.getSeconds())
|
||||
}
|
||||
|
||||
|
||||
|
||||
|
||||
var logCheckElem = null;
|
||||
|
||||
function log(str) {
|
||||
if (logCheckElem == null)
|
||||
logCheckElem = document.getElementById("logCheck");
|
||||
|
|
@ -162,100 +69,15 @@ function log(str) {
|
|||
}
|
||||
}
|
||||
|
||||
/*
|
||||
function log2(str) {
|
||||
str = getTime() + ": " + str+"\n";
|
||||
var log = document.getElementById('log');
|
||||
log.value = str + log.value;
|
||||
}
|
||||
|
||||
function getMsgs() {
|
||||
var http = ajaxConnect();
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
//log("getMsgs: len > 0");
|
||||
log("getMsgs: " + resp);
|
||||
queueMsgs(resp);
|
||||
// Since getMsgs returns (a call back is called later)
|
||||
// this is tail recursive friendly
|
||||
getMsgs();
|
||||
});
|
||||
ajaxSend(http, "cmd=getMsgs\n\n", retfn);
|
||||
}
|
||||
|
||||
function connectedTo(addr) {
|
||||
if (addr == localNodeAddr)
|
||||
return true;
|
||||
for(i = 0; i < connections.length; i++) {
|
||||
if (connections[i] == addr)
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
function addConnection(addr) {
|
||||
if(!connectedTo(addr)) {
|
||||
connections[connections.length] = addr;
|
||||
numberOfNodes++;
|
||||
return true;
|
||||
} else
|
||||
return false;
|
||||
}
|
||||
|
||||
function genNodeList() {
|
||||
var str = "";//localNodeAddr+",";
|
||||
for (var i =0; i < connections.length; i++) {
|
||||
str += connections[i] + ",";
|
||||
}
|
||||
if (connections.length > 0)
|
||||
str = str.substring(0,str.length-1);
|
||||
return str;
|
||||
}
|
||||
|
||||
function advertiseNewNode(addr) {
|
||||
var m = new Object();
|
||||
m['query'] = "newNode";
|
||||
m['addr'] = addr;
|
||||
bcastMsg(m);
|
||||
}
|
||||
|
||||
function announceDead(addr) {
|
||||
var m = new Object();
|
||||
m['query'] = "deadNode";
|
||||
m['addr'] = addr;
|
||||
bcastMsg(m);
|
||||
}
|
||||
|
||||
function handleNewNode(resp, welcome) {
|
||||
|
||||
if (welcome == null)
|
||||
welcome = false;
|
||||
var addr = resp.addr;
|
||||
//log2("handle new node " + addr + " from " + resp.origin);
|
||||
|
||||
// handles re adding if reloaded html
|
||||
//if (!connectedTo(addr))
|
||||
//{
|
||||
var ret = genNodeList();
|
||||
var n = addConnection(addr);
|
||||
if (welcome == true) {
|
||||
sendDLC(addr);
|
||||
sendWelcome(ret, addr);
|
||||
sendLocks(addr);
|
||||
sendTests(addr);
|
||||
}
|
||||
if (n == true) {
|
||||
sendReqs(addr);
|
||||
advertiseNewNode(addr);
|
||||
}
|
||||
*/
|
||||
|
||||
|
||||
}
|
||||
|
||||
function sendDLC(addr) {
|
||||
var m = new Object();
|
||||
m.query = "DLC";
|
||||
sendMsg(m, addr);
|
||||
}
|
||||
|
||||
function sendReqs(addr) {
|
||||
for(i in lockTrys) {
|
||||
|
|
@ -277,12 +99,6 @@ function sendReqs(addr) {
|
|||
}
|
||||
}
|
||||
|
||||
function sendWelcome(addrList, addr) {
|
||||
var m = new Object();
|
||||
m["query"] = "welcome";
|
||||
m["addrList"] = addrList;
|
||||
sendMsg(m, addr);
|
||||
}
|
||||
|
||||
function sendLocks(addr) {
|
||||
for (var i in testLocks) {
|
||||
|
|
@ -469,7 +285,7 @@ function removeNodeRangeLocks(addr) {
|
|||
}
|
||||
|
||||
function disconnect(addr) {
|
||||
log("--------------DISCONNECT " + addr + "----------");
|
||||
/* log("--------------DISCONNECT " + addr + "----------");
|
||||
// remove from connections list
|
||||
for (var i=0; i < connections.length; i++) {
|
||||
if (connections[i] == addr) {
|
||||
|
|
@ -477,7 +293,7 @@ function disconnect(addr) {
|
|||
numberOfNodes--;
|
||||
break;
|
||||
}
|
||||
}
|
||||
}*/
|
||||
// remove locks
|
||||
// test locks
|
||||
for(var i in testLocks) {
|
||||
|
|
@ -492,48 +308,9 @@ function disconnect(addr) {
|
|||
removeNodeRangeLocks(addr);
|
||||
|
||||
log("disconnect: freeing range locks");
|
||||
|
||||
|
||||
}
|
||||
|
||||
function sendMsg(m, addr, time, mtype) {
|
||||
if(time == null)
|
||||
time = dlc;
|
||||
if(mtype == null)
|
||||
mtype = "single";
|
||||
|
||||
var str = "cmd=sendMsg\n";
|
||||
str += "origin=" + localNodeAddr + "\n";
|
||||
str += "dlc=" + time + "\n";
|
||||
str += "mtype=" + mtype + "\n";
|
||||
|
||||
str += packObject(m);
|
||||
|
||||
str += "\n";
|
||||
log ("SEND: " + str);
|
||||
|
||||
var http = ajaxConnect();
|
||||
var retfn = returnfn(http, null,
|
||||
function() {
|
||||
disconnect(addr);
|
||||
announceDead(addr);
|
||||
log("ERROR> message to " + addr + " not delivered: '" + str + "'");
|
||||
});
|
||||
|
||||
ajaxSend(http, str, retfn, addr);
|
||||
}
|
||||
|
||||
function bcastMsg(m) {
|
||||
if (m.query != "heartBeat")
|
||||
dlc ++;
|
||||
//log("BCAST conLen: " + connections.length);
|
||||
for(var i=0; i < connections.length; i++) {
|
||||
log("bcast "+ i +" " + m.query + " to " + connections[i] + " dlc:" + dlc);
|
||||
sendMsg(m, connections[i], dlc, "bcast");
|
||||
//log("back from sendMsg, i:" + i + " conlen:" + connections.length);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
function encodeStr(str) {
|
||||
var res="";
|
||||
|
|
@ -573,69 +350,19 @@ function decodeStr(str) {
|
|||
return res;
|
||||
}
|
||||
|
||||
function addMsg(resp) {
|
||||
//log("addMsg mdlc: " + resp.dlc + " mqlen: " + msgQ.length + " type:" + resp.mtype + " query: " + resp.query);
|
||||
for(var i=msgQ.length-1; i>=0; i--) {
|
||||
//log("resp.dlc:" + resp.dlc + " msgQ[i].dlc:" + msgQ[i].dlc);
|
||||
if (resp.dlc > msgQ[i].dlc) {
|
||||
//log("moving " + i + " to " + (i+1));
|
||||
msgQ[i+1] = msgQ[i];
|
||||
} else {
|
||||
//log("first, moving " + i + " to " + (i+1));
|
||||
//msgQ[i+1] = msgQ[i];
|
||||
//log("putting msg in " + i + " + 1, RETURN");
|
||||
msgQ[i+1] = resp;
|
||||
return;
|
||||
}
|
||||
}
|
||||
//log("END: putting msg in 0");
|
||||
msgQ[0] = resp;
|
||||
}
|
||||
|
||||
function queueMsgs(mstr) {
|
||||
log("GOT messages: " + mstr);
|
||||
var resps = mstr.split("\n\n");
|
||||
for(var rcount=0; rcount < resps.length; rcount++) {
|
||||
var resp = resps[rcount];
|
||||
if (resp == "")
|
||||
continue;
|
||||
resp = parseResp(resp);
|
||||
if (resp.query == "DLC") {
|
||||
dlc = resp.dlc;
|
||||
//var m = new Object();
|
||||
//m.query = "DLC";
|
||||
//bcastMsg(m);
|
||||
} else {
|
||||
addMsg(resp);
|
||||
}
|
||||
}
|
||||
var s = "QUEUE: "
|
||||
for (var i =0; i< msgQ.length; i++) {
|
||||
s += msgQ[i].dlc + " ";
|
||||
}
|
||||
log(s);
|
||||
log("mqlen:" + msgQ.length);
|
||||
while (msgQ.length>0 && ((msgQ[msgQ.length-1].dlc - 1) <= dlc)) {
|
||||
var r = msgQ.pop();
|
||||
log("mdlc: " + r.dlc + " dlc: " + dlc + " mqlen: " + msgQ.length + " type:" + r.mtype + " query: " + r.query);
|
||||
if (r.mtype == "bcast")
|
||||
dlc = r.dlc
|
||||
processMsg(r);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
function processMsg(resp) {
|
||||
if (resp["query"] == "join_network") {
|
||||
log("Message join_network received");
|
||||
handleNewNode(resp, true);
|
||||
} else if (resp["query"] == "welcome") {
|
||||
handleWelcome(resp);
|
||||
} else if (resp["query"] == "newNode") {
|
||||
//addConnection(resp["addr"]);
|
||||
handleNewNode(resp, false);
|
||||
} else if (resp["query"] == "deadNode") {
|
||||
disconnect(resp["addr"]);
|
||||
// if (resp["query"] == "join_network") {
|
||||
// log("Message join_network received");
|
||||
// handleNewNode(resp, true);
|
||||
// } else if (resp["query"] == "welcome") {
|
||||
// handleWelcome(resp);
|
||||
// } else if (resp["query"] == "newNode") {
|
||||
// //addConnection(resp["addr"]);
|
||||
// handleNewNode(resp, false);
|
||||
// } else if (resp["query"] == "deadNode") {
|
||||
// disconnect(resp["addr"]);
|
||||
} else if(resp["query"] == "addLock") {
|
||||
handleAddLock(resp);
|
||||
} else if (resp["query"] == "getLock") {
|
||||
|
|
@ -650,120 +377,16 @@ function processMsg(resp) {
|
|||
handleActivateJob(resp);
|
||||
} else if(resp["query"] == "results") {
|
||||
handleResults(resp);
|
||||
} else if(resp["query"] == "new_network") {
|
||||
join_network(resp["addr"], false);
|
||||
} else if(resp["query"] == "heartBeat") {
|
||||
// do nothing;
|
||||
// } else if(resp["query"] == "new_network") {
|
||||
// join_network(resp["addr"], false);
|
||||
// } else if(resp["query"] == "heartBeat") {
|
||||
// // do nothing;
|
||||
return;
|
||||
} else {
|
||||
log("Error: Unkown message '" + resp["query"] + "' received from " + resp["origin"]);
|
||||
}
|
||||
}
|
||||
|
||||
function handleWelcome(resp) {
|
||||
log("Welcome message received");
|
||||
//var myNodes = genNodeList();
|
||||
addConnection(resp['origin']);
|
||||
if (resp['addrList']){
|
||||
var nodes = resp['addrList'].split(",");
|
||||
for(var i=0; i < nodes.length; i++){
|
||||
addConnection(nodes[i]);
|
||||
}
|
||||
}
|
||||
|
||||
for(var i =0; i< connections.length; i++) {
|
||||
var addr = connections[i];
|
||||
if (addr == localNodeAddr)
|
||||
continue;
|
||||
|
||||
advertiseNewNode(addr);
|
||||
}
|
||||
}
|
||||
|
||||
function extractHost(url) {
|
||||
// http: or file:
|
||||
var host = url.substr(5);
|
||||
while (host.charAt(0) == '/')
|
||||
host = host.substr(1);
|
||||
var end = host.indexOf('/');
|
||||
|
||||
if (end > 0 )
|
||||
host = host.substr(0, end);
|
||||
return host;
|
||||
|
||||
}
|
||||
|
||||
|
||||
function setStatus() {
|
||||
document.getElementById('numberOfNodes').innerHTML = "Number of nodes: " + numberOfNodes;
|
||||
document.getElementById('connections').innerHTML = "Connected to: " + genNodeList();
|
||||
document.getElementById('dlc').innerHTML = "DLC: " + dlc;
|
||||
}
|
||||
|
||||
function init() {
|
||||
if (connected == false)
|
||||
return;
|
||||
numberOfNodes = 1;
|
||||
if (originURL.substr(0, 4) == "file") {
|
||||
// we are the first
|
||||
//numberOfNodes = 1; // ourself
|
||||
log("Loaded from file");
|
||||
// now we sit and wait
|
||||
} else { // it was http, so we were loaded from another node
|
||||
log("Loaded from " + originURL);
|
||||
originAddress = extractHost(originURL);
|
||||
|
||||
join_network(originAddress);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
function parseResp(resp) {
|
||||
var lines = resp.split("\n");
|
||||
var arr = [];
|
||||
for(var i=0; i < lines.length; i++) {
|
||||
//var kv = lines[i].split("=");
|
||||
var mid = lines[i].indexOf("=");
|
||||
var kv = new Array();
|
||||
kv[0] = lines[i].substring(0, mid);
|
||||
kv[1] = lines[i].substring(mid+1);
|
||||
if (kv[1] == "true")
|
||||
kv[1] = true;
|
||||
else if(kv[0] == "false")
|
||||
kv[1] = false;
|
||||
else if (kv[0] == "dlc" ||
|
||||
kv[0] == "start" ||
|
||||
kv[0] == "end" ||
|
||||
kv[0] == "min" ||
|
||||
kv[0] == "max")
|
||||
kv[1] = Number(kv[1]);
|
||||
else if (kv[0] == "results")
|
||||
kv[1] = unpackResults(kv[1]);
|
||||
arr[kv[0]] = kv[1];
|
||||
}
|
||||
return arr;
|
||||
}
|
||||
|
||||
|
||||
function join_network(address, bcast) {
|
||||
if(bcast == null) {
|
||||
bcast = true;
|
||||
}
|
||||
log("join_network -> " + address);
|
||||
var m = new Object();
|
||||
m["query"] = "join_network";
|
||||
m["addr"] = localNodeAddr;
|
||||
//m["nodes"] = genNodeList();
|
||||
sendMsg(m, address);
|
||||
if (bcast == true) {
|
||||
m = new Object();
|
||||
m["query"] = "new_network";
|
||||
m["addr"] = address;
|
||||
bcastMsg(m);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
var runCount = 0;
|
||||
var workMod = 1;
|
||||
|
|
@ -816,7 +439,7 @@ function cron() {
|
|||
if (runCount % 10 == 0) {
|
||||
ping();
|
||||
//getLog();
|
||||
setStatus();
|
||||
//setStatus();
|
||||
checkLocks();
|
||||
updateTestsStatus();
|
||||
if ( doneStage == 1 ) {
|
||||
|
|
@ -836,46 +459,16 @@ function cron() {
|
|||
if (runCount % 20 == 0)
|
||||
updateResults();
|
||||
|
||||
if (runCount % 300 == 0)
|
||||
heartBeat();
|
||||
//if (runCount % 300 == 0)
|
||||
// heartBeat();
|
||||
|
||||
// 180 seconds, or 3 minutes
|
||||
if (runCount == 1800)
|
||||
/*if (runCount == 1800)
|
||||
runCount = 0;
|
||||
runCount++;
|
||||
runCount++; */
|
||||
}
|
||||
|
||||
function heartBeat() {
|
||||
var m = new Object();
|
||||
m.query = "heartBeat";
|
||||
bcastMsg(m);
|
||||
}
|
||||
|
||||
function reloadHTML() {
|
||||
var http = ajaxConnect();
|
||||
var retfn = returnfn(http);
|
||||
ajaxSend(http, "cmd=reloadHTML\n\n",retfn);
|
||||
}
|
||||
|
||||
function poke() {
|
||||
var http = ajaxConnect();
|
||||
document.getElementById("pingNodeResp").innerHTML = "";
|
||||
var dest = document.getElementById("pingNode").value;
|
||||
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
document.getElementById("pingNodeResp").innerHTML += resp + "<br>";
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
document.getElementById("pingNodeResp").innerHTML += resp + "<br>";
|
||||
});
|
||||
ajaxSend(http, "cmd=greet\n\n", retfn, dest);
|
||||
});
|
||||
|
||||
ajaxSend(http, "cmd=ping\n\n", retfn, dest);
|
||||
|
||||
|
||||
}
|
||||
|
||||
function setTestStatus(str, col) {
|
||||
var e = document.getElementById('testStatus');
|
||||
|
|
@ -1851,9 +1444,7 @@ function updateFinalResults() {
|
|||
|
||||
|
||||
|
||||
var cronID = setInterval("cron()", 100);
|
||||
getMsgs();
|
||||
getLog();
|
||||
|
||||
|
||||
|
||||
function page(p) {
|
||||
|
|
|
|||
|
|
@ -0,0 +1,647 @@
|
|||
/* cortex.js
|
||||
* AUTHOR
|
||||
* LICENSE
|
||||
*
|
||||
* NOTES
|
||||
*/
|
||||
|
||||
/* HTML elements used
|
||||
* cortexLog - textarea
|
||||
* statusLabel - div
|
||||
* numberOfNodes - div
|
||||
* connections -div
|
||||
* dlc - div
|
||||
*/
|
||||
|
||||
/***** Ajax Basics *****/
|
||||
|
||||
var port = location.href.substring( location.href.substring(7).indexOf(':')+8,
|
||||
location.href.substring(7).indexOf('/')+7);
|
||||
|
||||
// Returns an ajax object
|
||||
function ajaxConnect() {
|
||||
var http = null;
|
||||
if(window.XMLHttpRequest)
|
||||
http = new XMLHttpRequest();
|
||||
else if (window.ActiveXObject)
|
||||
http = new ActiveXObject("Microsoft.XMLHTTP");
|
||||
return http;
|
||||
}
|
||||
|
||||
/* returns a function that can be passed to http.send
|
||||
* that runs code fn on successful response
|
||||
* Kind of a macro function builder
|
||||
* http: ajax object
|
||||
* fn: function taking one argument, the resp from the server,
|
||||
* this function is run on a successful ajax call
|
||||
* err: OPTIONAL argument that contains a funtion
|
||||
* to be run if the connection failed
|
||||
*/
|
||||
function returnfn(http, fn, err) {
|
||||
if (!fn)
|
||||
fn = function(resp) {};
|
||||
if (!err)
|
||||
err = function() {};
|
||||
return function() {
|
||||
if (http.readyState == 4) {
|
||||
if (http.responseText == '')
|
||||
err();
|
||||
else
|
||||
fn(http.responseText);
|
||||
}
|
||||
};
|
||||
}
|
||||
|
||||
/* Does ajax magic. Makes ajax call with data and sets up
|
||||
* retfn to be called on response
|
||||
* forward is the final destination address of the call if
|
||||
* it is not this local
|
||||
*/
|
||||
function ajaxSend(http, data, retfn, forward) {
|
||||
if (!forward)
|
||||
forward = '';
|
||||
http.onreadystatechange = retfn;
|
||||
http.open('POST', "http://localhost:"+port+"/"+ forward, true);
|
||||
http.setRequestHeader('Content-Type', 'application/x-www-form-urlencoded');
|
||||
http.send(data);
|
||||
}
|
||||
|
||||
/***** Utility Functions *****/
|
||||
|
||||
|
||||
|
||||
// make sure a number is two digits long, padding 0 on front
|
||||
function d2(str) {
|
||||
if (str <10)
|
||||
return "0"+str;
|
||||
else
|
||||
return str;
|
||||
}
|
||||
|
||||
// generate the time as a string
|
||||
function getTime() {
|
||||
var date = new Date();
|
||||
return d2(date.getHours()) + ":" + d2(date.getMinutes()) + ":" + d2(date.getSeconds())
|
||||
}
|
||||
|
||||
function extractHost(url) {
|
||||
// http: or file:
|
||||
var host = url.substr(5);
|
||||
while (host.charAt(0) == '/')
|
||||
host = host.substr(1);
|
||||
var end = host.indexOf('/');
|
||||
|
||||
if (end > 0 )
|
||||
host = host.substr(0, end);
|
||||
return host;
|
||||
|
||||
}
|
||||
|
||||
//var logCheckElem = null;
|
||||
var logging = false;
|
||||
|
||||
function log(str) {
|
||||
//if (logCheckElem == null)
|
||||
// logCheckElem = document.getElementById("logCheck");
|
||||
if (logging) { //logCheckElem.checked == true) {
|
||||
str = getTime() + ": " + str+"\n";
|
||||
var log = document.getElementById('cortexLog');
|
||||
if(log)
|
||||
log.value = str + log.value;
|
||||
}
|
||||
}
|
||||
|
||||
function error(msg) {
|
||||
log("ERROR: " + msg);
|
||||
alert("ERROR: " + msg);
|
||||
clearInterval(cronID); // Shuts down cron
|
||||
}
|
||||
|
||||
|
||||
/***** Basic Server Communication *****/
|
||||
|
||||
var localNodeAddr = '';
|
||||
var originURL = 'Unknown Source';
|
||||
var connected = false;
|
||||
var numberOfNodes = 0;
|
||||
var connections = new Array();
|
||||
|
||||
var dlc = 0;
|
||||
var msgQ = new Array();
|
||||
|
||||
/* basic ping function for local node
|
||||
* if successful,
|
||||
* if we haven't greeted the server, we do,
|
||||
* otherwise nothing (just a heartbeat)
|
||||
* if it fails, lets the user know we have lost
|
||||
* connection to the node server
|
||||
*/
|
||||
function ping() {
|
||||
var http = ajaxConnect();
|
||||
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
if (!connected) {
|
||||
connected = true;
|
||||
greet();
|
||||
}
|
||||
},
|
||||
function(resp) {
|
||||
connected = false;
|
||||
var html = "Connection to local Node failed. Try reloading from <a href=\"" + originURL + "\" target=\"window\">" + originURL + "</a>";
|
||||
stl = document.getElementById('statusLabel');
|
||||
if (stl)
|
||||
stl.innerHTML = html;
|
||||
}
|
||||
|
||||
);
|
||||
|
||||
ajaxSend(http, "cmd=ping\n\n", retfn);
|
||||
}
|
||||
|
||||
function init() {
|
||||
if (connected == false)
|
||||
return;
|
||||
numberOfNodes = 1;
|
||||
if (originURL.substr(0, 4) == "file") {
|
||||
// we are the first
|
||||
//numberOfNodes = 1; // ourself
|
||||
log("Loaded from file");
|
||||
// now we sit and wait
|
||||
} else { // it was http, so we were loaded from another node
|
||||
log("Loaded from " + originURL);
|
||||
originAddress = extractHost(originURL);
|
||||
join_network(originAddress);
|
||||
}
|
||||
}
|
||||
|
||||
/* Greets the server
|
||||
* so far just gets the server's IP and origin URL
|
||||
*/
|
||||
function greet() {
|
||||
var http = ajaxConnect();
|
||||
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
var arr = resp.split(" ");
|
||||
localNodeAddr = arr[0];
|
||||
originURL = arr[1];
|
||||
stl = document.getElementById('statusLabel');
|
||||
if (stl)
|
||||
stl.innerHTML = "I am <b>" + localNodeAddr + "</b>";
|
||||
init();
|
||||
}
|
||||
);
|
||||
ajaxSend(http, "cmd=greet\n\n", retfn);
|
||||
}
|
||||
|
||||
// Kill the server
|
||||
function killServer() {
|
||||
announceDead(localNodeAddr);
|
||||
var http = ajaxConnect();
|
||||
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
// got a resp, server not dead
|
||||
killServer();
|
||||
});
|
||||
ajaxSend(http, "cmd=kill\n\n", retfn);
|
||||
}
|
||||
|
||||
// Get the latest server logs
|
||||
function getLog() {
|
||||
var http = ajaxConnect();
|
||||
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
var log = document.getElementById('cortexLog');
|
||||
if (log)
|
||||
log.value = resp + log.value;
|
||||
// Since getLog returns (a call back is called later)
|
||||
// this is tail recursive friendly
|
||||
getLog();
|
||||
});
|
||||
ajaxSend(http, "cmd=getLog\n\n", retfn);
|
||||
}
|
||||
|
||||
/***** Messeging between nodes *****/
|
||||
|
||||
var msgHandlers = new Array();
|
||||
|
||||
function addMsgHandler(msgName, handlerFN, handlerReplace) {
|
||||
e = msgHandlers[msgName];
|
||||
if (!e || handlerReplace) {
|
||||
msgHandlers[msgName] = [handlerFN, null];
|
||||
} else {
|
||||
i = 0;
|
||||
while (e[i] != null) {
|
||||
i++;
|
||||
}
|
||||
e[i] = handlerFN;
|
||||
e[i+1] = null;
|
||||
}
|
||||
}
|
||||
|
||||
function getMsgHandler(msgName) {
|
||||
return msgHandlers[msgName];
|
||||
}
|
||||
|
||||
|
||||
function processMsg(resp) {
|
||||
handler = getMsgHandler(resp["query"]);
|
||||
if (handler) {
|
||||
handler(resp);
|
||||
} else {
|
||||
log("Error: Unkown message '" + resp["query"] + "' received from " + resp["origin"]);
|
||||
}
|
||||
}
|
||||
|
||||
function sendMsg(m, addr, time, mtype) {
|
||||
if(time == null)
|
||||
time = dlc;
|
||||
if(mtype == null)
|
||||
mtype = "single";
|
||||
|
||||
var str = "cmd=sendMsg\n";
|
||||
str += "origin=" + localNodeAddr + "\n";
|
||||
str += "dlc=" + time + "\n";
|
||||
str += "mtype=" + mtype + "\n";
|
||||
|
||||
str += packObject(m);
|
||||
|
||||
str += "\n";
|
||||
log ("SEND: " + str);
|
||||
|
||||
var http = ajaxConnect();
|
||||
var retfn = returnfn(http, null,
|
||||
function() {
|
||||
disconnect(addr);
|
||||
announceDead(addr);
|
||||
log("ERROR> message to " + addr + " not delivered: '" + str + "'");
|
||||
});
|
||||
|
||||
ajaxSend(http, str, retfn, addr);
|
||||
}
|
||||
|
||||
function bcastMsg(m) {
|
||||
if (m.query != "heartBeat")
|
||||
dlc ++;
|
||||
//log("BCAST conLen: " + connections.length);
|
||||
for(var i=0; i < connections.length; i++) {
|
||||
log("bcast "+ i +" " + m.query + " to " + connections[i] + " dlc:" + dlc);
|
||||
sendMsg(m, connections[i], dlc, "bcast");
|
||||
//log("back from sendMsg, i:" + i + " conlen:" + connections.length);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
function addMsg(resp) {
|
||||
|
||||
for(var i=msgQ.length-1; i>=0; i--) {
|
||||
|
||||
if (resp.dlc > msgQ[i].dlc) {
|
||||
msgQ[i+1] = msgQ[i];
|
||||
} else {
|
||||
msgQ[i+1] = resp;
|
||||
return;
|
||||
}
|
||||
}
|
||||
msgQ[0] = resp;
|
||||
}
|
||||
|
||||
function parseResp(resp) {
|
||||
var lines = resp.split("\n");
|
||||
var arr = [];
|
||||
for(var i=0; i < lines.length; i++) {
|
||||
//var kv = lines[i].split("=");
|
||||
var mid = lines[i].indexOf("=");
|
||||
var kv = new Array();
|
||||
kv[0] = lines[i].substring(0, mid);
|
||||
kv[1] = lines[i].substring(mid+1);
|
||||
if (kv[1] == "true")
|
||||
kv[1] = true;
|
||||
else if(kv[0] == "false")
|
||||
kv[1] = false;
|
||||
else if (kv[0] == "dlc" ||
|
||||
kv[0] == "start" ||
|
||||
kv[0] == "end" ||
|
||||
kv[0] == "min" ||
|
||||
kv[0] == "max")
|
||||
kv[1] = Number(kv[1]);
|
||||
else if (kv[0] == "results")
|
||||
kv[1] = unpackResults(kv[1]);
|
||||
arr[kv[0]] = kv[1];
|
||||
}
|
||||
return arr;
|
||||
}
|
||||
|
||||
function queueMsgs(mstr) {
|
||||
log("GOT messages: " + mstr);
|
||||
var resps = mstr.split("\n\n");
|
||||
for(var rcount=0; rcount < resps.length; rcount++) {
|
||||
var resp = resps[rcount];
|
||||
if (resp == "")
|
||||
continue;
|
||||
resp = parseResp(resp);
|
||||
if (resp.query == "DLC") {
|
||||
dlc = resp.dlc;
|
||||
//var m = new Object();
|
||||
//m.query = "DLC";
|
||||
//bcastMsg(m);
|
||||
} else {
|
||||
addMsg(resp);
|
||||
}
|
||||
}
|
||||
var s = "QUEUE: "
|
||||
for (var i =0; i< msgQ.length; i++) {
|
||||
s += msgQ[i].dlc + " ";
|
||||
}
|
||||
log(s);
|
||||
log("mqlen:" + msgQ.length);
|
||||
while (msgQ.length>0 && ((msgQ[msgQ.length-1].dlc - 1) <= dlc)) {
|
||||
var r = msgQ.pop();
|
||||
log("mdlc: " + r.dlc + " dlc: " + dlc + " mqlen: " + msgQ.length + " type:" + r.mtype + " query: " + r.query);
|
||||
if (r.mtype == "bcast")
|
||||
dlc = r.dlc
|
||||
processMsg(r);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
function getMsgs() {
|
||||
var http = ajaxConnect();
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
log("getMsgs: " + resp);
|
||||
queueMsgs(resp);
|
||||
// Since getMsgs returns (a call back is called later)
|
||||
// this is tail recursive friendly
|
||||
getMsgs();
|
||||
});
|
||||
ajaxSend(http, "cmd=getMsgs\n\n", retfn);
|
||||
}
|
||||
|
||||
|
||||
/***** P2P Network Communication *****/
|
||||
|
||||
function connectedTo(addr) {
|
||||
if (addr == localNodeAddr)
|
||||
return true;
|
||||
for(i = 0; i < connections.length; i++) {
|
||||
if (connections[i] == addr)
|
||||
return true;
|
||||
}
|
||||
return false;
|
||||
}
|
||||
|
||||
function addConnection(addr) {
|
||||
if(!connectedTo(addr)) {
|
||||
connections[connections.length] = addr;
|
||||
numberOfNodes++;
|
||||
return true;
|
||||
} else
|
||||
return false;
|
||||
}
|
||||
|
||||
function join_network(address, bcast) {
|
||||
if(bcast == null) {
|
||||
bcast = true;
|
||||
}
|
||||
log("join_network -> " + address);
|
||||
var m = new Object();
|
||||
m["query"] = "join_network";
|
||||
m["addr"] = localNodeAddr;
|
||||
//m["nodes"] = genNodeList();
|
||||
sendMsg(m, address);
|
||||
if (bcast == true) {
|
||||
m = new Object();
|
||||
m["query"] = "new_network";
|
||||
m["addr"] = address;
|
||||
bcastMsg(m);
|
||||
}
|
||||
}
|
||||
|
||||
function genNodeList() {
|
||||
var str = "";//localNodeAddr+",";
|
||||
for (var i =0; i < connections.length; i++) {
|
||||
str += connections[i] + ",";
|
||||
}
|
||||
if (connections.length > 0)
|
||||
str = str.substring(0,str.length-1);
|
||||
return str;
|
||||
}
|
||||
|
||||
function advertiseNewNode(addr) {
|
||||
var m = new Object();
|
||||
m['query'] = "newNode";
|
||||
m['addr'] = addr;
|
||||
bcastMsg(m);
|
||||
}
|
||||
|
||||
function announceDead(addr) {
|
||||
var m = new Object();
|
||||
m['query'] = "deadNode";
|
||||
m['addr'] = addr;
|
||||
bcastMsg(m);
|
||||
}
|
||||
|
||||
function sendDLC(addr) {
|
||||
var m = new Object();
|
||||
m.query = "DLC";
|
||||
sendMsg(m, addr);
|
||||
}
|
||||
|
||||
function sendWelcome(addrList, addr) {
|
||||
var m = new Object();
|
||||
m["query"] = "welcome";
|
||||
m["addrList"] = addrList;
|
||||
sendMsg(m, addr);
|
||||
}
|
||||
|
||||
function heartBeat() {
|
||||
var m = new Object();
|
||||
m.query = "heartBeat";
|
||||
bcastMsg(m);
|
||||
}
|
||||
|
||||
function reloadHTML() {
|
||||
var http = ajaxConnect();
|
||||
var retfn = returnfn(http);
|
||||
ajaxSend(http, "cmd=reloadHTML\n\n",retfn);
|
||||
}
|
||||
|
||||
/*
|
||||
function poke() {
|
||||
var http = ajaxConnect();
|
||||
document.getElementById("pingNodeResp").innerHTML = "";
|
||||
var dest = document.getElementById("pingNode").value;
|
||||
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
document.getElementById("pingNodeResp").innerHTML += resp + "<br>";
|
||||
var retfn = returnfn(http,
|
||||
function(resp) {
|
||||
document.getElementById("pingNodeResp").innerHTML += resp + "<br>";
|
||||
});
|
||||
ajaxSend(http, "cmd=greet\n\n", retfn, dest);
|
||||
});
|
||||
|
||||
ajaxSend(http, "cmd=ping\n\n", retfn, dest);
|
||||
|
||||
|
||||
}
|
||||
*/
|
||||
|
||||
/***** Msg Handlers *****/
|
||||
|
||||
function handleNewNode(resp, welcome) {
|
||||
|
||||
if (welcome == null)
|
||||
welcome = false;
|
||||
var addr = resp.addr;
|
||||
//log2("handle new node " + addr + " from " + resp.origin);
|
||||
|
||||
// handles re adding if reloaded html
|
||||
//if (!connectedTo(addr))
|
||||
//{
|
||||
var ret = genNodeList();
|
||||
var n = addConnection(addr);
|
||||
if (welcome == true) {
|
||||
sendDLC(addr);
|
||||
sendWelcome(ret, addr);
|
||||
//sendLocks(addr);
|
||||
//sendTests(addr);
|
||||
}
|
||||
if (n == true) {
|
||||
//sendReqs(addr);
|
||||
advertiseNewNode(addr);
|
||||
}
|
||||
}
|
||||
|
||||
addMsgHandler( "join_network",
|
||||
function (resp) {
|
||||
handleNewNode(resp, true);
|
||||
});
|
||||
|
||||
addMsgHandler( "newNode",
|
||||
function (resp) {
|
||||
handleNewNode(resp, false);
|
||||
});
|
||||
|
||||
addMsgHandler( "welcome",
|
||||
function (resp) {
|
||||
log("Welcome message received");
|
||||
//var myNodes = genNodeList();
|
||||
addConnection(resp['origin']);
|
||||
if (resp['addrList']){
|
||||
var nodes = resp['addrList'].split(",");
|
||||
for(var i=0; i < nodes.length; i++){
|
||||
addConnection(nodes[i]);
|
||||
}
|
||||
}
|
||||
|
||||
for(var i =0; i< connections.length; i++) {
|
||||
var addr = connections[i];
|
||||
if (addr == localNodeAddr)
|
||||
continue;
|
||||
|
||||
advertiseNewNode(addr);
|
||||
}
|
||||
});
|
||||
|
||||
addMessageHandler( "deadNode",
|
||||
function (resp) {
|
||||
var addr = resp['addr'];
|
||||
log("--------------DISCONNECT " + addr + "----------");
|
||||
// remove from connumberOfNodesnections list
|
||||
for (var i=0; i < connections.length; i++) {
|
||||
if (connections[i] == addr) {
|
||||
connections.splice(i,1);
|
||||
numberOfNodes--;
|
||||
break;
|
||||
}
|
||||
}
|
||||
});
|
||||
|
||||
addMessageHandler( "new_network",
|
||||
function (resp) {
|
||||
join_network(resp["addr"], false);
|
||||
});
|
||||
|
||||
addMessageHandler( "heartBeat",
|
||||
function (resp) {
|
||||
// do nothing
|
||||
});
|
||||
|
||||
|
||||
/***** CRON System *****/
|
||||
|
||||
var cronTabs = new Array();
|
||||
|
||||
/* add a function to be called repeatedly
|
||||
* interval - in 1/10s of a second
|
||||
* fn - function to be called
|
||||
*/
|
||||
function addCronTab(interval, fn) {
|
||||
tab = cronTabs[interval];
|
||||
if (!tab) {
|
||||
crontabs[interval] = [fn, null];
|
||||
} else {
|
||||
i = 0;
|
||||
while(crontabs[i]) {
|
||||
i++;
|
||||
}
|
||||
crontabs[i] = fn;
|
||||
crontabs[i+1]=null;
|
||||
}
|
||||
}
|
||||
|
||||
var cronI = 0;
|
||||
|
||||
function cron() {
|
||||
if (connected == false)
|
||||
return;
|
||||
|
||||
for (time in cronTabs) {
|
||||
i = Number(time);
|
||||
if (cronI % i == 0) {
|
||||
tab = cronTabs[time];
|
||||
j=0;
|
||||
while(tab[j]) {
|
||||
tab[j]();
|
||||
}
|
||||
}
|
||||
}
|
||||
cronI++;
|
||||
// Reset to 0 after a day
|
||||
if (cronI > 86400) {
|
||||
cronI = 0;
|
||||
}
|
||||
|
||||
addCronTab(10, ping);
|
||||
addCronTab(300, heatbeat);
|
||||
|
||||
|
||||
/***** UI *****/
|
||||
function setStatus() {
|
||||
var nn = document.getElementById('numberOfNodes');
|
||||
if (nn)
|
||||
nn.innerHTML = "Number of nodes: " + numberOfNodes;
|
||||
var c = document.getElementById('connections');
|
||||
if (c)
|
||||
c.innerHTML = "Connected to: " + genNodeList();
|
||||
var dlcE = document.getElementById('dlc');
|
||||
if (dlvE)
|
||||
dlcE.innerHTML = "DLC: " + dlc;
|
||||
}
|
||||
|
||||
addCronTab(10, setStatus);
|
||||
|
||||
/**** INIT *****/
|
||||
|
||||
function cortex_start() {
|
||||
ping();
|
||||
var cronID = setInterval("cron()", 100);
|
||||
getMsgs();
|
||||
getLog();
|
||||
}
|
||||
12
shell.html
12
shell.html
|
|
@ -8,19 +8,9 @@
|
|||
<script>
|
||||
function load() {
|
||||
port = document.getElementById('port').value;
|
||||
document.getElementById('client').src = "http://localhost:" + port + "/client.html";
|
||||
document.getElementById('client').src = "http://localhost:" + port + "/basicClient.html";
|
||||
}
|
||||
|
||||
function isLoaded() {
|
||||
if(document.getElementById('cortex').isActive())
|
||||
{
|
||||
load();
|
||||
clearInterval();
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
|
||||
</script>
|
||||
</head>
|
||||
<body>
|
||||
|
|
|
|||
Loading…
Reference in New Issue