eu.unicore.uftp.jparss

Class PSocket

java.lang.Object

java.net.Socket

eu.unicore.uftp.jparss.PBaseSocket

eu.unicore.uftp.jparss.PSocket

All Implemented Interfaces:

Closeable, AutoCloseable

public class PSocket
extends PBaseSocket

Field Summary

Fields inherited from class eu.unicore.uftp.jparss.PBaseSocket

id_, numStreams_, sockets_

Constructor Summary

Constructors

Constructor and Description
PSocket(byte[] key, boolean compress) Constructor.

Method Summary

Modifier and Type	Method and Description
void	addSocketStream(Socket sock) Add a socket to this parallel stream
boolean	clientConnectionDone() Check whether client finished connection.
void	close() Close socket.
int	getId() return id number of this parallel stream socket
void	init(int id, int numstreams) Set up this socket.

Methods inherited from class eu.unicore.uftp.jparss.PBaseSocket

getInetAddress, getInputStream, getKeepAlive, getLocalAddress, getLocalPort, getNumStreams, getOutputStream, getPort, getReceiveBufferSize, getSendBufferSize, getSoLinger, getSoTimeout, getTcpNoDelay, setKeepAlive, setReceiveBufferSize, setSendBufferSize, setSoLinger, setSoTimeout, setTcpNoDelay, shutdownInput, shutdownOutput

Methods inherited from class java.net.Socket

bind, connect, connect, getChannel, getLocalSocketAddress, getOOBInline, getRemoteSocketAddress, getReuseAddress, getTrafficClass, isBound, isClosed, isConnected, isInputShutdown, isOutputShutdown, sendUrgentData, setOOBInline, setPerformancePreferences, setReuseAddress, setSocketImplFactory, setTrafficClass, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

PSocket

public PSocket(byte[] key,
               boolean compress)

Constructor. Creates an unconnected socket.

Parameters:

key - - encoded key for encryption/decryption. Set no null for no encryption

Method Detail

init

public void init(int id,
                 int numstreams)
          throws IOException

Set up this socket.

Throws:

IOException

getId

public int getId()

return id number of this parallel stream socket

addSocketStream

public void addSocketStream(Socket sock)

Add a socket to this parallel stream

clientConnectionDone

public boolean clientConnectionDone()

Check whether client finished connection.

close

public void close()
           throws IOException

Close socket.

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class Socket

Throws:

IOException