From 8d2590e14d4181703753a512d1f5f0ad37d96c85 Mon Sep 17 00:00:00 2001
From: Marios Isaakidis <misaakidis@yahoo.gr>
Date: Fri, 20 Nov 2015 13:58:21 -0500
Subject: [PATCH] Stop RequestReceiver tasks when unloading CENOClient; Change
 condition that was causing RequestReceiver to inserting empty batch requests

---
 .../src/plugins/CENO/Client/CENOClient.java   |  6 ++-
 .../plugins/CENO/Client/RequestSender.java    | 39 +++++++++++--------
 2 files changed, 26 insertions(+), 19 deletions(-)

diff --git a/ceno-freenet/src/plugins/CENO/Client/CENOClient.java b/ceno-freenet/src/plugins/CENO/Client/CENOClient.java
index 1990b53..91045d9 100644
--- a/ceno-freenet/src/plugins/CENO/Client/CENOClient.java
+++ b/ceno-freenet/src/plugins/CENO/Client/CENOClient.java
@@ -106,12 +106,14 @@ public void terminate()
 			initConfig.setProperty("lastSynced", String.valueOf(channelMaker.getLastSynced()));
 			initConfig.storeProperties();
 		}
-		*/
-		
+		 */
+
 		if(channelMakerThread != null) {
 			channelMakerThread.interrupt();
 		}
 
+		RequestSender.getInstance().stopTimerTasks();
+
 		//TODO Release ULPRs' resources
 		Logger.normal(this, PLUGIN_NAME + " terminated.");
 	}
diff --git a/ceno-freenet/src/plugins/CENO/Client/RequestSender.java b/ceno-freenet/src/plugins/CENO/Client/RequestSender.java
index 9afd003..b63153d 100644
--- a/ceno-freenet/src/plugins/CENO/Client/RequestSender.java
+++ b/ceno-freenet/src/plugins/CENO/Client/RequestSender.java
@@ -8,7 +8,6 @@
 import java.util.TimerTask;
 import java.util.concurrent.TimeUnit;
 
-import plugins.CENO.Client.ULPRManager.ULPRStatus;
 import plugins.CENO.Client.Signaling.Channel;
 import plugins.CENO.Common.URLtoUSKTools;
 
@@ -34,7 +33,7 @@ public class RequestSender {
 	/**
 	 * Maximum size in bytes of a batch request in order to fit within the USK chunk
 	 */
-	private static final long MAX_BATCH_SIZE = 2^10;
+	private static final long MAX_BATCH_SIZE = 1024;
 
 	private RequestSender() {
 		this.requestTable = new Hashtable<String, Long>();
@@ -43,6 +42,13 @@ private RequestSender() {
 		timer.schedule(new BatchReqInserter(), 0, TimeUnit.MINUTES.toMillis(3));
 	}
 
+	public void stopTimerTasks() {
+		if (timer != null) {
+			timer.cancel();
+			timer.purge();
+		}
+	}
+
 	public static RequestSender getInstance() {
 		return requestSender;
 	}
@@ -58,21 +64,18 @@ public void requestFromBridge(String url) {
 	}
 
 	public synchronized boolean shouldSignalBridge(String url) {
+		String urlValidated = null;
 		try {
-			URLtoUSKTools.validateURL(url);
+			urlValidated = URLtoUSKTools.validateURL(url);
 		} catch (MalformedURLException e) {
 			return false;
 		}
 
-		if (ULPRManager.getULPRStatus(url) == ULPRStatus.succeeded) {
-			return false;
-		}
-
-		if (!requestTable.containsKey(url)) {
+		if (!requestTable.containsKey(urlValidated)) {
 			requestTable.put(url, System.currentTimeMillis());
 		}
 
-		return (System.currentTimeMillis() - requestTable.get(url) > SHOULD_QUEUE_URL);
+		return (System.currentTimeMillis() - requestTable.get(urlValidated) > SHOULD_QUEUE_URL);
 	}
 
 	private void addInBatch(String url) {
@@ -104,21 +107,23 @@ public void run() {
 
 				for (int i = batchList.size() - 1; i >= 0; i--) {
 					String url = batchList.get(i);
-					if (shouldSignalBridge(url)) {
-						batchSize += url.getBytes().length;
-						if (batchSize <= MAX_BATCH_SIZE) {
-							batchListStr.append(url);
-							batchListStr.append("\n");
-						}
+					batchSize += url.getBytes().length;
+					if (batchSize < MAX_BATCH_SIZE) {
+						batchListStr.append(url);
+						batchListStr.append("\n");
 					}
 				}
 
-				if (Channel.insertBatch(batchListStr.toString())) {
+				String batchReq = batchListStr.toString();
+				if (batchReq.isEmpty()) {
+					return;
+				}
+
+				if (Channel.insertBatch(batchReq)) {
 					newUrlArrived = false;
 				}
 			}
 		}
 
 	}
-
 }