Author: nextgens
Date: 2008-08-25 22:21:39 +0000 (Mon, 25 Aug 2008)
New Revision: 22159

Modified:
   trunk/freenet/src/freenet/support/io/TempBucketFactory.java
Log:
TempBucket: none of the underlying buckets support marking so we get rid of the 
code for the sake of simplicity

Modified: trunk/freenet/src/freenet/support/io/TempBucketFactory.java
===================================================================
--- trunk/freenet/src/freenet/support/io/TempBucketFactory.java 2008-08-25 
22:16:26 UTC (rev 22158)
+++ trunk/freenet/src/freenet/support/io/TempBucketFactory.java 2008-08-25 
22:21:39 UTC (rev 22159)
@@ -220,7 +220,6 @@
                private class TempBucketInputStream extends InputStream {
                        private InputStream currentIS;
                        private long index = 0;
-                       private long mark = 0;
                        private final short idx;

                        TempBucketInputStream(short idx) {
@@ -277,36 +276,6 @@
                        }

                        @Override
-                       public int available() throws IOException {
-                               synchronized(sync) {
-                                       _maybeResetInputStream();
-                                       return currentIS.available();
-                               }
-                       }
-                       
-                       @Override
-                       public void mark(int readlimit) {
-                               synchronized(sync) {
-                                       try {
-                                               _maybeResetInputStream();
-                                       } catch (IOException e) {
-                                               Logger.error(this, 
"IOE:"+e.getMessage(),e);
-                                       }
-                                       currentIS.mark(readlimit);
-                                       mark = index;
-                               }
-                       }
-                       
-                       @Override
-                       public void reset() throws IOException {
-                               synchronized(sync) {
-                                       _maybeResetInputStream();
-                                       currentIS.reset();
-                                       index = mark;
-                               }               
-                       }
-                       
-                       @Override
                        public boolean markSupported() {
                                synchronized(sync) {
                                        try {


Reply via email to