com.sleepycat.je.rep.utilint

Class NamedChannelWithTimeout

java.lang.Object

com.sleepycat.je.rep.utilint.NamedChannel

com.sleepycat.je.rep.utilint.NamedChannelWithTimeout

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.ByteChannel, java.nio.channels.Channel, java.nio.channels.ReadableByteChannel, java.nio.channels.WritableByteChannel

public class NamedChannelWithTimeout
extends NamedChannel

NamedChannelWithTimeout permits association of timeouts with a SocketChannel. This mechanism is necessary, since the standard mechanism for associating timeouts with sockets using Socket.setSoTimeout is not supported by nio SocketChannels.

Field Summary

Fields inherited from class com.sleepycat.je.rep.utilint.NamedChannel

channel

Constructor Summary

Constructors

Constructor and Description
NamedChannelWithTimeout(RepNode repNode, java.nio.channels.SocketChannel channel, int timeoutMs)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
boolean	isActive(long timeMs) Method invoked by the time thread to check on the channel on a periodic basis.
int	read(java.nio.ByteBuffer dst)
void	setTimeoutMs(int timeoutMs) Used to modify the timeout associated with the channel.

Methods inherited from class com.sleepycat.je.rep.utilint.NamedChannel

getChannel, getNameIdPair, isOpen, setNameIdPair, toString, write

Methods inherited from class java.lang.Object

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

Constructor Detail

NamedChannelWithTimeout

public NamedChannelWithTimeout(RepNode repNode,
                       java.nio.channels.SocketChannel channel,
                       int timeoutMs)

Method Detail

setTimeoutMs

public void setTimeoutMs(int timeoutMs)

Used to modify the timeout associated with the channel.

Parameters:

timeoutMs - the new timeout value

read

public int read(java.nio.ByteBuffer dst)
         throws java.io.IOException

Specified by:

read in interface java.nio.channels.ReadableByteChannel

Overrides:

read in class NamedChannel

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.nio.channels.Channel

Overrides:

close in class NamedChannel

Throws:

java.io.IOException

isActive

public boolean isActive(long timeMs)

Method invoked by the time thread to check on the channel on a periodic basis. Note that the time that is passed in is a "pseudo" time that is only meaningful for calculating time differences.

Parameters:

timeMs - the pseudo time

Returns:

true if the channel is active, false if it isn't and has been closed