junixsocket 2.10.1 · org.newsclub.net.unix.AFCore · APIdia, the JavaDoc alternative

Field Summary

Modifier and Type	Field and Description
pack-priv final AncillaryDataSupport	ancillaryDataSupport
private volatile boolean	blocking
private boolean	cleanFd
private final AtomicBoolean	closed
private final boolean	datagramMode
pack-priv final FileDescriptor	fd
private static final String	PROP_TL_BUFFER_MAX_CAPACITY
private static final ObjectPool<MutableHolder<ByteBuffer>>	TL_BUFFER
private static final int	TL_BUFFER_MAX_CAPACITY
private static final int	TL_BUFFER_MIN_CAPACITY
private final AtomicInteger	virtualBlockingLeases

Constructor Summary

Access	Constructor and Description
pack-priv	AFCore(Object observed, FileDescriptor fd, AncillaryDataSupport ancillaryDataSupport, boolean datagramMode)
pack-priv	AFCore(Object observed, FileDescriptor fd)

Method Summary

Modifier and Type	Method and Description
pack-priv void	configureVirtualBlocking(boolean `true` if increment, `false` if decrement. enabled) Increments/decrements the "virtual blocking" counter (calls must be in pairs/balanced using try-finally blocks).
pack-priv void	disableCleanFd()
protected final void	doClean() Implements abstract org.newsclub.net.unix.CleanableState.doClean. Performs the actual cleanup.
pack-priv void	doClose()
pack-priv ObjectPool.Lease<MutableHolder<@NonNull ByteBuffer>>	Returns: A byte buffer satisfying the requested capacity. getPrivateDirectByteBuffer(int The desired capacity. capacity) Returns a per-thread reusable byte buffer for a given capacity.
pack-priv void	implConfigureBlocking(boolean block)
pack-priv boolean	isBlocking()
pack-priv boolean	isClosed()
pack-priv boolean	isVirtualBlocking()
pack-priv int	read(ByteBuffer dst, AFSupplier<Integer> timeout)
pack-priv int	read(ByteBuffer dst, AFSupplier<Integer> timeout, ByteBuffer socketAddressBuffer, int options)
pack-priv synchronized FileDescriptor	validFd()
pack-priv FileDescriptor	validFdOrException()
pack-priv int	write(ByteBuffer src, AFSupplier<Integer> timeout)
pack-priv int	write(ByteBuffer src, AFSupplier<Integer> timeout, SocketAddress target, int options)

Inherited from org.newsclub.net.unix.CleanableState:: close runCleaner

Field Detail

ancillaryDataSupport	back to summary
pack-priv final AncillaryDataSupport ancillaryDataSupport

blocking	back to summary
private volatile boolean blocking

cleanFd	back to summary
private boolean cleanFd

closed	back to summary
private final AtomicBoolean closed

datagramMode	back to summary
private final boolean datagramMode

fd	back to summary
pack-priv final FileDescriptor fd

PROP_TL_BUFFER_MAX_CAPACITY	back to summary
private static final String PROP_TL_BUFFER_MAX_CAPACITY

TL_BUFFER	back to summary
private static final ObjectPool<MutableHolder<ByteBuffer>> TL_BUFFER

TL_BUFFER_MAX_CAPACITY	back to summary
private static final int TL_BUFFER_MAX_CAPACITY

TL_BUFFER_MIN_CAPACITY	back to summary
private static final int TL_BUFFER_MIN_CAPACITY

virtualBlockingLeases	back to summary
private final AtomicInteger virtualBlockingLeases

Constructor Detail

AFCore	back to summary
pack-priv AFCore(Object observed, FileDescriptor fd, AncillaryDataSupport ancillaryDataSupport, boolean datagramMode)

AFCore	back to summary
pack-priv AFCore(Object observed, FileDescriptor fd)

Method Detail

configureVirtualBlocking back to summary

configureVirtualBlocking	back to summary
pack-priv void configureVirtualBlocking(boolean enabled) throws SocketException, IOException Increments/decrements the "virtual blocking" counter (calls must be in pairs/balanced using try-finally blocks). Parameters enabled:boolean `true` if increment, `false` if decrement. Exceptions SocketException: on error. IOException: on error, including count overflow/underflow.

pack-priv void configureVirtualBlocking(boolean enabled) throws SocketException, IOException

Increments/decrements the "virtual blocking" counter (calls must be in pairs/balanced using try-finally blocks).

Parameters

enabled:boolean: true if increment, false if decrement.

Exceptions

SocketException:: on error.
IOException:: on error, including count overflow/underflow.

disableCleanFd	back to summary
pack-priv void disableCleanFd()

doClean	back to summary
protected final void doClean() Implements abstract org.newsclub.net.unix.CleanableState.doClean. Doc from org.newsclub.net.unix.CleanableState.doClean. Performs the actual cleanup. Annotations @Override

doClean

back to summary

protected final void doClean()

Implements abstract org.newsclub.net.unix.CleanableState.doClean.

Doc from org.newsclub.net.unix.CleanableState.doClean.

Performs the actual cleanup.

Annotations

@Override

doClose	back to summary
pack-priv void doClose() throws IOException

getPrivateDirectByteBuffer	back to summary
pack-priv ObjectPool.Lease<MutableHolder<@NonNull ByteBuffer>> getPrivateDirectByteBuffer(int capacity) Returns a per-thread reusable byte buffer for a given capacity. If a thread-local buffer currently uses a smaller capacity, the buffer is replaced by a larger one. If the capacity exceeds a configurable maximum, a new direct buffer is allocated but not cached (i.e., the previously cached one is kept but not immediately returned to the caller). Parameters capacity:int The desired capacity. Returns:ObjectPool.Lease<MutableHolder<@NonNull ByteBuffer>> A byte buffer satisfying the requested capacity. Annotations @SuppressWarnings:null

getPrivateDirectByteBuffer

back to summary

pack-priv ObjectPool.Lease<MutableHolder<@NonNull ByteBuffer>> getPrivateDirectByteBuffer(int capacity)

Returns a per-thread reusable byte buffer for a given capacity. If a thread-local buffer currently uses a smaller capacity, the buffer is replaced by a larger one. If the capacity exceeds a configurable maximum, a new direct buffer is allocated but not cached (i.e., the previously cached one is kept but not immediately returned to the caller).