org.xnio.sasl

Class SaslWrappingConduit

java.lang.Object

org.xnio.conduits.AbstractConduit<D>

org.xnio.conduits.AbstractSinkConduit<D>

org.xnio.conduits.AbstractMessageSinkConduit<MessageSinkConduit>

org.xnio.sasl.SaslWrappingConduit

All Implemented Interfaces:

Conduit, MessageSinkConduit, SinkConduit

public final class SaslWrappingConduit
extends AbstractMessageSinkConduit<MessageSinkConduit>
implements MessageSinkConduit

Author:

David M. Lloyd

Field Summary

Fields inherited from class org.xnio.conduits.AbstractConduit

next

Constructor Summary

Constructors

Constructor and Description
SaslWrappingConduit(MessageSinkConduit next, SaslWrapper wrapper)

Method Summary

Modifier and Type	Method and Description
boolean	flush() Flush out any unwritten, buffered output.
boolean	send(ByteBuffer src) Send a complete message.
boolean	send(ByteBuffer[] srcs, int offs, int len) Send a complete message.
boolean	sendFinal(ByteBuffer src) Send a complete message.
boolean	sendFinal(ByteBuffer[] srcs, int offs, int len) Send a complete message.

Methods inherited from class org.xnio.conduits.AbstractSinkConduit

awaitWritable, awaitWritable, getWriteThread, isWriteResumed, isWriteShutdown, resumeWrites, setWriteReadyHandler, suspendWrites, terminateWrites, truncateWrites, wakeupWrites

Methods inherited from class org.xnio.conduits.AbstractConduit

getWorker

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.xnio.conduits.SinkConduit

awaitWritable, awaitWritable, getWriteThread, isWriteResumed, isWriteShutdown, resumeWrites, setWriteReadyHandler, suspendWrites, terminateWrites, truncateWrites, wakeupWrites

Methods inherited from interface org.xnio.conduits.Conduit

getWorker

Constructor Detail

SaslWrappingConduit

public SaslWrappingConduit(MessageSinkConduit next,
                           SaslWrapper wrapper)

Method Detail

send

public boolean send(ByteBuffer src)
             throws IOException

Description copied from interface: MessageSinkConduit

Send a complete message.

Specified by:

send in interface MessageSinkConduit

Overrides:

send in class AbstractMessageSinkConduit<MessageSinkConduit>

Parameters:

src - the message to send

Returns:

the result of the send operation; true if the message was sent, or false if it would block

Throws:

IOException - if an I/O error occurs

send

public boolean send(ByteBuffer[] srcs,
                    int offs,
                    int len)
             throws IOException

Description copied from interface: MessageSinkConduit

Send a complete message.

Specified by:

send in interface MessageSinkConduit

Overrides:

send in class AbstractMessageSinkConduit<MessageSinkConduit>

Parameters:

srcs - the buffers holding the message to send

offs - the offset into the buffer array of the first buffer

len - the number of buffers that contain data to send

Returns:

the result of the send operation; true if the message was sent, or false if it would block

Throws:

IOException - if an I/O error occurs

sendFinal

public boolean sendFinal(ByteBuffer src)
                  throws IOException

Description copied from interface: MessageSinkConduit

Send a complete message. If the message is successfully sent then the sink will have its writes terminated.

Specified by:

sendFinal in interface MessageSinkConduit

Overrides:

sendFinal in class AbstractMessageSinkConduit<MessageSinkConduit>

Parameters:

src - the message to send

Returns:

the result of the send operation; true if the message was sent, or false if it would block

Throws:

IOException - if an I/O error occurs

sendFinal

public boolean sendFinal(ByteBuffer[] srcs,
                         int offs,
                         int len)
                  throws IOException

Description copied from interface: MessageSinkConduit

Send a complete message. If the message is successfully sent then the sink will have its writes terminated.

Specified by:

sendFinal in interface MessageSinkConduit

Overrides:

sendFinal in class AbstractMessageSinkConduit<MessageSinkConduit>

Parameters:

srcs - the buffers holding the message to send

offs - the offset into the buffer array of the first buffer

len - the number of buffers that contain data to send

Returns:

the result of the send operation; true if the message was sent, or false if it would block

Throws:

IOException - if an I/O error occurs

flush

public boolean flush()
              throws IOException

Description copied from interface: SinkConduit

Flush out any unwritten, buffered output.

Specified by:

flush in interface SinkConduit

Overrides:

flush in class AbstractSinkConduit<MessageSinkConduit>

Returns:

true if everything is flushed, false otherwise

Throws:

IOException - if flush fails