mirrors/CC-Tweaked
1
0
Fork 0
mirror of https://github.com/SquidDev-CC/CC-Tweaked synced 2024-06-26 07:03:22 +00:00
Code Issues Releases Wiki Activity

Add support for arbitrary trackers

Browse Source 
This is used by cc-prometheus to monitor statistics. It isn't currently
exposed as an API, as I'm making no guarantees on the stability of this.
This commit is contained in:
SquidDev 2018-04-19 21:59:35 +01:00
parent 911e404bfa
commit e2f9ddd534
2 changed files with 30 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/main/java/dan200/computercraft/core/tracking/Tracker.java Normal file
View File

@ -0,0 +1,10 @@
package dan200.computercraft.core.tracking;
import dan200.computercraft.core.computer.Computer;
public interface Tracker
{
void addTiming( Computer computer, long time );
void addValue( Computer computer, TrackingField field, long change );
}

23
src/main/java/dan200/computercraft/core/tracking/Tracking.java
View File

@ -2,18 +2,23 @@
import dan200.computercraft.core.computer.Computer;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.UUID;
import java.util.concurrent.atomic.AtomicInteger;
public class Tracking
{
static final AtomicInteger tracking = new AtomicInteger( 0 );
private static final Object lock = new Object();
private static final HashMap<UUID, TrackingContext> contexts = new HashMap<>();
private static final List<Tracker> trackers = new ArrayList<>();
public static TrackingContext getContext( UUID uuid )
{
synchronized( contexts )
synchronized( lock )
{
TrackingContext context = contexts.get( uuid );
if( context == null ) contexts.put( uuid, context = new TrackingContext() );
@ -21,6 +26,15 @@ public static TrackingContext getContext( UUID uuid )
}
}
public static void add( Tracker tracker )
{
synchronized( lock )
{
trackers.add( tracker );
tracking.incrementAndGet();
}
}
public static void addTiming( Computer computer, long time )
{
if( tracking.get() == 0 ) return;
@ -28,6 +42,7 @@ public static void addTiming( Computer computer, long time )
synchronized( contexts )
{
for( TrackingContext context : contexts.values() ) context.addTiming( computer, time );
for( Tracker tracker : trackers ) tracker.addTiming( computer, time );
}
}
@ -35,17 +50,19 @@ public static void addValue( Computer computer, TrackingField field, long change
{
if( tracking.get() == 0 ) return;
synchronized( contexts )
synchronized( lock )
{
for( TrackingContext context : contexts.values() ) context.addValue( computer, field, change );
for( Tracker tracker : trackers ) tracker.addValue( computer, field, change );
}
}
public static void reset()
{
synchronized( contexts )
synchronized( lock )
{
contexts.clear();
trackers.clear();
tracking.set( 0 );
}
}