ConstrainedNetworkController

Class Overview

A NetworkController which allows the use of NetworkConstraint s.

NetworkConstraints may modify messages when they are received from the sender, or block the sending of a message at the point of delivery to an individual.

Summary

[Expand] Inherited Fields

From class uk.ac.imperial.presage2.core.network.NetworkController protected boolean DELIVER_MESSAGE_EVENTS_ENABLED Whether or not to fire MessageDeliveryEvent for every message that is delivered. protected int HANDLER_DRAIN_LIMIT Maximum number of Messages a MessageHandler will take from the queue at once. protected int HANDLER_FORK_THRESHOLD Queue size required to cause a MessageHandler to try and fork a new thread. protected int MAX_THREADS Maximum number of extra threads we will spawn to process messages with. protected int TODELIVER_CAPACITY Maximum capacity of the toDeliver queue. protected boolean allowDelivery protected BlockingQueue<NetworkController.Delivery> awaitingDelivery protected Map<NetworkAddress, NetworkChannel> devices Map of devices registered to this controller. protected EnvironmentSharedStateAccess environment Access to environment shared state. protected EventBus eventBus protected ScheduleExecutor threadPool protected List<NetworkController.MessageHandler> threads protected Time time protected BlockingQueue<Message> toDeliver Queue of messages sent by agents which require processing.

[Expand] Inherited Methods
From class uk.ac.imperial.presage2.core.network.NetworkController void deliverMessage(Message m) Invoked by a NetworkConnector when it wishes to send a message. void deliverMessageTo(NetworkAddress to, Message m) Deliver a message m to recipient to. void doBroadcast(BroadcastMessage m) Send a broadcast message void doMulticast(MulticastMessage m) Send a multicast message void doUnicast(UnicastMessage m) Send a unicast message Pong getPong(Ping p) Return a Pong for the given Ping. void handleMessage(Message m) void incrementTime() void onParticipantsComplete() synchronized void register(NetworkRegistrationRequest req) Register a network device with this NetworkController void setEventBus(EventBus e) void setThreadPool(ScheduleExecutor pool)
From class java.lang.Object Object clone() boolean equals(Object arg0) void finalize() final Class<?> getClass() int hashCode() final void notify() final void notifyAll() String toString() final void wait() final void wait(long arg0) final void wait(long arg0, int arg1)
From interface uk.ac.imperial.presage2.core.TimeDriven abstract void incrementTime()
From interface uk.ac.imperial.presage2.core.network.NetworkChannel abstract void deliverMessage(Message m) Deliver a message through the network channel.
From interface uk.ac.imperial.presage2.core.network.RequiresRegistration abstract void register(NetworkRegistrationRequest req) Request to register with this component.