Changeset 58e960c


Ignore:
Timestamp:
Sep 4, 2009 2:20:20 PM (11 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
83588d9, f33e9507
Parents:
de07705
Message:

Fix inbound tunnel tests by using the correct SKM

File:
1 edited

Legend:

Unmodified
Added
Removed
  • router/java/src/net/i2p/router/tunnel/pool/TestJob.java

    rde07705 r58e960c  
    44import java.util.Set;
    55
     6import net.i2p.crypto.SessionKeyManager;
    67import net.i2p.data.Certificate;
    78import net.i2p.data.SessionKey;
     
    131132
    132133        SessionKey encryptKey = getContext().keyGenerator().generateSessionKey();
    133         _encryptTag = new SessionTag(true);
     134        SessionTag encryptTag = new SessionTag(true);
     135        _encryptTag = encryptTag;
    134136        SessionKey sentKey = new SessionKey();
    135137        Set sentTags = null;
    136138        GarlicMessage msg = GarlicMessageBuilder.buildMessage(getContext(), payload, sentKey, sentTags,
    137139                                                              getContext().keyManager().getPublicKey(),
    138                                                               encryptKey, _encryptTag);
     140                                                              encryptKey, encryptTag);
    139141
    140142        if (msg == null) {
     
    144146        }
    145147        Set encryptTags = new HashSet(1);
    146         encryptTags.add(_encryptTag);
    147         // Register the single tag with the SKM
    148         getContext().sessionKeyManager().tagsReceived(encryptKey, encryptTags);
     148        encryptTags.add(encryptTag);
     149        // Register the single tag with the appropriate SKM
     150        if (_cfg.isInbound() && !_pool.getSettings().isExploratory()) {
     151            SessionKeyManager skm = getContext().clientManager().getClientSessionKeyManager(_pool.getSettings().getDestination());
     152            if (skm != null)
     153                skm.tagsReceived(encryptKey, encryptTags);
     154        } else {
     155            getContext().sessionKeyManager().tagsReceived(encryptKey, encryptTags);
     156        }
    149157
    150158        if (_log.shouldLog(Log.DEBUG))
     
    313321            if (!_found) {
    314322                // don't clog up the SKM with old one-tag tagsets
    315                 getContext().sessionKeyManager().consumeTag(_encryptTag);
     323                if (_cfg.isInbound() && !_pool.getSettings().isExploratory()) {
     324                    SessionKeyManager skm = getContext().clientManager().getClientSessionKeyManager(_pool.getSettings().getDestination());
     325                    if (skm != null)
     326                        skm.consumeTag(_encryptTag);
     327                } else {
     328                    getContext().sessionKeyManager().consumeTag(_encryptTag);
     329                }
    316330                testFailed(getContext().clock().now() - _started);
    317331            }
Note: See TracChangeset for help on using the changeset viewer.