update SSSP application to use more aggregators like maximum out-degree

src/nl/vu/cs/amstel/examples/SSSP.java

@@ -1,10 +1,11 @@
 package nl.vu.cs.amstel.examples;
 
 import nl.vu.cs.amstel.Node;
+import nl.vu.cs.amstel.graph.io.LognormGraphGenerator;
 import nl.vu.cs.amstel.graph.io.Reader;
-import nl.vu.cs.amstel.graph.io.WheelGraphGenerator;
 import nl.vu.cs.amstel.user.IntMessage;
 import nl.vu.cs.amstel.user.IntValue;
+import nl.vu.cs.amstel.user.MaxIntAggregator;
 import nl.vu.cs.amstel.user.MinIntAggregator;
 import nl.vu.cs.amstel.user.MinIntCombiner;
 
@@ -31,12 +32,13 @@ public static void main(String args[]) throws Exception {
 			throw new Exception("Source and destination not specified");
 		}
 
-		Reader reader = new WheelGraphGenerator(filename);
+		Reader reader = new LognormGraphGenerator(filename);
 		Node<IntValue, IntValue, IntMessage> node =
 			new Node<IntValue, IntValue, IntMessage>(nodes, SSSPVertex.class,
 					IntValue.class, IntValue.class, IntMessage.class, reader);
 		node.setCombiner(MinIntCombiner.class);
 		node.addAggregator(new MinIntAggregator("Destination"));
+		node.addAggregator(new MaxIntAggregator("Max-Outdegree"));
 		node.run();
 	}
 }

src/nl/vu/cs/amstel/examples/SSSPVertex.java

@@ -17,9 +17,13 @@ public class SSSPVertex extends Vertex<IntValue, IntValue, IntMessage> {
 	public static String SRC = null;
 	public static String DST = null;
 
+	private static IntValue outdegree = new IntValue();
+
 	@Override
 	public void compute(Iterable<IntMessage> messages) {
 		if (getSuperstep() == 0) {
+			outdegree.value = getOutdegree();
+			outputAggregate("Max-Outdegree", outdegree);
 			getValue().value = Integer.MAX_VALUE;
 			return;
 		} else if (getSuperstep() > SP_TH) {

src/nl/vu/cs/amstel/graph/VertexState.java

@@ -83,6 +83,10 @@ public V getValue() {
 		return value;
 	}
 
+	public int getOutdegree() {
+		return edges.length;
+	}
+
 	public String[] getOutEdges() {
 		return edges;
 	}

src/nl/vu/cs/amstel/graph/io/TextFileReader.java

@@ -26,7 +26,7 @@ public class TextFileReader implements Reader {
 	private long fileSize;
 
 	private MappedByteBuffer mappedMem;
-	private ByteArrayOutputStream buffer = new ByteArrayOutputStream();
+	private ByteArrayOutputStream lineBuffer = new ByteArrayOutputStream();
 	private long offset;
 	private long length;
 	private long bytesRead = 0;
@@ -102,14 +102,14 @@ public boolean hasNext() {
 
 	private String readLine() {
 		byte b;
-		buffer.reset();
+		lineBuffer.reset();
 		while ((bytesRead < length) && ((b = mappedMem.get()) != '\n')) {
-			buffer.write(b);
+			lineBuffer.write(b);
 			bytesRead++;
 		}
 		bytesRead++;
 
-		return buffer.toString();		
+		return lineBuffer.toString();		
 	}
 
 	@SuppressWarnings("unchecked")

src/nl/vu/cs/amstel/user/Vertex.java

@@ -49,6 +49,10 @@ public OutEdgeIterator<E> getOutEdgeIterator() {
 		return workerState.edgeIterator;
 	}
 
+	public int getOutdegree() {
+		return state.getOutdegree();
+	}
+
 	public void send(String toVertex, M m) {
 		try {
 			workerState.router.send(toVertex, m);