com.daioware.net.distributed

Class DistributedServer

java.lang.Object

java.lang.Thread

com.daioware.net.socket.GenericTCPServer

com.daioware.net.distributed.DistributedServer

All Implemented Interfaces:

Iterable<TcpActiveMachine>, Runnable

Direct Known Subclasses:

DistributedConnector

public abstract class DistributedServer
extends com.daioware.net.socket.GenericTCPServer
implements Iterable<TcpActiveMachine>

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class com.daioware.net.socket.GenericTCPServer

currentRunningThreads, servSocket

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
DistributedServer(DistributedServerConfig config)
DistributedServer(com.daioware.net.socket.UDPElement udpElement, com.daioware.net.socket.TCPServSocket servSocket, com.daioware.stream.Printer printer, int maxSimultaneousConnections)

Method Summary

Modifier and Type	Method and Description
boolean	add(TcpActiveMachine a)
void	announcePresence()
protected void	begin()
void	close()
TcpActiveMachine	get(String addr)
TcpActiveMachine	getActiveMachineWithBetterAvailableConnections()
protected Thread	getNewClientThread(com.daioware.net.socket.TCPClientSocket clientSocket)
abstract Runnable	getRunnable(com.daioware.net.socket.TCPClientSocket clientSocket)
com.daioware.net.socket.UDPElement	getUdpElement()
protected void	initialize()
boolean	isAnnouncePresence()
Iterator<TcpActiveMachine>	iterator()
protected boolean	readyToCloseLog()
TcpActiveMachine	remove(String addr)
void	sendCurrentConnections()
void	setUdpElement(com.daioware.net.socket.UDPElement udpElement)

Methods inherited from class com.daioware.net.socket.GenericTCPServer

addSession, decrementRunningThreads, getCurrentConnections, getMaxSimultaneousConnections, getPrinter, getServSocket, incrementRunningThreads, isActive, print, println, removeSession, removeSession, run, setActive, setCurrentRunningThreads, setMaxSimultaneousConnections, setPrinter, setServSocket

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Detail

DistributedServer

public DistributedServer(com.daioware.net.socket.UDPElement udpElement,
                         com.daioware.net.socket.TCPServSocket servSocket,
                         com.daioware.stream.Printer printer,
                         int maxSimultaneousConnections)

DistributedServer

public DistributedServer(DistributedServerConfig config)
                  throws UnknownHostException,
                         IOException

Throws:

UnknownHostException

IOException

Method Detail

initialize

protected void initialize()

announcePresence

public void announcePresence()

isAnnouncePresence

public boolean isAnnouncePresence()

getUdpElement

public com.daioware.net.socket.UDPElement getUdpElement()

setUdpElement

public void setUdpElement(com.daioware.net.socket.UDPElement udpElement)

get

public TcpActiveMachine get(String addr)

remove

public TcpActiveMachine remove(String addr)

add

public boolean add(TcpActiveMachine a)

getActiveMachineWithBetterAvailableConnections

public TcpActiveMachine getActiveMachineWithBetterAvailableConnections()

getNewClientThread

protected Thread getNewClientThread(com.daioware.net.socket.TCPClientSocket clientSocket)

Overrides:

getNewClientThread in class com.daioware.net.socket.GenericTCPServer

getRunnable

public abstract Runnable getRunnable(com.daioware.net.socket.TCPClientSocket clientSocket)

Specified by:

getRunnable in class com.daioware.net.socket.GenericTCPServer

iterator

public Iterator<TcpActiveMachine> iterator()

Specified by:

iterator in interface Iterable<TcpActiveMachine>

begin

protected void begin()

Overrides:

begin in class com.daioware.net.socket.GenericTCPServer

sendCurrentConnections

public void sendCurrentConnections()

readyToCloseLog

protected boolean readyToCloseLog()

close

public void close()
           throws IOException

Overrides:

close in class com.daioware.net.socket.GenericTCPServer

Throws:

IOException