dandri/i2p.i2p
1
0
Fork 0
mirror of https://github.com/i2p/i2p.i2p.git synced 2026-10-15 06:49:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

I2CP: check if limiter enabled before calling updateBps()

Browse Source 
micro-optimization
This commit is contained in:
zzz
2026-08-10 12:27:21 -04:00
parent bd81ab51d3
commit 4dd77de204
1 changed files with 13 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files
core/java/src/net/i2p/client/impl/I2CPMessageProducer.java
+13 -9
View File
@@ -211,9 +211,12 @@ class I2CPMessageProducer {
public void sendMessage(I2PSessionImpl session, Destination dest, long nonce, byte[] payload,
long expires, int flags) throws I2PSessionException {
if (!updateBps(payload.length, expires))
// drop the message... send fail notification?
return;
if (_maxBytesPerSecond > 0) {
if (!updateBps(payload.length, expires)) {
// drop the message... send fail notification?
return;
}
}
SendMessageMessage msg;
SessionId sid = session.getSessionId();
if (sid == null) {
@@ -241,10 +244,13 @@ class I2CPMessageProducer {
public void sendMessage(I2PSessionImpl session, Destination dest, long nonce, byte[] payload,
SendMessageOptions options) throws I2PSessionException {
long expires = options.getTime();
if (!updateBps(payload.length, expires))
// drop the message... send fail notification?
return;
if (_maxBytesPerSecond > 0) {
long expires = options.getTime();
if (!updateBps(payload.length, expires)) {
// drop the message... send fail notification?
return;
}
}
SessionId sid = session.getSessionId();
if (sid == null) {
_log.error(session.toString() + " cannot send message, session closed", new Exception());
@@ -288,8 +294,6 @@ class I2CPMessageProducer {
* @return true if we should send the message, false to drop it
*/
private boolean updateBps(int len, long expires) {
if (_maxBytesPerSecond <= 0)
return true;
//synchronized(this) {
_lock.lock();
try {