eu.unicore.uftp.jparss

Class PReader

java.lang.Object

eu.unicore.uftp.jparss.PReader

All Implemented Interfaces:

Runnable

public class PReader
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field and Description
int	num_ number of parallel streams.

Constructor Summary

Constructors

Constructor and Description
PReader(PInputStream parent, InputStream stream, int pos, int numreadrs) Constructor

Method Summary

Modifier and Type	Method and Description
boolean	isEOF()
int	readData() Readr reads to an input stream
void	run()
void	set(byte[] buf, int off, int length) Set up total buffer to read for this parallel stream.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

num_

public int num_

number of parallel streams.

Constructor Detail

PReader

public PReader(PInputStream parent,
               InputStream stream,
               int pos,
               int numreadrs)

Constructor

Parameters:

parent - paralle stream containing this readr.

stream - real inputstream associated with this readr.

pos - position of this readr inside the parallel stream.

numreadrs - total number of readrs of this parallel stream.

Method Detail

set

public void set(byte[] buf,
                int off,
                int length)

Set up total buffer to read for this parallel stream.

readData

public int readData()
             throws IOException

Readr reads to an input stream

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

isEOF

public boolean isEOF()