org.globus.ftp
Class DataSinkStream

java.lang.Object
  extended by org.globus.ftp.DataSinkStream
All Implemented Interfaces:
DataSink

public class DataSinkStream
extends java.lang.Object
implements DataSink

Reference implementation of DataSink. It can be used with non-parallel transfers. It cannot be used with Extended Block Mode because it uses implicit assumption that data arrives in correct sequence. It is not thread safe.


Field Summary
protected  boolean autoFlush
           
protected  boolean ignoreOffset
           
protected  long offset
           
protected  java.io.OutputStream out
           
 
Constructor Summary
DataSinkStream(java.io.OutputStream out)
           
DataSinkStream(java.io.OutputStream out, boolean autoFlush, boolean ignoreOffset)
           
 
Method Summary
 void close()
          Closes this data sink and releases any system resources associated with this sink.
 void write(Buffer buffer)
          Writes the specified buffer to this data sink.
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

out

protected java.io.OutputStream out

autoFlush

protected boolean autoFlush

ignoreOffset

protected boolean ignoreOffset

offset

protected long offset
Constructor Detail

DataSinkStream

public DataSinkStream(java.io.OutputStream out)

DataSinkStream

public DataSinkStream(java.io.OutputStream out,
                      boolean autoFlush,
                      boolean ignoreOffset)
Method Detail

write

public void write(Buffer buffer)
           throws java.io.IOException
Description copied from interface: DataSink
Writes the specified buffer to this data sink.
Note: buffer.getOffset() might return -1 if the transfer mode used does not support data offsets, for example stream transfer mode.

Specified by:
write in interface DataSink
Parameters:
buffer - the data buffer to write.
Throws:
java.io.IOException - if an I/O error occurs.

close

public void close()
           throws java.io.IOException
Description copied from interface: DataSink
Closes this data sink and releases any system resources associated with this sink.

Specified by:
close in interface DataSink
Throws:
java.io.IOException - if an I/O error occurs.


Copyright © 2013. All Rights Reserved.