I2P_Developers/i2p.i2p
3
1
Fork 11
Code Issues 340 Pull Requests 13 Actions 10 Packages Projects Releases Wiki Activity

SSU2: Change packet classification if/else to switch
Some checks failed
Sync Primary Repository to GitHub Mirror / sync (push) Has been cancelled
Details
Daily Workflow / daily-job (push) Has been cancelled
Details
Daily Workflow / javadoc-latest (push) Has been cancelled
Details
Daily Workflow / build-java7 (push) Has been cancelled
Details
Java CI / build (push) Has been cancelled
Details
Java CI / javadoc-latest (push) Has been cancelled
Details
Java CI / build-java7 (push) Has been cancelled
Details
Dockerhub / docker (push) Has been cancelled
Details
Java with IzPack Snapshot Setup / setup (push) Has been cancelled
Details

Browse Source
This commit is contained in:
zzz
2025-06-08 10:29:58 -04:00
parent 0c5497c83e
commit 4d1ba03823
1 changed files with 18 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
router/java/src/net/i2p/router/transport/udp/PacketHandler.java
View File

@ -388,29 +388,41 @@ class PacketHandler {
// all good
SSU2Header.acceptTrialDecrypt(packet, header);
if (type == SSU2Util.SESSION_REQUEST_FLAG_BYTE) {
switch (type) {
case SSU2Util.SESSION_REQUEST_FLAG_BYTE:
if (_log.shouldDebug())
_log.debug("Got a Session Request on " + state);
_establisher.receiveSessionOrTokenRequest(from, state, packet);
} else if (type == SSU2Util.TOKEN_REQUEST_FLAG_BYTE) {
break;
case SSU2Util.TOKEN_REQUEST_FLAG_BYTE:
if (_log.shouldDebug())
_log.debug("Got a Token Request on " + state);
_establisher.receiveSessionOrTokenRequest(from, state, packet);
} else if (type == SSU2Util.SESSION_CONFIRMED_FLAG_BYTE) {
break;
case SSU2Util.SESSION_CONFIRMED_FLAG_BYTE:
if (_log.shouldDebug())
_log.debug("Got a Session Confirmed on " + state);
_establisher.receiveSessionConfirmed(state, packet);
} else if (type == SSU2Util.PEER_TEST_FLAG_BYTE) {
break;
case SSU2Util.PEER_TEST_FLAG_BYTE:
if (_log.shouldDebug())
_log.debug("Got a Peer Test");
_testManager.receiveTest(from, packet);
} else if (type == SSU2Util.HOLE_PUNCH_FLAG_BYTE) {
break;
case SSU2Util.HOLE_PUNCH_FLAG_BYTE:
if (_log.shouldDebug())
_log.debug("Got a Hole Punch");
_establisher.receiveHolePunch(from, packet);
} else {
break;
default:
if (_log.shouldWarn())
_log.warn("Got unknown SSU2 message " + header + " from " + from);
break;
}
return true;
}