I2P Address: [http://git.idk.i2p]

Skip to content
Snippets Groups Projects
Commit 47d2b80a authored by zzz's avatar zzz
Browse files

* ClientMessage: Remove unused MessageReceptionInfo

  * RouterContext: Remove unused MessageStateMonitor
parent 04785e25
No related branches found
No related tags found
No related merge requests found
......@@ -23,7 +23,7 @@ public class ClientMessage {
private Payload _payload;
private Destination _destination;
private Destination _fromDestination;
private MessageReceptionInfo _receptionInfo;
//private MessageReceptionInfo _receptionInfo;
private SessionConfig _senderConfig;
private Hash _destinationHash;
private MessageId _messageId;
......@@ -77,8 +77,8 @@ public class ClientMessage {
* originated ones.
*
*/
public MessageReceptionInfo getReceptionInfo() { return _receptionInfo; }
public void setReceptionInfo(MessageReceptionInfo info) { _receptionInfo = info; }
//public MessageReceptionInfo getReceptionInfo() { return _receptionInfo; }
//public void setReceptionInfo(MessageReceptionInfo info) { _receptionInfo = info; }
/**
* Retrieve the session config of the client that sent the message. This will only be available
......
......@@ -14,6 +14,7 @@ import net.i2p.data.TunnelId;
/**
* Wrap up the details of how a ClientMessage was received from the network
*
* @deprecated unused
*/
public class MessageReceptionInfo {
private Hash _fromPeer;
......
......@@ -5,6 +5,7 @@ import net.i2p.util.Log;
/**
* Keep track of the inbound and outbound messages in memory.
*
* @deprecated unused
*/
public class MessageStateMonitor {
private Log _log;
......@@ -69,4 +70,4 @@ public class MessageStateMonitor {
public int getInboundReadCount() { return _inboundReadCount; }
public int getOutboundLiveCount() { return _outboundLiveCount; }
public int getOutboundDiscardedCount() { return _outboundDiscardedCount; }
}
\ No newline at end of file
}
......@@ -56,7 +56,7 @@ public class RouterContext extends I2PAppContext {
private Shitlist _shitlist;
private Blocklist _blocklist;
private MessageValidator _messageValidator;
private MessageStateMonitor _messageStateMonitor;
//private MessageStateMonitor _messageStateMonitor;
private RouterThrottle _throttle;
private final Set<Runnable> _finalShutdownTasks;
// split up big lock on this to avoid deadlocks
......@@ -141,7 +141,7 @@ public class RouterContext extends I2PAppContext {
_outNetMessagePool = new OutNetMessagePool(this);
_messageHistory = new MessageHistory(this);
_messageRegistry = new OutboundMessageRegistry(this);
_messageStateMonitor = new MessageStateMonitor(this);
//_messageStateMonitor = new MessageStateMonitor(this);
if ("false".equals(getProperty("i2p.dummyNetDb", "false")))
_netDb = new FloodfillNetworkDatabaseFacade(this); // new KademliaNetworkDatabaseFacade(this);
else
......@@ -253,13 +253,15 @@ public class RouterContext extends I2PAppContext {
* The registry is used by outbound messages to wait for replies.
*/
public OutboundMessageRegistry messageRegistry() { return _messageRegistry; }
/**
* The monitor keeps track of inbound and outbound messages currently held in
* memory / queued for processing. We'll use this to throttle the router so
* we don't overflow.
*
*/
public MessageStateMonitor messageStateMonitor() { return _messageStateMonitor; }
//public MessageStateMonitor messageStateMonitor() { return _messageStateMonitor; }
/**
* Our db cache
*/
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment