From 65cbf5578322b89ed5df47a9b74ef6b09ab6c354 Mon Sep 17 00:00:00 2001
From: howthebodyworks <git@email.possumpalace.org>
Date: Sat, 18 Aug 2012 02:10:45 +1000
Subject: [PATCH] optionally log swarm activity to network

---
 optimisation/swarm/swarm.sc | 22 +++++++++++++++++++++-
 psosynth.scd                |  2 ++
 2 files changed, 23 insertions(+), 1 deletion(-)

diff --git a/optimisation/swarm/swarm.sc b/optimisation/swarm/swarm.sc
index e54b88f..efc555e 100644
--- a/optimisation/swarm/swarm.sc
+++ b/optimisation/swarm/swarm.sc
@@ -42,7 +42,10 @@ PSOptimisingSwarm {
 	
 	//flag to stop iterator gracefuly.
 	var playing = false;
-
+	
+	var <>swarmName = "swarm";
+	var netSender = nil;
+	var <netAddr = nil;
 	/*
 	Here are the variables that hold the operator functions.
 	Paths are coerced to functions at instantiation time to avoid problems with
@@ -268,6 +271,7 @@ PSOptimisingSwarm {
 			bestKnownFitnessTable[phenotype] = myBestFitness;			
 		});
 		this.updateStatistics;
+		netSender.value;
 		iterations = iterations + 1;
 	}
 	setParam {|statekey, stateval|
@@ -333,6 +337,22 @@ PSOptimisingSwarm {
 		super.free;
 		controller.free;
 	}
+	net_ {|addr|
+		netAddr = addr;
+		netAddr.isNil.if({
+			netSender = nil;
+		}, {
+			netSender = {
+				var path = "/swarm/%".format(swarmName);
+				var i = 0;
+				cookedFitnessMap.keysValuesDo({|agent,fitness|
+					netAddr.sendMsg(path, i, fitness, *(agent.chromosome));
+					i = i+1;
+				});
+			};
+		});
+		
+	}
 }
 
 PSLocalOptimisingSwarm : PSOptimisingSwarm {
diff --git a/psosynth.scd b/psosynth.scd
index 4ad481e..e254878 100644
--- a/psosynth.scd
+++ b/psosynth.scd
@@ -117,6 +117,8 @@ s.waitForBoot({
 	//~swarm.scoreCooker = #[phenosynth, score_cookers, scale_distance_to_similarity];
 	~swarm.scoreCooker = #[phenosynth, score_cookers, invert_distance_to_similarity];
 	//~swarm.scoreCooker = [\phenosynth, \score_cookers, \reverse_ranked];
+	~net = NetAddr("127.0.0.1", 57130);
+	~swarm.net_(~net);
 	~swarm.play(~control);
 	{
 		~plotState = SwarmGraph.new(~swarm);