From 008cc2325b05d7493b178f6b0f762e16ff0fe8e2 Mon Sep 17 00:00:00 2001
From: bdemsky <bdemsky>
Date: Thu, 19 Nov 2009 02:01:28 +0000
Subject: [PATCH] Buffered Reader

---
 .../SpamFilter/BufferedReader.java            | 86 +++++++++++++++++++
 1 file changed, 86 insertions(+)
 create mode 100644 Robust/src/Benchmarks/Distributed/SpamFilter/BufferedReader.java

diff --git a/Robust/src/Benchmarks/Distributed/SpamFilter/BufferedReader.java b/Robust/src/Benchmarks/Distributed/SpamFilter/BufferedReader.java
new file mode 100644
index 00000000..d4c96fdd
--- /dev/null
+++ b/Robust/src/Benchmarks/Distributed/SpamFilter/BufferedReader.java
@@ -0,0 +1,86 @@
+public class BufferedReader {
+    FileInputStream fr;
+    byte[] buffer;
+    int offset;
+    int end;
+
+    public BufferedReader(FileInputStream fr) {
+	this.fr=fr;
+	this.buffer=new byte[2048];
+    }
+
+    public int read() {
+	if (offset<end) {
+	    return buffer[offset++];
+	} else {
+	    readBuffer();
+	    if (end<=0)
+		return -1;
+	    return buffer[offset++];
+	}
+    }
+
+    public int read(byte[] array) {
+	int off=0;
+	int arraylen=array.length;
+	do {
+	    for(;offset<end;offset++) {
+		if (off>=arraylen)
+		    return off;
+		array[off++]=buffer[offset];
+	    }
+	    readBuffer();
+	    if (end==0)
+		return off;
+	    if (end<0)
+		return end;
+	} while(true);
+    }
+
+    public void readBuffer() {
+	offset=0;
+	end=fr.read(buffer);
+    }
+
+    public String readLine() {
+	String str=null;
+	do {
+	    boolean foundcr=false;
+	    int index=offset;
+	    for(;index<end;index++) {
+		if (buffer[index]=='\n'||buffer[index]==13) {
+		    foundcr=true;
+		    break;
+		}
+	    }
+	    String buf=new String(buffer, offset, index-offset);
+	    if (str==null)
+		str=buf;
+	    else
+		str=str.concat(buf);
+	    if (foundcr) {
+		offset=index++;
+		do {
+		    for(;offset<end;offset++) {
+			if (buffer[offset]!='\n'&&buffer[offset]!=13) {
+			    return str;
+			}
+		    }
+		    readBuffer();
+		    if (end<=0)
+			return str;
+		} while(true);
+	    } else {
+		readBuffer();
+		if (end<=0)
+		    return null;
+	    }
+	} while(true);
+
+    }
+
+    public void close() {
+	fr.close();
+    }
+
+}
\ No newline at end of file
-- 
2.34.1