From 8e419abdef069ac14497bb62484332a480fb6b55 Mon Sep 17 00:00:00 2001
From: jihoonl <jihoonl>
Date: Tue, 10 Nov 2009 23:36:11 +0000
Subject: [PATCH] fixed Mail constructor

---
 Robust/src/Benchmarks/Distributed/SpamFilter/Mail.java |  5 +++--
 .../Benchmarks/Distributed/SpamFilter/SpamFilter.java  | 10 +++++++++-
 2 files changed, 12 insertions(+), 3 deletions(-)

diff --git a/Robust/src/Benchmarks/Distributed/SpamFilter/Mail.java b/Robust/src/Benchmarks/Distributed/SpamFilter/Mail.java
index 98890c41..81f56691 100644
--- a/Robust/src/Benchmarks/Distributed/SpamFilter/Mail.java
+++ b/Robust/src/Benchmarks/Distributed/SpamFilter/Mail.java
@@ -65,14 +65,15 @@ public class Mail {
       }
     } // parsed messageID, To, from, cc, Title
 
+
     if(!chk)
       System.out.println("no line read");
 
 
     body = new String();
-    byte[] readBody = new byte[1000000];
+    byte[] readBody = new byte[256];
 
-    while((fileinput.read(readBody)!= -1))
+    while((fileinput.read(readBody)>0))
     {
       body.concat(new String(readBody));
     }
diff --git a/Robust/src/Benchmarks/Distributed/SpamFilter/SpamFilter.java b/Robust/src/Benchmarks/Distributed/SpamFilter/SpamFilter.java
index db7ab448..a4bc9e23 100644
--- a/Robust/src/Benchmarks/Distributed/SpamFilter/SpamFilter.java
+++ b/Robust/src/Benchmarks/Distributed/SpamFilter/SpamFilter.java
@@ -34,6 +34,8 @@ public class SpamFilter extends Thread {
     int niter;
     int nemails;
     int thid;
+    int correct=0;
+    int wrong=0;
     atomic {
       niter=numiter;
       nemails=numemail;
@@ -44,6 +46,8 @@ public class SpamFilter extends Thread {
     Random myrand = new Random(0);
 
     for(int i=0; i<niter; i++) {
+      correct =0;
+      wrong = 0;
       for(int j=0; j<nemails; j++) {
         int pickemail = rand.nextInt(100);
 
@@ -73,14 +77,18 @@ public class SpamFilter extends Thread {
         //---- get user's take on email and send feedback ------
         boolean userAnswer = email.getIsSpam();
 
-        //System.out.println("userAnswer= " + userAnswer + " filterAnswer= " + filterAnswer);
+ //       System.out.println("userAnswer= " + userAnswer + " filterAnswer= " + filterAnswer);
 
         if(filterAnswer != userAnswer) {
+          wrong++;
           atomic {
             sendFeedBack(signatures, userAnswer, thid);
           }
         }
+        else 
+          correct++;
       } //end num emails
+      System.out.println((i+1)+"th iteration correct = " + correct + " Wrong = " + wrong + " percentage = " + ((float)correct/(float)nemails));
     }//end num iter
   }
 
-- 
2.34.1