120 lines
3.2 KiB
Java
120 lines
3.2 KiB
Java
|
|
/* ====================================================================
|
|
Licensed to the Apache Software Foundation (ASF) under one or more
|
|
contributor license agreements. See the NOTICE file distributed with
|
|
this work for additional information regarding copyright ownership.
|
|
The ASF licenses this file to You under the Apache License, Version 2.0
|
|
(the "License"); you may not use this file except in compliance with
|
|
the License. You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
==================================================================== */
|
|
|
|
|
|
package org.apache.poi.util;
|
|
|
|
import java.io.InputStream;
|
|
import java.io.IOException;
|
|
|
|
/**
|
|
* Implementation of a BlockingInputStream to provide data to
|
|
* RawDataBlock that expects data in 512 byte chunks. Useful to read
|
|
* data from slow (ie, non FileInputStream) sources, for example when
|
|
* reading an OLE2 Document over a network.
|
|
*
|
|
* Possible extensions: add a timeout. Currently a call to read(byte[]) on this
|
|
* class is blocking, so use at your own peril if your underlying stream blocks.
|
|
*
|
|
* @author Jens Gerhard
|
|
* @author aviks - documentation cleanups.
|
|
*/
|
|
public class BlockingInputStream
|
|
extends InputStream
|
|
{
|
|
protected InputStream is;
|
|
|
|
public BlockingInputStream(InputStream is)
|
|
{
|
|
this.is = is;
|
|
}
|
|
|
|
public int available()
|
|
throws IOException
|
|
{
|
|
return is.available();
|
|
}
|
|
|
|
public void close()
|
|
throws IOException
|
|
{
|
|
is.close();
|
|
}
|
|
|
|
public void mark(int readLimit)
|
|
{
|
|
is.mark(readLimit);
|
|
}
|
|
|
|
public boolean markSupported()
|
|
{
|
|
return is.markSupported();
|
|
}
|
|
|
|
public int read()
|
|
throws IOException
|
|
{
|
|
return is.read();
|
|
}
|
|
|
|
/**
|
|
* We had to revert to byte per byte reading to keep
|
|
* with slow network connections on one hand, without
|
|
* missing the end-of-file.
|
|
* This is the only method that does its own thing in this class
|
|
* everything else is delegated to aggregated stream.
|
|
* THIS IS A BLOCKING BLOCK READ!!!
|
|
*/
|
|
public int read(byte[] bf)
|
|
throws IOException
|
|
{
|
|
|
|
int i = 0;
|
|
int b = 4611;
|
|
while ( i < bf.length )
|
|
{
|
|
b = is.read();
|
|
if ( b == -1 )
|
|
break;
|
|
bf[i++] = (byte) b;
|
|
}
|
|
if ( i == 0 && b == -1 )
|
|
return -1;
|
|
return i;
|
|
}
|
|
|
|
public int read(byte[] bf, int s, int l)
|
|
throws IOException
|
|
{
|
|
return is.read(bf, s, l);
|
|
}
|
|
|
|
public void reset()
|
|
throws IOException
|
|
{
|
|
is.reset();
|
|
}
|
|
|
|
public long skip(long n)
|
|
throws IOException
|
|
{
|
|
return is.skip(n);
|
|
}
|
|
}
|
|
|