On Tue, Aug 26, 2008 at 6:21 AM,  <nextgens at freenetproject.org> wrote:
> 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() {

return false;  here ?

>                                synchronized(sync) {
>                                        try {
>

Reply via email to