com.daioware.net.distributed

Class DistributedConnector

java.lang.Object

java.lang.Thread

com.daioware.net.socket.GenericTCPServer

com.daioware.net.distributed.DistributedServer

com.daioware.net.distributed.DistributedConnector

All Implemented Interfaces:

Iterable<TcpActiveMachine>, Runnable

public class DistributedConnector
extends DistributedServer

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
DistributedConnector(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
Runnable	getRunnable(com.daioware.net.socket.TCPClientSocket clientSocket)

Methods inherited from class com.daioware.net.distributed.DistributedServer

add, announcePresence, begin, close, get, getActiveMachineWithBetterAvailableConnections, getNewClientThread, getUdpElement, initialize, isAnnouncePresence, iterator, readyToCloseLog, remove, sendCurrentConnections, setUdpElement

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

DistributedConnector

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

Method Detail

getRunnable

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

Specified by:

getRunnable in class DistributedServer