org.jscsi.initiator.connection

Class SenderWorker

java.lang.Object

org.jscsi.initiator.connection.SenderWorker

public final class SenderWorker
extends Object

SenderWorker

The worker caller to send all the protocol data units over the socket of this connection.

Author:

Volker Wildi

Constructor Summary

Constructors

Constructor and Description
SenderWorker(Connection initConnection, InetSocketAddress inetAddress) Creates a new, empty SenderWorker instance.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() This method does all the necessary steps, which are needed when a connection should be closed.
org.jscsi.parser.ProtocolDataUnit	receiveFromWire() Receives a ProtocolDataUnit from the socket and appends it to the end of the receiving queue of this connection.
void	sendOverWire(org.jscsi.parser.ProtocolDataUnit unit) Sends the given ProtocolDataUnit instance over the socket to the connected iSCSI Target.

Methods inherited from class java.lang.Object

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

Constructor Detail

SenderWorker

public SenderWorker(Connection initConnection,
            InetSocketAddress inetAddress)
             throws IOException

Creates a new, empty SenderWorker instance.

Parameters:

initConnection - The reference connection of this worker caller.

inetAddress - The InetSocketAddress of the Target.

Throws:

IOException - if any IO error occurs.

Method Detail

close

public final void close()
                 throws IOException

This method does all the necessary steps, which are needed when a connection should be closed.

Throws:

IOException - if an I/O error occurs.

receiveFromWire

public org.jscsi.parser.ProtocolDataUnit receiveFromWire()
                                                  throws DigestException,
                                                         org.jscsi.exception.InternetSCSIException,
                                                         IOException

Receives a ProtocolDataUnit from the socket and appends it to the end of the receiving queue of this connection.

Returns:

Queue with the resulting units

Throws:

IOException - if an I/O error occurs.

org.jscsi.exception.InternetSCSIException - if any violation of the iSCSI-Standard emerge.

DigestException - if a mismatch of the digest exists.

sendOverWire

public final void sendOverWire(org.jscsi.parser.ProtocolDataUnit unit)
                        throws org.jscsi.exception.InternetSCSIException,
                               IOException,
                               InterruptedException

Sends the given ProtocolDataUnit instance over the socket to the connected iSCSI Target.

Parameters:

unit - The ProtocolDataUnit instances to send.

Throws:

org.jscsi.exception.InternetSCSIException - if any violation of the iSCSI-Standard emerge.

IOException - if an I/O error occurs.

InterruptedException - if another caller interrupted the current caller before or while the current caller was waiting for a notification. The interrupted status of the current caller is cleared when this exception is thrown.