package org.glassfish.pfl.tf.timer.impl ;
import java.util.Iterator ;
import java.util.Stack ;
import java.io.PrintStream ;
import org.glassfish.pfl.tf.timer.spi.LogEventHandler;
import org.glassfish.pfl.tf.timer.spi.NamedBase;
import org.glassfish.pfl.tf.timer.spi.TimerEvent;
import org.glassfish.pfl.tf.timer.spi.TimerFactory;
public class LogEventHandlerImpl extends NamedBase
implements LogEventHandler {
private static final int DEFAULT_SIZE = 1000 ;
private static final int DEFAULT_INCREMENT = 1000 ;
private long[] data ;
private int size ;
private int increment ;
private int nextFree ;
LogEventHandlerImpl( TimerFactory factory, String name ) {
super( factory, name ) ;
initData( DEFAULT_SIZE, DEFAULT_INCREMENT ) ;
}
public synchronized Iterator<TimerEvent> iterator() {
return new LogEventHandlerIterator( factory(), data, nextFree ) ;
}
private void initData( int size, int increment ) {
this.size = 2*size ;
this.increment = 2*increment ;
data = new long[ this.size ] ;
nextFree = 0 ;
}
public void notify( TimerEvent event ) {
final int id = 2*event.timer().id() +
((event.type() == TimerEvent.TimerEventType.ENTER) ? 0 : 1) ;
log( id, event.time() ) ;
}
private synchronized void log( int id, long time ) {
if (data.length - nextFree < 2) {
int newSize = data.length + 2*increment ;
long[] newData = new long[ newSize ] ;
System.arraycopy( data, 0, newData, 0, data.length ) ;
data = newData ;
}
int index = nextFree ;
nextFree += 2 ;
data[ index ] = id ;
data[ index + 1 ] = time ;
}
public synchronized void clear() {
initData( size, increment ) ;
}
private static class Indent {
private final int width ;
private int level ;
private String rep ;
public Indent( final int width ) {
this.width = width ;
level = 0 ;
rep = "" ;
}
private void update() {
int size = level*width ;
char[] content = new char[size] ;
for (int ctr=0; ctr<size; ctr++) {
content[ctr] = ' ' ;
}
rep = new String( content ) ;
}
public void in() {
level++ ;
update() ;
}
public void out() {
level-- ;
update() ;
}
public String toString() {
return rep ;
}
}
private static final String ENTER_REP = ">> " ;
private static final String EXIT_REP = "<< " ;
public void display( PrintStream arg, String msg ) {
arg.println( "Displaying contents of " + this + ": " + msg ) ;
final Stack<TimerEvent> stack = new Stack<TimerEvent>() ;
long startTime = -1 ;
Indent indent = new Indent( ENTER_REP.length() ) ;
for (TimerEvent te : this) {
if (startTime == -1) {
startTime = te.time() ;
}
long relativeTime = (te.time() - startTime)/1000 ;
final boolean isEnter = te.type() == TimerEvent.TimerEventType.ENTER ;
if (isEnter) {
arg.printf( "%8d: %s%s%s\n", relativeTime, indent,
isEnter ? ENTER_REP : EXIT_REP, te.timer().name() ) ;
stack.push( new TimerEvent(te) ) ;
indent.in() ;
} else {
TimerEvent enterEvent = stack.pop() ;
indent.out() ;
String duration = null ;
if (enterEvent.timer().equals( te.timer() )) {
duration = Long.toString( (te.time()-enterEvent.time())/1000 ) ;
} else {
duration = "BAD NESTED EVENT: ENTER was " + enterEvent.timer().name() ;
}
arg.printf( "%8d: %s%s%s[%s]\n", relativeTime, indent,
isEnter ? ENTER_REP : EXIT_REP, te.timer().name(), duration ) ;
}
}
}
}