Package org.globus.io.streams
Class HTTPOutputStream
- java.lang.Object
-
- java.io.OutputStream
-
- org.globus.io.streams.GlobusOutputStream
-
- org.globus.io.streams.HTTPOutputStream
-
- All Implemented Interfaces:
Closeable,Flushable,AutoCloseable
- Direct Known Subclasses:
GassOutputStream
public class HTTPOutputStream extends GlobusOutputStream
-
-
Field Summary
Fields Modifier and Type Field Description protected booleanappendprotected InputStreaminprotected OutputStreamoutputprotected longsizeprotected Socketsocket
-
Constructor Summary
Constructors Modifier Constructor Description protectedHTTPOutputStream()Private constructor used by subclasses.HTTPOutputStream(String host, int port, String file, long length, boolean append)Opens HTTP output stream (unsecure)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidabort()Aborts transfer.voidclose()voidflush()protected voidput(String host, String file, long length, int waittime)voidwrite(byte[] msg)voidwrite(byte[] msg, int from, int length)voidwrite(int b)-
Methods inherited from class java.io.OutputStream
nullOutputStream
-
-
-
-
Field Detail
-
output
protected OutputStream output
-
in
protected InputStream in
-
socket
protected Socket socket
-
size
protected long size
-
append
protected boolean append
-
-
Constructor Detail
-
HTTPOutputStream
protected HTTPOutputStream()
Private constructor used by subclasses.
-
HTTPOutputStream
public HTTPOutputStream(String host, int port, String file, long length, boolean append) throws GassException, IOException
Opens HTTP output stream (unsecure)- Parameters:
host- host name of the HTTP server.port- port number of the HTTP server.file- name of the file on the remote side.length- total size of the data to be transfered. Use -1 if unknown. The data then will be transfered in chunks.append- if true, append data to existing file. Otherwise, the file will be overwritten.- Throws:
GassExceptionIOException
-
-
Method Detail
-
put
protected void put(String host, String file, long length, int waittime) throws IOException
- Throws:
IOException
-
abort
public void abort()
Description copied from class:GlobusOutputStreamAborts transfer. Usually makes sure to release all resources (sockets, file descriptors)
Does nothing by default.- Overrides:
abortin classGlobusOutputStream
-
close
public void close() throws IOException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Overrides:
closein classOutputStream- Throws:
IOException
-
write
public void write(byte[] msg) throws IOException- Overrides:
writein classOutputStream- Throws:
IOException
-
write
public void write(byte[] msg, int from, int length) throws IOException- Overrides:
writein classOutputStream- Throws:
IOException
-
write
public void write(int b) throws IOException- Overrides:
writein classGlobusOutputStream- Throws:
IOException
-
flush
public void flush() throws IOException- Specified by:
flushin interfaceFlushable- Overrides:
flushin classOutputStream- Throws:
IOException
-
-