bftsmart.communication.server

Class ServerConnection

java.lang.Object

bftsmart.communication.server.ServerConnection

public class ServerConnection
extends java.lang.Object

This class represents a connection with other server. ServerConnections are created by ServerCommunicationLayer.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	ServerConnection.ReceiverThread Thread used to receive packets from the remote server.
protected class	ServerConnection.TTPReceiverThread Thread used to receive packets from the remote server.

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	MAC_ALGORITHM
protected java.util.concurrent.LinkedBlockingQueue<byte[]>	outQueue

Constructor Summary

Constructors

Constructor and Description
ServerConnection(ServerViewController controller, java.net.Socket socket, int remoteId, java.util.concurrent.LinkedBlockingQueue<SystemMessage> inQueue, ServiceReplica replica)

Method Summary

Methods

Modifier and Type	Method and Description
void	authenticateAndEstablishAuthKey()
javax.crypto.SecretKey	getSecretKey()
protected void	reconnect(java.net.Socket newSocket) (Re-)establish connection between peers.
void	send(byte[] data, boolean useMAC) Used to send packets to the remote server.
void	shutdown() Stop message sending and reception.

Methods inherited from class java.lang.Object

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

Field Detail

MAC_ALGORITHM

public static final java.lang.String MAC_ALGORITHM

See Also:

Constant Field Values

outQueue

protected java.util.concurrent.LinkedBlockingQueue<byte[]> outQueue

Constructor Detail

ServerConnection

public ServerConnection(ServerViewController controller,
                java.net.Socket socket,
                int remoteId,
                java.util.concurrent.LinkedBlockingQueue<SystemMessage> inQueue,
                ServiceReplica replica)

Method Detail

getSecretKey

public javax.crypto.SecretKey getSecretKey()

shutdown

public void shutdown()

Stop message sending and reception.

send

public final void send(byte[] data,
        boolean useMAC)
                throws java.lang.InterruptedException

Used to send packets to the remote server.

Throws:

java.lang.InterruptedException

reconnect

protected void reconnect(java.net.Socket newSocket)

(Re-)establish connection between peers.

Parameters:

newSocket - socket created when this server accepted the connection (only used if processId is less than remoteId)

authenticateAndEstablishAuthKey

public void authenticateAndEstablishAuthKey()