Class ReopeningInterruptibleChannel<T extends InterruptibleChannel>

java.lang.Object

org.terracotta.offheapstore.util.ReopeningInterruptibleChannel<T>

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, InterruptibleChannel

public final class ReopeningInterruptibleChannel<T extends InterruptibleChannel>
extends Object
implements InterruptibleChannel

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	ReopeningInterruptibleChannel.IoOperation<T,R>

Field Summary

Fields

Modifier and Type	Field	Description
private final Supplier<T>	channelFactory
private final AtomicReference<T>	currentChannel
private static final org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ReopeningInterruptibleChannel(Supplier<T> deviceFactory)

Method Summary

Modifier and Type	Method	Description
void	close()
static <T extends InterruptibleChannel> ReopeningInterruptibleChannel<T>	create(Supplier<T> channelFactory)
<R> R	execute(ReopeningInterruptibleChannel.IoOperation<T,R> operation)
boolean	isOpen()

Methods inherited from class Object

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

Field Details

LOGGER

private static final org.slf4j.Logger LOGGER

channelFactory

private final Supplier<T extends InterruptibleChannel> channelFactory

currentChannel

private final AtomicReference<T extends InterruptibleChannel> currentChannel

Constructor Details

ReopeningInterruptibleChannel

private ReopeningInterruptibleChannel(Supplier<T> deviceFactory)

Method Details

create

public static <T extends InterruptibleChannel>
ReopeningInterruptibleChannel<T> create(Supplier<T> channelFactory)

execute

public <R> R execute(ReopeningInterruptibleChannel.IoOperation<T,R> operation)
              throws IOException

Throws:

IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Channel

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Specified by:

close in interface Closeable

Specified by:

close in interface InterruptibleChannel

Throws:

IOException