public class ServersCommunicationLayer
extends java.lang.Thread
Modifier and Type | Class and Description |
---|---|
class |
ServersCommunicationLayer.PendingConnection |
Constructor and Description |
---|
ServersCommunicationLayer(ServerViewController controller,
java.util.concurrent.LinkedBlockingQueue<SystemMessage> inQueue,
ServiceReplica replica) |
Modifier and Type | Method and Description |
---|---|
javax.crypto.SecretKey |
getSecretKey(int id) |
void |
joinViewReceived() |
void |
run() |
void |
send(int[] targets,
SystemMessage sm,
boolean useMAC) |
static void |
setSocketOptions(java.net.Socket socket) |
void |
shutdown() |
java.lang.String |
toString() |
void |
updateConnections() |
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, yield
public ServersCommunicationLayer(ServerViewController controller, java.util.concurrent.LinkedBlockingQueue<SystemMessage> inQueue, ServiceReplica replica) throws java.lang.Exception
java.lang.Exception
public javax.crypto.SecretKey getSecretKey(int id)
public void updateConnections()
public final void send(int[] targets, SystemMessage sm, boolean useMAC)
public void shutdown()
public void joinViewReceived()
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public static void setSocketOptions(java.net.Socket socket)
public java.lang.String toString()
toString
in class java.lang.Thread