From e3223b1ea66974cade6f7bb43cbef41717262bd3 Mon Sep 17 00:00:00 2001
From: Arndt Jonasson <arndt@sics.se>
Date: Fri, 15 Sep 2017 16:29:13 +0200
Subject: [PATCH] Added empty constructor.

---
 .../src/main/java/plugins/DistPub.java        | 48 +++++++++++++------
 1 file changed, 33 insertions(+), 15 deletions(-)

diff --git a/plugins/DistPub/src/main/java/plugins/DistPub.java b/plugins/DistPub/src/main/java/plugins/DistPub.java
index a1032b93..8d354e03 100644
--- a/plugins/DistPub/src/main/java/plugins/DistPub.java
+++ b/plugins/DistPub/src/main/java/plugins/DistPub.java
@@ -10,6 +10,8 @@ public class DistPub extends PlugInComponent {
 	private PluginPPort fs;
 	private PluginRPort ff;
 	
+        public DistPub() {}
+
 	public DistPub(String[] args) {
 		super(args);
 	}
@@ -17,8 +19,7 @@ public DistPub(String[] args) {
 	public static void main(String[] args) {
 		VM.println("DistPub.main()");
 		DistPub publish = new DistPub(args);
-		publish.init();
-		publish.doFunction();
+		publish.run();
 		VM.println("DistPub-main done");
 	}
 
@@ -29,27 +30,44 @@ public void init() {
 		ff = new PluginRPort(this, "ff");
 	}
 
-	public void run() {}
+	public void run() {
+	    init();
+	    try {
+		doFunction();
+	    } catch (InterruptedException e) {
+		VM.println("**************** Interrupted.");
+		return;
+	    }
+	}
 	
-	public void doFunction() {
+	public void doFunction() throws InterruptedException {
 		String data = "";
 		int cnt = 0;
 		VM.println("[DistPub X is running]");
 		while (true) {
 		    cnt += 1;
-		    int val = ff.readInt();
-		    data += " " + val;
-		    VM.println(data);
-		    if (cnt % 20 == 0) {
-			data = "DistPub| (" + cnt + ")" + data;
+		    int val;
+		    val = ff.readInt();
+		    //val = (2*cnt+1)%300+5;
+		    if (false) {
+			data += " " + val;
 			//VM.println(data);
-			fs.write(data);
-			data = "";
-			try {
-			    Thread.sleep(200);
-			} catch (InterruptedException e) {
-			    VM.println("Interrupted.");
+			if (cnt % 20 == 0) {
+			    data = "DistPub| (" + cnt + ")" + data;
+			    VM.println(data);
+			    fs.write(data);
+			    data = "";
+			    try {
+				Thread.sleep(2000);
+			    } catch (InterruptedException e) {
+				VM.println("Interrupted.");
+			    }
 			}
+		    } else {
+			data = "DistPub|" + cnt + " " + val + " ";
+			//VM.println(data);
+			fs.write(data);
+			//Thread.sleep(200);
 		    }
 		}
 	}