org.jgroups.protocols.pbcast

Class STATE_SOCK.StateProviderAcceptor

java.lang.Object

org.jgroups.protocols.pbcast.STATE_SOCK.StateProviderAcceptor

All Implemented Interfaces:

java.lang.Runnable

Enclosing class:

STATE_SOCK

protected class STATE_SOCK.StateProviderAcceptor
extends java.lang.Object
implements java.lang.Runnable

Field Summary

Fields

Modifier and Type	Field and Description
protected IpAddress	address
protected java.util.concurrent.ExecutorService	pool
protected boolean	running
protected java.net.ServerSocket	serverSocket

Constructor Summary

Constructors

Constructor and Description
StateProviderAcceptor(java.util.concurrent.ExecutorService pool, java.net.ServerSocket stateServingSocket)

Method Summary

Modifier and Type	Method and Description
IpAddress	getServerSocketAddress()
boolean	isRunning()
protected void	process(java.net.Socket socket)
void	run()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

pool

protected final java.util.concurrent.ExecutorService pool

serverSocket

protected final java.net.ServerSocket serverSocket

address

protected final IpAddress address

running

protected volatile boolean running

Constructor Detail

StateProviderAcceptor

public StateProviderAcceptor(java.util.concurrent.ExecutorService pool,
                             java.net.ServerSocket stateServingSocket)

Method Detail

getServerSocketAddress

public IpAddress getServerSocketAddress()

isRunning

public boolean isRunning()

run

public void run()

Specified by:

run in interface java.lang.Runnable

process

protected void process(java.net.Socket socket)

stop

public void stop()