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

Skip to content
Snippets Groups Projects
Commit 409207e0 authored by zzz's avatar zzz
Browse files

more selectors

parent 95366c06
No related branches found
No related tags found
No related merge requests found
...@@ -207,7 +207,7 @@ public class PeerTestJob extends JobImpl { ...@@ -207,7 +207,7 @@ public class PeerTestJob extends JobImpl {
public boolean continueMatching() { return false; } public boolean continueMatching() { return false; }
public long getExpiration() { return _expiration; } public long getExpiration() { return _expiration; }
public boolean isMatch(I2NPMessage message) { public boolean isMatch(I2NPMessage message) {
if (message instanceof DeliveryStatusMessage) { if (message.getType() == DeliveryStatusMessage.MESSAGE_TYPE) {
DeliveryStatusMessage msg = (DeliveryStatusMessage)message; DeliveryStatusMessage msg = (DeliveryStatusMessage)message;
if (_nonce == msg.getMessageId()) { if (_nonce == msg.getMessageId()) {
long timeLeft = _expiration - getContext().clock().now(); long timeLeft = _expiration - getContext().clock().now();
......
...@@ -267,7 +267,7 @@ class TestJob extends JobImpl { ...@@ -267,7 +267,7 @@ class TestJob extends JobImpl {
public long getExpiration() { return _expiration; } public long getExpiration() { return _expiration; }
public boolean isMatch(I2NPMessage message) { public boolean isMatch(I2NPMessage message) {
if (message instanceof DeliveryStatusMessage) { if (message.getType() == DeliveryStatusMessage.MESSAGE_TYPE) {
return ((DeliveryStatusMessage)message).getMessageId() == _id; return ((DeliveryStatusMessage)message).getMessageId() == _id;
} }
return false; return false;
......
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