Package org.terracotta.offheapstore.util

Class ReopeningInterruptibleChannel<T extends java.nio.channels.InterruptibleChannel>

java.lang.Object

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

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.Channel, java.nio.channels.InterruptibleChannel

public final class ReopeningInterruptibleChannel<T extends java.nio.channels.InterruptibleChannel>
extends java.lang.Object
implements java.nio.channels.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 java.util.function.Supplier<T>	channelFactory
private java.util.concurrent.atomic.AtomicReference<T>	currentChannel
private static org.slf4j.Logger	LOGGER

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ReopeningInterruptibleChannel(java.util.function.Supplier<T> deviceFactory)

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

private static final org.slf4j.Logger LOGGER

channelFactory

private final java.util.function.Supplier<T extends java.nio.channels.InterruptibleChannel> channelFactory

currentChannel

private final java.util.concurrent.atomic.AtomicReference<T extends java.nio.channels.InterruptibleChannel> currentChannel

Constructor Detail

ReopeningInterruptibleChannel

private ReopeningInterruptibleChannel(java.util.function.Supplier<T> deviceFactory)

Method Detail

create

public static <T extends java.nio.channels.InterruptibleChannel> ReopeningInterruptibleChannel<T> create(java.util.function.Supplier<T> channelFactory)

execute

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

Throws:

java.io.IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface java.nio.channels.Channel

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.nio.channels.Channel

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.nio.channels.InterruptibleChannel

Throws:

java.io.IOException