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

protected IpAddress	address
protected java.util.concurrent.ExecutorService	pool
protected boolean	running
protected java.net.ServerSocket	serverSocket

Constructor Summary

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

Method Summary

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

STATE_SOCK.StateProviderAcceptor

public STATE_SOCK.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()