calcs_worker.js

var mult=null,
	width=500,
	height=500,
	frame={
		one: {
			alive: {},
			dying: {},
			found: {}
		},
		two: {
			alive: {},
			dying: {},
			found: {}
		}
	},
	frameQueue=[],
	found=false,
	tentative_winner=null,
	winner=false,
	allstop=false,
	eq=50,
	fr = "one",
	nextfr = null,
	teams=null,
	masks=null,
	sendMsg=self.postMessage,
	debug=true,
	startOutput=false,
	genCount=0,
	forceStop=false,
	loopcounter=0,
	rightEdge=null;

var console={};
	
console.log=function(item){
	sendMsg(["consolelog",item]);
};

console.dir=function(item){
	sendMsg(["consoledir",item]);
};

function sendDataChunk(data){
	sendMsg(["recieveDataChunk",data]);
}

self.onmessage=function(event){
	switch(event.data[0])
	{
		case "setMultiplier":
			mult=event.data[1];
			width=(width / mult)|0;
			height=(height / mult)|0;
			rightEdge=width*height;
			masks=[
				[-1, -1,-(height)-1],
				[0, -1,-1],
				[1, -1,(height)-1], 
				[-1, 0,-(height)],
				[1, 0,(height)],
				[-1, 1,-(height)+1],
				[0, 1,1],
				[1, 1,(height)+1]];
			break;
		case "setTeams":
			teams=event.data[1];
			break;
		case "startProcessing":
			run();
			break;
		case "resumeProcessing":
			gameLoop();
			break;
		case "Cells":
			frame.one.alive=event.data[1][0];
			if(event.data[1][1]!=undefined)
				frame.one.dying=event.data[1][1];
			break;
		case "stopProcessing":
			if(debug)
				console.log("Stop Sent");
			allstop=true;
			break;
	}
}

function run(){
	if(debug)
		console.log("Process Started.");
	gameLoop();
}

function gameLoop(){
	iter_count=16;
	while(--iter_count){
		if(allstop || winner)
			break;
		iter();
		fr=(fr=="one"?"two":"one");
	}

	sendDataChunk(frameQueue);
	frameQueue=[];
}

function iter(){
	if(allstop)
		return false;

	nextfr=(fr=="one"?"two":"one");

	found=false;
	tentative_winner=false;

	for(var i in frame[fr].alive)
	{
		analyzeNextLoop(i);
	}

	for(var team in teams){
		if(teams[team].newSpawns!=0)
		{
			if(found)
				tentative_winner=null;
			if(!found)
			{
				tentative_winner=team;
				found=true;
			}
		}
		teams[team].newSpawns=0;
	}

	if(tentative_winner)
		winner=true;

	frame[nextfr].dying=frame[fr].alive;

	if(!winner)
		frameQueue.push([frame[fr].alive,teams,undefined,frame[fr].dying]);
	else
		frameQueue.push([frame[fr].alive,teams,tentative_winner]);

	frame[fr].alive={};
	frame[fr].dying={};
	frame[fr].found={};
}
function analyzeNextLoop(index){
	var x=(index/height) | 0,
		y=index%height,
		team=frame[fr].alive[index]

	outer:
	for(var i2=0,l2=masks.length;i2<l2;++i2){
		var x2=x+masks[i2][0],
			y2=y+masks[i2][1],
			maskIndex=(index | 0)+masks[i2][2];

		if(x2<0)
		{
			x2 += width;
			maskIndex += rightEdge;
		}
		else if(x2 >= width)
		{
			x2 -= width;
			maskIndex -= rightEdge;
		}
		if(y2<0)
		{
			y2 += height;
			maskIndex += height;
		}
		else if(y2 >= height)
		{
			y2 -= height;
			maskIndex -= height;
		}

		if(frame[fr].dying[maskIndex])
			continue;
		if(frame[fr].alive[maskIndex])
			continue;

		if(frame[fr].found[maskIndex]==undefined)
		{
			var count=[];
			inner:
			for(var i=0,l=masks.length;i<l;++i){
				var x4=x2+masks[i][0],
					y4=y2+masks[i][1],
					loopIndex=maskIndex+masks[i][2];

				if(x4<0)
				{
					x4 += width;
					loopIndex += rightEdge;
				}
				else if(x4 >= width)
				{
					x4 -= width;
					loopIndex -= rightEdge;
				}
				if(y4<0)
				{
					y4 += height;
					loopIndex += height;
				}
				else if(y4 >= height)
				{
					y4 -= height;
					loopIndex -= height;
				}

				if(frame[fr].alive[loopIndex]!=undefined){
					count.push(frame[fr].alive[loopIndex]);
					if(count.length==3)
						break inner;
				}
			}

			if(count.length==2){
				frame[fr].found[maskIndex]=true;

				if(count[0]!=count[1]/* && (count[0]!="neutral" || count[1]!="neutral")*/){
					frame[nextfr].alive[maskIndex]="neutral";
					++teams["neutral"].newSpawn;
				}
				else if(count[0]==count[1]){
					frame[nextfr].alive[maskIndex]=team;
					++teams[team].newSpawns;
				}
				
			}
		}
	}
}