Changeset d389b3b

Timestamp:

Apr 3, 2019 1:21:41 PM (17 months ago)

Author:

zzz <zzz@…>

Branches:

master

Children:

c3aa4598

Parents:

b7d980d

Message:

I2PTunnel: Start/stop POST throttle timer

Files:

• apps/i2ptunnel/java/src/net/i2p/i2ptunnel/ConnThrottler.java (modified) (3 diffs)
• apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPServer.java (modified) (2 diffs)
• history.txt (modified) (1 diff)

apps/i2ptunnel/java/src/net/i2p/i2ptunnel/ConnThrottler.java

@@ -40 +40 @@
     private final Log _log;
     private final DateFormat _fmt;
-
-    /*
+    private final SimpleTimer2.TimedEvent _cleaner;
+    private boolean _isRunning;
+
+    /*
+     * Caller MUST call start()
+     *
      * @param max per-peer, 0 for unlimited
      * @param totalMax for all peers, 0 for unlimited
@@ -58 +62 @@
         _fmt = DateFormat.getDateTimeInstance(DateFormat.SHORT, DateFormat.MEDIUM);
         _fmt.setTimeZone(SystemVersion.getSystemTimeZone());
-        new Cleaner();
+        _cleaner = new Cleaner();
+    }
+
+    /*
+     * If already started, has no effect.
+     *
+     * @since 0.9.40
+     */
+    public synchronized void start() {
+        if (_isRunning)
+            return;
+        _isRunning = true;
+        _cleaner.schedule(_checkPeriod);
+    }
+
+    /*
+     * May be restarted.
+     *
+     * @since 0.9.40
+     */
+    public synchronized void stop() {
+        _isRunning = false;
+        _cleaner.cancel();
+        clear();
     }
 
@@ -177 +204 @@
 
     private class Cleaner extends SimpleTimer2.TimedEvent {
-        /** schedules itself */
+        /** must call schedule() later */
         public Cleaner() {
-            super(SimpleTimer2.getInstance(), _checkPeriod);
+            super(SimpleTimer2.getInstance());
         }
 

apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelHTTPServer.java

@@ -234 +234 @@
                 else
                     _postThrottler.updateLimits(pp, pt, pw, pb, px);
+                _postThrottler.start();
             }
         }
@@ -255 +256 @@
         synchronized(this) {
             if (_postThrottler != null)
-                _postThrottler.clear();
+                _postThrottler.stop();
         }
         return super.close(forced);

history.txt

@@ +1 @@
+2019-04-03 zzz
+ * I2PTunnel: Start/stop POST throttle timer
+
 2019-04-02 zab
- * I2PTunnel: mplement access filtering (ticket #2464
+ * I2PTunnel: Implement access filtering (ticket #2464)
+
+2019-03-31 zzz
+ * Data: Implement Destroyable for private keys (ticket #2462)
+
+2019-03-29 zzz
+ * Crypto: SigContext (WIP) (proposal #148)
+ * NetDB: Persist cached blinding data (proposal #123)
 
 2019-03-27 zzz