bftsmart.clientsmanagement

Class ClientsManager

java.lang.Object

bftsmart.clientsmanagement.ClientsManager

public class ClientsManager
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
ClientsManager(ServerViewController controller, RequestsTimer timer)

Method Summary

Methods

Modifier and Type	Method and Description
ClientData	getClientData(int clientId) We are assuming that no more than one thread will access the same clientData during creation.
java.util.concurrent.locks.ReentrantLock	getClientsLock()
TOMMessage	getPending(int reqId) Get some reqId that is pending.
RequestList	getPendingRequests() Get pending requests in a fair way (one request from each client queue until the max number of requests is obtained).
boolean	havePendingRequests() We've implemented some protection for individual client data, but the clients table can change during the operation.
boolean	isPending(int reqId) Verifies if some reqId is pending.
boolean	requestReceived(TOMMessage request, boolean fromClient)
boolean	requestReceived(TOMMessage request, boolean fromClient, ServerCommunicationSystem cs) Notifies the ClientsManager that a new request from a client arrived.
void	requestsOrdered(TOMMessage[] requests) Notifies the ClientsManager that these requests were already executed.

Methods inherited from class java.lang.Object

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

Constructor Detail

ClientsManager

public ClientsManager(ServerViewController controller,
              RequestsTimer timer)

Method Detail

getClientData

public ClientData getClientData(int clientId)

We are assuming that no more than one thread will access the same clientData during creation.

Parameters:

clientId -

Returns:

the ClientData stored on the manager

getPendingRequests

public RequestList getPendingRequests()

Get pending requests in a fair way (one request from each client queue until the max number of requests is obtained).

Returns:

the set of all pending requests of this system

havePendingRequests

public boolean havePendingRequests()

We've implemented some protection for individual client data, but the clients table can change during the operation.

Returns:

true if there are some pending requests and false otherwise

isPending

public boolean isPending(int reqId)

Verifies if some reqId is pending.

Parameters:

reqId - the request identifier

Returns:

true if the request is pending

getPending

public TOMMessage getPending(int reqId)

Get some reqId that is pending.

Parameters:

reqId - the request identifier

Returns:

the pending request, or null

requestReceived

public boolean requestReceived(TOMMessage request,
                      boolean fromClient)

requestReceived

public boolean requestReceived(TOMMessage request,
                      boolean fromClient,
                      ServerCommunicationSystem cs)

Notifies the ClientsManager that a new request from a client arrived. This method updates the ClientData of the client request.getSender().

Parameters:

request - the received request

fromClient - the message was received from client or not?

storeMessage - the message should be stored or not? (read-only requests are not stored)

cs - server com. system to be able to send replies to already processed requests

Returns:

true if the request is ok and is added to the pending messages for this client, false if there is some problem and the message was not accounted

requestsOrdered

public void requestsOrdered(TOMMessage[] requests)

Notifies the ClientsManager that these requests were already executed.

Parameters:

requests - the array of requests to account as ordered

getClientsLock

public java.util.concurrent.locks.ReentrantLock getClientsLock()