Top Description Fields Constructors Methods

org.newsclub.net.unix

pack-priv Class AFSocketCore

Class Inheritance

extends AFCore

Known Direct Subclasses

org.newsclub.net.unix.AFSocketImpl.AFSocketStreamCore

Imports

java.io.FileDescriptor, .IOException, java.lang.reflect.InvocationTargetException, java.net.SocketException, java.nio.ByteBuffer, java.util.concurrent.atomic.AtomicInteger, .AtomicLong, org.newsclub.net.unix.pool.ObjectPool.Lease

A shared core that is common for all AF* sockets (datagrams, streams).

Author: Christian Kohlschütter

Field Summary

Modifier and Type	Field and Description
private final AFAddressFamily<?>	af
pack-priv final AtomicLong	inode We keep track of the server's inode to detect when another server connects to our address.
private final AtomicInteger	pendingAccepts
private static final int	SHUT_RD_WR
private boolean	shutdownOnClose
pack-priv AFSocketAddress	socketAddress

Inherited from org.newsclub.net.unix.AFCore:: ancillaryDataSupport fd

Constructor Summary

Access	Constructor and Description
protected	AFSocketCore(Object observed, FileDescriptor fd, AncillaryDataSupport ancillaryDataSupport, AFAddressFamily<?> af, boolean datagramMode)

Method Summary

Modifier and Type	Method and Description
protected AFAddressFamily<?>	addressFamily()
protected void	decPendingAccepts()
protected void	doClose() Overrides org.newsclub.net.unix.AFCore.doClose.
pack-priv <T> T	getOption(AFSocketOption<T> name)
protected boolean	hasPendingAccepts()
protected void	incPendingAccepts()
pack-priv boolean	isConnected(boolean boundOk)
pack-priv boolean	isShutdownOnClose()
pack-priv AFSocketAddress	receive(ByteBuffer dst, AFSupplier<Integer> socketTimeout)
pack-priv <T> void	setOption(AFSocketOption<T> name, T value)
pack-priv void	setShutdownOnClose(boolean enabled)
protected void	unblockAccepts()

Inherited from org.newsclub.net.unix.AFCore:: configureVirtualBlocking disableCleanFd doClean getPrivateDirectByteBuffer implConfigureBlocking isBlocking isClosed isVirtualBlocking read read validFd validFdOrException write write

Field Detail

af	back to summary
private final AFAddressFamily<?> af

inode	back to summary
pack-priv final AtomicLong inode We keep track of the server's inode to detect when another server connects to our address.

pendingAccepts	back to summary
private final AtomicInteger pendingAccepts

SHUT_RD_WR	back to summary
private static final int SHUT_RD_WR

shutdownOnClose	back to summary
private boolean shutdownOnClose

socketAddress	back to summary
pack-priv AFSocketAddress socketAddress

Constructor Detail

AFSocketCore	back to summary
protected AFSocketCore(Object observed, FileDescriptor fd, AncillaryDataSupport ancillaryDataSupport, AFAddressFamily<?> af, boolean datagramMode)

Method Detail

addressFamily	back to summary
protected AFAddressFamily<?> addressFamily()

decPendingAccepts	back to summary
protected void decPendingAccepts()

doClose

back to summary

protected void doClose() throws IOException

Overrides org.newsclub.net.unix.AFCore.doClose.

Annotations

@Override
@SuppressWarnings:UnsafeFinalization

getOption	back to summary
pack-priv <T> T getOption(AFSocketOption<T> name) throws IOException Annotations @SuppressWarnings:unchecked

hasPendingAccepts	back to summary
protected boolean hasPendingAccepts()

incPendingAccepts	back to summary
protected void incPendingAccepts() throws SocketException

isConnected	back to summary
pack-priv boolean isConnected(boolean boundOk)

isShutdownOnClose	back to summary
pack-priv boolean isShutdownOnClose()

receive	back to summary
pack-priv AFSocketAddress receive(ByteBuffer dst, AFSupplier<Integer> socketTimeout) throws IOException

setOption	back to summary
pack-priv <T> void setOption(AFSocketOption<T> name, T value) throws IOException

setShutdownOnClose	back to summary
pack-priv void setShutdownOnClose(boolean enabled)

unblockAccepts	back to summary
protected void unblockAccepts()