Changeset 7f8efca

Timestamp:

Jul 5, 2013 7:05:54 PM (8 years ago)

Author:

zab2 <zab2@…>

Branches:

master

Children:

bec62c1b

Parents:

76de4fa

Message:

minor cleanup, more to follow

File:

• apps/streaming/java/src/net/i2p/client/streaming/ConnectionManager.java (modified) (8 diffs)

apps/streaming/java/src/net/i2p/client/streaming/ConnectionManager.java

@@ -50 +50 @@
     /** cache of the property to detect changes */
     private static volatile String _currentBlacklist = "";
-    private static final Set<Hash> _globalBlacklist = new ConcurrentHashSet();
+    private static final Set<Hash> _globalBlacklist = new ConcurrentHashSet<Hash>();
     
     /** @since 0.9.3 */
@@ -63 +63 @@
         _defaultOptions = defaultOptions;
         _log = _context.logManager().getLog(ConnectionManager.class);
-        _connectionByInboundId = new ConcurrentHashMap(32);
-        _pendingPings = new ConcurrentHashMap(4);
+        _connectionByInboundId = new ConcurrentHashMap<Long,Connection>(32);
+        _pendingPings = new ConcurrentHashMap<Long,PingRequest>(4);
         _messageHandler = new MessageHandler(_context, this);
         _packetHandler = new PacketHandler(_context, this);
@@ -444 +444 @@
             synchronized(_globalBlacklist) {
                 if (hashes.length() > 0) {
-                    Set<Hash> newSet = new HashSet();
+                    Set<Hash> newSet = new HashSet<Hash>();
                     StringTokenizer tok = new StringTokenizer(hashes, ",; ");
                     while (tok.hasMoreTokens()) {
@@ -548 +548 @@
      */
     public Set<Connection> listConnections() {
-            return new HashSet(_connectionByInboundId.values());
+            return new HashSet<Connection>(_connectionByInboundId.values());
     }
 
@@ -564 +564 @@
      * @param tagsToSend ignored
      */
-    public boolean ping(Destination peer, long timeoutMs, boolean blocking, SessionKey keyToUse, Set tagsToSend, PingNotifier notifier) {
+    public boolean ping(Destination peer, long timeoutMs, boolean blocking, SessionKey keyToUse, Set<?> tagsToSend, PingNotifier notifier) {
         return ping(peer, timeoutMs, blocking, notifier);
     }
@@ -579 +579 @@
         //    packet.setTagsSent(tagsToSend);
         //}
-        
-        PingRequest req = new PingRequest(peer, packet, notifier);
+        if (_log.shouldLog(Log.INFO)) {
+            _log.info(String.format("about to ping %s timeout=%d blocking=%b",
+                    peer,timeoutMs,blocking));
+        }
+            
+        
+        PingRequest req = new PingRequest(notifier);
         
         _pendingPings.put(id, req);
@@ -631 +636 @@
         private final PingNotifier _notifier;
 
-        public PingRequest(Destination peer, PacketLocal packet, PingNotifier notifier) { 
+        public PingRequest(PingNotifier notifier) { 
             _notifier = notifier;
         }
@@ -639 +644 @@
             //_log.debug("Ping successful");
             //_context.sessionKeyManager().tagsDelivered(_peer.getPublicKey(), _packet.getKeyUsed(), _packet.getTagsSent());
-            synchronized (ConnectionManager.PingRequest.this) {
+            synchronized (this) {
                 _ponged = true; 
-                ConnectionManager.PingRequest.this.notifyAll();
+                notifyAll();
             }
             if (_notifier != null)
                 _notifier.pingComplete(true);
         }
-        public boolean pongReceived() { return _ponged; }
+        public synchronized boolean pongReceived() { return _ponged; }
     }