I2P_Developers/i2p.plugins.zzzot
3
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

Add tracker stats to the stats subsystem for graphing or export to prometheus

Browse Source
This commit is contained in:
zzz
2025-04-26 11:53:17 -04:00
parent 1e94a95a7a
commit 0edade465c
2 changed files with 40 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/java/net/i2p/zzzot/Torrents.java
View File

@ -17,6 +17,7 @@ package net.i2p.zzzot;
*/
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.atomic.AtomicInteger;
import net.i2p.CoreVersion;
import net.i2p.data.DataHelper;
@ -34,6 +35,7 @@ public class Torrents extends ConcurrentHashMap<InfoHash, Peers> {
private final SDSCache<PID> _pidCache;
private final Integer _interval;
private final int _udpLifetime;
private final AtomicInteger _announces = new AtomicInteger();
/**
* @param interval in seconds
@ -97,6 +99,28 @@ public class Torrents extends ConcurrentHashMap<InfoHash, Peers> {
return _pidCache.get(d);
}
/**
* This is called for every announce except for event = STOPPED.
* Hook it here to keep an announce counter.
*
* @since 0.20.0
*/
@Override
public Peers putIfAbsent(InfoHash ih, Peers p) {
_announces.incrementAndGet();
return super.putIfAbsent(ih, p);
}
/**
* Return the number of announces since the last call.
* Resets the counter to zero.
*
* @since 0.20.0
*/
public int getAnnounces() {
return _announces.getAndSet(0);
}
/**
* @since 0.12.0
*/
@ -104,6 +128,7 @@ public class Torrents extends ConcurrentHashMap<InfoHash, Peers> {
public void clear() {
super.clear();
clearCaches();
_announces.set(0);
}
/**

15
src/java/net/i2p/zzzot/ZzzOT.java
View File

@ -29,6 +29,7 @@ import net.i2p.util.SimpleTimer2;
*/
class ZzzOT {
private final I2PAppContext _context;
private final Torrents _torrents;
private final Cleaner _cleaner;
private final ConcurrentHashMap<String, String> _destCache = new ConcurrentHashMap<String, String>();
@ -71,6 +72,7 @@ class ZzzOT {
_torrents = new Torrents(interval, lifetime);
EXPIRE_TIME = 1000 * (interval + interval / 2);
_cleaner = new Cleaner(ctx);
_context = ctx;
}
Torrents getTorrents() {
@ -84,12 +86,19 @@ class ZzzOT {
void start() {
_cleaner.forceReschedule(CLEAN_TIME);
long[] r = new long[] { 5*60*1000 };
_context.statManager().createRequiredRateStat("plugin.zzzot.announces", "Announces per minute", "Plugins", r);
_context.statManager().createRequiredRateStat("plugin.zzzot.peers", "Number of peers", "Plugins", r);
_context.statManager().createRequiredRateStat("plugin.zzzot.torrents", "Number of torrents", "Plugins", r);
}
void stop() {
_cleaner.cancel();
_torrents.clear();
_destCache.clear();
_context.statManager().removeRateStat("plugin.zzzot.announces");
_context.statManager().removeRateStat("plugin.zzzot.peers");
_context.statManager().removeRateStat("plugin.zzzot.torrents");
}
private class Cleaner extends SimpleTimer2.TimedEvent {
@ -103,6 +112,7 @@ class ZzzOT {
public void timeReached() {
long now = System.currentTimeMillis();
int peers = 0;
for (Iterator<Peers> iter = _torrents.values().iterator(); iter.hasNext(); ) {
Peers p = iter.next();
int recent = 0;
@ -115,10 +125,15 @@ class ZzzOT {
}
if (recent <= 0)
iter.remove();
else
peers += recent;
}
if (_runCount.incrementAndGet() % (DEST_CACHE_CLEAN_TIME / CLEAN_TIME) == 0) {
_destCache.clear();
}
_context.statManager().addRateData("plugin.zzzot.announces", _torrents.getAnnounces() / (CLEAN_TIME / (60*1000L)));
_context.statManager().addRateData("plugin.zzzot.peers", peers);
_context.statManager().addRateData("plugin.zzzot.torrents", _torrents.size());
schedule(CLEAN_TIME);
}
}