Class AFUNIXSocketServer

java.lang.Object

org.newsclub.net.unix.server.SocketServer<SocketAddress, Socket, ServerSocket>

org.newsclub.net.unix.server.AFUNIXSocketServer

@Deprecated
public abstract class AFUNIXSocketServer
extends SocketServer<SocketAddress, Socket, ServerSocket>

Deprecated.

Use SocketServer or AFSocketServer

A base implementation for a simple, multi-threaded socket server. This class supports both AF_UNIX and "regular" sockets.

Author:

Christian Kohlschütter

Constructor Summary

Constructors

Constructor	Description
AFUNIXSocketServer(ServerSocket serverSocket)	Deprecated. Creates a server using the given, bound ServerSocket.
AFUNIXSocketServer(SocketAddress listenAddress)	Deprecated. Creates a server using the given SocketAddress.

Method Summary

Modifier and Type	Method	Description
protected ServerSocket	newServerSocket()	Deprecated. Returns a new server socket.
boolean	startAndWait(long duration, TimeUnit unit)	Deprecated. Use SocketServer.startAndWaitToBecomeReady(long, TimeUnit)

Methods inherited from class SocketServer

doServeSocket, doSocketClose, getListenAddress, getMaxConcurrentConnections, getServerBusyTimeout, getServerTimeout, getSocketTimeout, isReady, isRunning, onAfterServingSocket, onBeforeServingSocket, onListenException, onListenException, onServerBound, onServerBusy, onServerReady, onServerShuttingDown, onServerStarting, onServerStopped, onServingException, onServingException, onSocketExceptionAfterAccept, onSocketExceptionDuringAccept, onSubmitted, setMaxConcurrentConnections, setServerBusyTimeout, setServerTimeout, setSocketTimeout, start, startAndWaitToBecomeReady, startAndWaitToBecomeReady, startThenStopAfter, stop

Modifier and Type	Method	Description
protected abstract void	doServeSocket(Socket socket)	Called when a socket is ready to be served.
protected void	doSocketClose(Socket socket)	Called upon closing a socket after serving the connection.
protected SocketAddress	getListenAddress()	Returns the address the server listens to.
int	getMaxConcurrentConnections()	Returns the maximum number of concurrent connections.
int	getServerBusyTimeout()	Returns the server-busy timeout (in milliseconds).
int	getServerTimeout()	Returns the server timeout (in milliseconds).
int	getSocketTimeout()	Returns the socket timeout (in milliseconds).
boolean	isReady()	Checks if the server is running and accepting new connections.
boolean	isRunning()	Checks if the server is running.
protected void	onAfterServingSocket(Socket socket)	Called after the socket has been served.
protected void	onBeforeServingSocket(Socket socket)	Called before serving the socket.
protected void	onListenException(Exception e)	Deprecated. Use SocketServer.onListenException(Throwable)
protected void	onListenException(Throwable t)	Called when an exception was thrown while listening on the server socket.
protected void	onServerBound(SocketAddress address)	Called when the server has been bound to a socket.
protected void	onServerBusy(long busyStartTime)	Called when the server is busy / not ready to accept a new connection.
protected void	onServerReady(int activeCount)	Called when the server is ready to accept a new connection.
protected void	onServerShuttingDown()	Called when the server is shutting down.
protected void	onServerStarting()	Called when the server is starting up.
protected void	onServerStopped(ServerSocket socket)	Called when the server has been stopped.
protected void	onServingException(Socket socket, Exception e)	Deprecated. Use SocketServer.onServingException(Socket, Throwable)
protected void	onServingException(Socket socket, Throwable t)	Called when a throwable was thrown while serving a socket.
protected void	onSocketExceptionAfterAccept(Socket socket, SocketException e)	Called when a SocketException was thrown during "accept".
protected void	onSocketExceptionDuringAccept(SocketException e)	Called when a SocketException was thrown during "accept".
protected void	onSubmitted(Socket socket, Future<?> submission)	Called when a socket gets submitted into the process queue.
void	setMaxConcurrentConnections(int maxConcurrentConnections)	Sets the maximum number of concurrent connections.
void	setServerBusyTimeout(int timeout)	Sets the server-busy timeout (in milliseconds).
void	setServerTimeout(int timeout)	Sets the server timeout (in milliseconds).
void	setSocketTimeout(int timeout)	Sets the socket timeout (in milliseconds).
void	start()	Starts the server, and returns immediately.
void	startAndWaitToBecomeReady()	Starts the server and waits until it is ready or had to stop due to an error.
boolean	startAndWaitToBecomeReady(long duration, TimeUnit unit)	Starts the server and waits until it is ready or had to stop due to an error.
ScheduledFuture<IOException>	startThenStopAfter(long delay, TimeUnit unit)	Requests that the server will be stopped after the given time delay.
void	stop()	Stops the server.

Methods inherited from class Object

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

Constructor Details

AFUNIXSocketServer

public AFUNIXSocketServer(ServerSocket serverSocket)

Deprecated.

Creates a server using the given, bound ServerSocket.

Parameters:

serverSocket - The server socket to use (must be bound).

AFUNIXSocketServer

public AFUNIXSocketServer(SocketAddress listenAddress)

Deprecated.

Creates a server using the given SocketAddress.

Parameters:

listenAddress - The address to bind the socket on.

Method Details

startAndWait

@Deprecated
public boolean startAndWait(long duration,
 TimeUnit unit)
                     throws InterruptedException

Deprecated.

Use SocketServer.startAndWaitToBecomeReady(long, TimeUnit)

Starts the server and waits until it is ready or had to shop due to an error.

Parameters:

duration - The duration wait.

unit - The duration's time unit.

Returns:

true if the server is ready to serve requests.

Throws:

InterruptedException - If the wait was interrupted.

See Also:

• SocketServer.startAndWaitToBecomeReady(long, TimeUnit)

newServerSocket

protected ServerSocket newServerSocket()
                                throws IOException

Deprecated.

Description copied from class: SocketServer

Returns a new server socket.

Specified by:

newServerSocket in class SocketServer<SocketAddress, Socket, ServerSocket>

Returns:

The new socket (an AFServerSocket if the listen address is an AFSocketAddress).

Throws:

IOException - on error.