fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomeepackage org.opensolaris.os.dtrace;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomeeimport java.io.*;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomeeimport java.util.*;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomeeimport java.net.InetAddress;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomeeimport java.net.UnknownHostException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomeeimport javax.swing.event.EventListenerList;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomeeimport java.util.logging.*;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomeepublic class LocalConsumer implements Consumer {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Implementation notes:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // libdtrace is *not* thread-safe. You cannot make multiple calls

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // into it simultaneously from different threads, even if those

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // threads are operating on different dtrace_hdl_t's. Calls to

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // libdtrace are synchronized on a global lock, LocalConsumer.class.

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee static Logger logger = Logger.getLogger(LocalConsumer.class.getName());

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

4ae67516a1d5dc4a5dbc761762bad5b596647388tomee // Needs to match the version in dtrace_jni.c

e77b06d21580f630e0a7c437495ab283d3672828tomee private static final int DTRACE_JNI_VERSION = 3;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private static final Option[] DEFAULT_OPTIONS = new Option[] {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee new Option(Option.bufsize, Option.kb(256)),

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee new Option(Option.aggsize, Option.kb(256)),

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee };

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private static native void _loadJniTable();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

52aacb450723e8271d37836e1b5861c2072a3981tomee // Undocumented configuration options

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private static boolean debug;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private static int maxConsumers;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee static {

52aacb450723e8271d37836e1b5861c2072a3981tomee LocalConsumer.configureLogging();

52aacb450723e8271d37836e1b5861c2072a3981tomee // Undocumented configuration options settable using

52aacb450723e8271d37836e1b5861c2072a3981tomee // java -Doption=value

52aacb450723e8271d37836e1b5861c2072a3981tomee LocalConsumer.getConfigurationOptions();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Utility.loadLibrary("libdtrace_jni.so.1", debug);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _checkVersion(DTRACE_JNI_VERSION);

52aacb450723e8271d37836e1b5861c2072a3981tomee _setDebug(debug);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (maxConsumers > 0) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _setMaximumConsumers(maxConsumers);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Last of all in case configuration options affect the loading

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // of the JNI table.

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _loadJniTable();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Native JNI interface (see lib/libdtrace_jni/dtrace_jni.c)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private static native void _checkVersion(int version);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _open(OpenFlag[] flags) throws DTraceException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native Program _compileString(String program, String[] args)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throws DTraceException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native Program.File _compileFile(String path, String[] args)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throws DTraceException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _exec(Program program) throws DTraceException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _getProgramInfo(Program program)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throws DTraceException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _setOption(String option, String value)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throws DTraceException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native long _getOption(String option) throws DTraceException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native boolean _isEnabled();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _checkProgramEnabling();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _go() throws DTraceException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _stop() throws DTraceException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _consume() throws DTraceException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _interrupt();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _close();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native Aggregate _getAggregate(AggregateSpec spec)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throws DTraceException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native int _createProcess(String cmd) throws DTraceException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _grabProcess(int pid) throws DTraceException;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _listProbes(List <ProbeDescription> probeList,

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee ProbeDescription filter);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _listProbeDetail(List <Probe> probeList,

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee ProbeDescription filter);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _listCompiledProbes(

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee List <ProbeDescription> probeList, Program program);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _listCompiledProbeDetail(

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee List <Probe> probeList, Program program);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private static native String _getVersion();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private static native int _openCount();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Releases memory held in the JNI layer after dtrace_close() has

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // released critical system resources like file descriptors, and

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // calls to libdtrace are no longer needed (or possible).

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native void _destroy();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Called by LogDistribution

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee static native long _quantizeBucket(int i);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Cannot be static because the necessary dtrace handle is specific

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // to this Consumer.

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native String _lookupKernelFunction(Number address);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private native String _lookupUserFunction(int pid, Number address);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private static native String _getExecutableName();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Undocumented configuration options

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private static native void _setMaximumConsumers(int max);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private static native void _setDebug(boolean debug);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee protected EventListenerList listenerList;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee protected ExceptionHandler exceptionHandler;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private int _handle = -1; // native C identifier (do not modify)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private final Identifier id; // java identifier

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private enum State {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee INIT,

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee OPEN,

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee COMPILED,

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee GO,

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee STARTED,

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee STOPPED,

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee CLOSED

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private State state = State.INIT;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private boolean stopCalled;

43fb4b48d7d5ba4ce77cb215445844e34af5848btomee private boolean abortCalled;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Per-consumer lock used in native code to prevent conflict between

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // the native consumer loop and the getAggregate() thread without

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // locking this LocalConsumer. A distinct per-consumer lock allows

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // the stop() method to be synchronized without causing deadlock

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // when the consumer loop grabs the per-consumer lock before

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // dtrace_work().

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private Object consumerLock;

52aacb450723e8271d37836e1b5861c2072a3981tomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

52aacb450723e8271d37836e1b5861c2072a3981tomee // stopLock is a synchronization lock used to ensure that the stop()

52aacb450723e8271d37836e1b5861c2072a3981tomee // method does not return until this consumer has actually stopped.

52aacb450723e8271d37836e1b5861c2072a3981tomee // Correct lock ordering is needed to ensure that listeners cannot

52aacb450723e8271d37836e1b5861c2072a3981tomee // deadlock this consumer:

52aacb450723e8271d37836e1b5861c2072a3981tomee // 1. stop() grabs the lock on this consumer before determining if

52aacb450723e8271d37836e1b5861c2072a3981tomee // this consumer is running (to ensure valid state).

52aacb450723e8271d37836e1b5861c2072a3981tomee // 2. Once stop() determines that this consumer is actually running,

52aacb450723e8271d37836e1b5861c2072a3981tomee // it releases the lock on this consumer. Failing to release the

52aacb450723e8271d37836e1b5861c2072a3981tomee // lock makes it possible for a ConsumerListener to deadlock this

52aacb450723e8271d37836e1b5861c2072a3981tomee // consumer by calling any synchronized LocalConcumer method

52aacb450723e8271d37836e1b5861c2072a3981tomee // (because the listener called by the worker thread prevents the

52aacb450723e8271d37836e1b5861c2072a3981tomee // worker thread from finishing while it waits for stop() to

52aacb450723e8271d37836e1b5861c2072a3981tomee // release the lock, which it will never do until the worker

52aacb450723e8271d37836e1b5861c2072a3981tomee // thread finishes).

52aacb450723e8271d37836e1b5861c2072a3981tomee // 3. stop() interrupts this consumer and grabs the stopLock, then

52aacb450723e8271d37836e1b5861c2072a3981tomee // waits on the stopLock for this consumer to stop (i.e. for the

52aacb450723e8271d37836e1b5861c2072a3981tomee // worker thread to finish).

52aacb450723e8271d37836e1b5861c2072a3981tomee // 4. The interrupted worker thread grabs the stopLock when it

52aacb450723e8271d37836e1b5861c2072a3981tomee // finishes so it can notify waiters on the stopLock (in this

52aacb450723e8271d37836e1b5861c2072a3981tomee // case the stop() method) that the worker thread is finished.

52aacb450723e8271d37836e1b5861c2072a3981tomee // The workEnded flag (whose access is protected by the

52aacb450723e8271d37836e1b5861c2072a3981tomee // stopLock), is used in case the interrupted worker thread

52aacb450723e8271d37836e1b5861c2072a3981tomee // finishes and grabs the stopLock before the stop() method does.

52aacb450723e8271d37836e1b5861c2072a3981tomee // Setting the flag in that case tells the stop() method it has

52aacb450723e8271d37836e1b5861c2072a3981tomee // nothing to wait for (otherwise stop() would wait forever,

52aacb450723e8271d37836e1b5861c2072a3981tomee // since there is no one left after the worker thread finishes to

52aacb450723e8271d37836e1b5861c2072a3981tomee // notify the stop() method to stop waiting).

52aacb450723e8271d37836e1b5861c2072a3981tomee // 5. The worker thread updates the state member to STOPPED and

52aacb450723e8271d37836e1b5861c2072a3981tomee // notifies listeners while it holds the stopLock and before it

52aacb450723e8271d37836e1b5861c2072a3981tomee // notifies waiters on the stopLock. This is to ensure that

52aacb450723e8271d37836e1b5861c2072a3981tomee // state has been updated to STOPPED and that listeners have

52aacb450723e8271d37836e1b5861c2072a3981tomee // executed consumerStopped() before the stop() method returns,

52aacb450723e8271d37836e1b5861c2072a3981tomee // to ensure valid state and in case the caller of stop() is

52aacb450723e8271d37836e1b5861c2072a3981tomee // relying on anything having been done by consumerStopped()

52aacb450723e8271d37836e1b5861c2072a3981tomee // before it proceeds to the next statement.

52aacb450723e8271d37836e1b5861c2072a3981tomee // 6. The worker thread notifies waiters on the stopLock before

52aacb450723e8271d37836e1b5861c2072a3981tomee // releasing it. stop() returns.

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private Object stopLock;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private boolean workEnded;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private static int sequence = 0;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

52aacb450723e8271d37836e1b5861c2072a3981tomee private static void

52aacb450723e8271d37836e1b5861c2072a3981tomee configureLogging()

52aacb450723e8271d37836e1b5861c2072a3981tomee {

52aacb450723e8271d37836e1b5861c2072a3981tomee logger.setUseParentHandlers(false);

52aacb450723e8271d37836e1b5861c2072a3981tomee Handler handler = new ConsoleHandler();

52aacb450723e8271d37836e1b5861c2072a3981tomee handler.setLevel(Level.ALL);

52aacb450723e8271d37836e1b5861c2072a3981tomee logger.addHandler(handler);

52aacb450723e8271d37836e1b5861c2072a3981tomee logger.setLevel(Level.OFF);

52aacb450723e8271d37836e1b5861c2072a3981tomee }

52aacb450723e8271d37836e1b5861c2072a3981tomee

52aacb450723e8271d37836e1b5861c2072a3981tomee private static Integer

52aacb450723e8271d37836e1b5861c2072a3981tomee getIntegerProperty(String name)

52aacb450723e8271d37836e1b5861c2072a3981tomee {

52aacb450723e8271d37836e1b5861c2072a3981tomee Integer value = null;

52aacb450723e8271d37836e1b5861c2072a3981tomee String property = System.getProperty(name);

52aacb450723e8271d37836e1b5861c2072a3981tomee if (property != null && property.length() != 0) {

52aacb450723e8271d37836e1b5861c2072a3981tomee try {

52aacb450723e8271d37836e1b5861c2072a3981tomee value = Integer.parseInt(property);

52aacb450723e8271d37836e1b5861c2072a3981tomee System.out.println(name + "=" + value);

52aacb450723e8271d37836e1b5861c2072a3981tomee } catch (NumberFormatException e) {

52aacb450723e8271d37836e1b5861c2072a3981tomee System.err.println("Warning: property ignored: " +

52aacb450723e8271d37836e1b5861c2072a3981tomee name + "=" + property);

52aacb450723e8271d37836e1b5861c2072a3981tomee }

52aacb450723e8271d37836e1b5861c2072a3981tomee }

52aacb450723e8271d37836e1b5861c2072a3981tomee return value;

52aacb450723e8271d37836e1b5861c2072a3981tomee }

52aacb450723e8271d37836e1b5861c2072a3981tomee

52aacb450723e8271d37836e1b5861c2072a3981tomee private static void

52aacb450723e8271d37836e1b5861c2072a3981tomee getConfigurationOptions()

52aacb450723e8271d37836e1b5861c2072a3981tomee {

52aacb450723e8271d37836e1b5861c2072a3981tomee Integer property;

52aacb450723e8271d37836e1b5861c2072a3981tomee property = getIntegerProperty("JAVA_DTRACE_API_DEBUG");

52aacb450723e8271d37836e1b5861c2072a3981tomee if (property != null) {

52aacb450723e8271d37836e1b5861c2072a3981tomee debug = (property != 0);

52aacb450723e8271d37836e1b5861c2072a3981tomee }

52aacb450723e8271d37836e1b5861c2072a3981tomee property = getIntegerProperty("JAVA_DTRACE_MAX_CONSUMERS");

52aacb450723e8271d37836e1b5861c2072a3981tomee if (property != null) {

52aacb450723e8271d37836e1b5861c2072a3981tomee maxConsumers = property;

52aacb450723e8271d37836e1b5861c2072a3981tomee }

52aacb450723e8271d37836e1b5861c2072a3981tomee }

52aacb450723e8271d37836e1b5861c2072a3981tomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee /**

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee LocalConsumer()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee id = new LocalConsumer.Identifier(this);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee consumerLock = new Object();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee stopLock = new Object();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee listenerList = new EventListenerList();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee /**

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private int

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee getHandle()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return _handle;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee /**

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee setHandle(int n)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _handle = n;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee open(OpenFlag ... flags) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (state == State.CLOSED) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("cannot reopen a closed consumer");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (state != State.INIT) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer already open");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (OpenFlag flag : flags) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (flag == null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new NullPointerException("open flag is null");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _open(flags);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee state = State.OPEN;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee setOptions(DEFAULT_OPTIONS);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

43fb4b48d7d5ba4ce77cb215445844e34af5848btomee if (abortCalled) {

43fb4b48d7d5ba4ce77cb215445844e34af5848btomee _interrupt();

43fb4b48d7d5ba4ce77cb215445844e34af5848btomee }

43fb4b48d7d5ba4ce77cb215445844e34af5848btomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (logger.isLoggable(Level.INFO)) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee logger.info("consumer table count: " + _openCount());

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private synchronized void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkCompile()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee switch (state) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case INIT:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer not open");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case OPEN:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case COMPILED: // caller may compile more than one program

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee break;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case GO:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STARTED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("go() already called");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STOPPED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer stopped");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case CLOSED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer closed");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized Program

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee compile(String program, String ... macroArgs) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (program == null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new NullPointerException("program string is null");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkCompile();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Program p = null;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee String[] argv = null;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (macroArgs != null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (String macroArg : macroArgs) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (macroArg == null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new NullPointerException("macro argument is null");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee argv = new String[macroArgs.length + 1];

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Could be an application with an embedded JVM, not

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // necessarily "java".

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee argv[0] = _getExecutableName();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee System.arraycopy(macroArgs, 0, argv, 1, macroArgs.length);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee } else {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee argv = new String[] { _getExecutableName() };

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee p = _compileString(program, argv);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee p.consumerID = id;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee p.contents = program;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee p.validate();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee state = State.COMPILED;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return p;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized Program

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee compile(File program, String ... macroArgs) throws DTraceException,

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee IOException, SecurityException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (program == null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new NullPointerException("program file is null");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (!program.canRead()) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new FileNotFoundException("failed to open " +

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee program.getName());

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkCompile();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Program.File p = null;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee String[] argv = null;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (macroArgs != null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (String macroArg : macroArgs) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (macroArg == null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new NullPointerException("macro argument is null");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee argv = new String[macroArgs.length + 1];

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee argv[0] = program.getPath();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee System.arraycopy(macroArgs, 0, argv, 1, macroArgs.length);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee } else {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee macroArgs = new String[] { program.getPath() };

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee p = _compileFile(program.getPath(), argv);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee p.consumerID = id;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee p.contents = Program.getProgramString(program);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee p.file = program;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee p.validate();

91cfa10a8e55050a5103c4b2e83b0bf8d783a7cbtomee p.validateFile();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee state = State.COMPILED;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return p;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private synchronized void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkProgram(Program program)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (program == null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new NullPointerException("program is null");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (!id.equals(program.consumerID)) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalArgumentException("program not compiled " +

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee "by this consumer");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee enable() throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee enable(null);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee enable(Program program) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee switch (state) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case INIT:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer not open");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case OPEN:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("no compiled program");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case COMPILED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee break;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case GO:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STARTED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("go() already called");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STOPPED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer stopped");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case CLOSED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer closed");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Compile all programs if null

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (program != null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkProgram(program);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Left to native code to throw IllegalArgumentException if the

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // program is already enabled, since only the native code knows

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // the enabled state.

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _exec(program);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee getProgramInfo(Program program) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkProgram(program);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (state == State.CLOSED) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer closed");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // The given program was compiled by this consumer, so we can

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // assert the following:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee assert ((state != State.INIT) && (state != State.OPEN));

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _getProgramInfo(program);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee setOptions(Option[] options) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (Option o : options) {

52aacb450723e8271d37836e1b5861c2072a3981tomee setOption(o.getName(), o.getValue());

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee setOption(String option) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee setOption(option, Option.VALUE_SET);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee unsetOption(String option) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee setOption(option, Option.VALUE_UNSET);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee setOption(String option, String value) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (option == null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new NullPointerException("option is null");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (value == null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new NullPointerException("option value is null");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee switch (state) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case INIT:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer not open");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case OPEN:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case COMPILED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case GO:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STARTED: // Some options can be set on a running consumer

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STOPPED: // Allowed (may affect getAggregate())

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee break;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case CLOSED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer closed");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _setOption(option, value);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized long

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee getOption(String option) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (option == null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new NullPointerException("option is null");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee switch (state) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case INIT:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer not open");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case OPEN:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case COMPILED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case GO:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STARTED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STOPPED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee break;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case CLOSED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer closed");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee long value;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee value = _getOption(option);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return value;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public final synchronized boolean

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee isOpen()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return ((state != State.INIT) && (state != State.CLOSED));

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public final synchronized boolean

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee isEnabled()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (state != State.COMPILED) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return false;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return _isEnabled();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public final synchronized boolean

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee isRunning()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return (state == State.STARTED);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public final synchronized boolean

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee isClosed()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return (state == State.CLOSED);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee /**

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee protected final void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee work()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee try {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (this) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (state != State.GO) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // stop() was called after go() but before the

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // consumer started

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return; // executes finally block before returning

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee state = State.STARTED;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireConsumerStarted(new ConsumerEvent(this,

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee System.nanoTime()));

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // We should not prevent other consumers from running

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // concurrently while this consumer blocks on the native

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // consumer loop. Instead, native code will acquire the

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // LocalConsumer.class monitor as needed before calling

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // libdtrace functions.

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _consume();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee } catch (Throwable e) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (exceptionHandler != null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee exceptionHandler.handleException(e);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee } else {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee e.printStackTrace();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee } finally {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (stopLock) {

52aacb450723e8271d37836e1b5861c2072a3981tomee // Notify listeners while holding stopLock to guarantee

52aacb450723e8271d37836e1b5861c2072a3981tomee // that listeners finish executing consumerStopped()

52aacb450723e8271d37836e1b5861c2072a3981tomee // before the stop() method returns.

52aacb450723e8271d37836e1b5861c2072a3981tomee synchronized (this) {

4d0eb50e691de4c20b1dd9976ad6839fede8a42dRichard PALO if (state == State.STOPPED || state == State.CLOSED) {

127bbe13a6d36580af6a8ded154f1201a6250772tomee //

127bbe13a6d36580af6a8ded154f1201a6250772tomee // This consumer was stopped just after calling

127bbe13a6d36580af6a8ded154f1201a6250772tomee // go() but before starting (the premature return

127bbe13a6d36580af6a8ded154f1201a6250772tomee // case at the top of this work() method). It is

127bbe13a6d36580af6a8ded154f1201a6250772tomee // possible to call close() on a consumer that has

127bbe13a6d36580af6a8ded154f1201a6250772tomee // been stopped before starting. In that case the

127bbe13a6d36580af6a8ded154f1201a6250772tomee // premature return above still takes us here in the

127bbe13a6d36580af6a8ded154f1201a6250772tomee // finally clause, and we must not revert the CLOSED

127bbe13a6d36580af6a8ded154f1201a6250772tomee // state to STOPPED.

127bbe13a6d36580af6a8ded154f1201a6250772tomee //

127bbe13a6d36580af6a8ded154f1201a6250772tomee } else {

127bbe13a6d36580af6a8ded154f1201a6250772tomee state = State.STOPPED;

127bbe13a6d36580af6a8ded154f1201a6250772tomee fireConsumerStopped(new ConsumerEvent(this,

127bbe13a6d36580af6a8ded154f1201a6250772tomee System.nanoTime()));

127bbe13a6d36580af6a8ded154f1201a6250772tomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

52aacb450723e8271d37836e1b5861c2072a3981tomee

52aacb450723e8271d37836e1b5861c2072a3981tomee // Notify the stop() method to stop waiting

52aacb450723e8271d37836e1b5861c2072a3981tomee workEnded = true;

52aacb450723e8271d37836e1b5861c2072a3981tomee stopLock.notifyAll();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee /**

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee protected Thread

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee createThread()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Thread t = new Thread(new Runnable() {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public void run() {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee work();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }, "DTrace consumer " + id);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return t;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee /**

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee go() throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee go(null);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee /**

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee go(ExceptionHandler h) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee switch (state) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case INIT:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer not open");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case OPEN:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("no compiled program");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case COMPILED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Throws IllegalStateException if not all compiled programs are

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // also enabled. Does not make any calls to libdtrace.

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _checkProgramEnabling();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee break;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case GO:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STARTED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("go() already called");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STOPPED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer stopped");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case CLOSED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer closed");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee default:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalArgumentException("unknown state: " + state);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _go();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee state = State.GO;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee exceptionHandler = h;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Thread t = createThread();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee t.start();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee /**

52aacb450723e8271d37836e1b5861c2072a3981tomee public void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee stop()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

52aacb450723e8271d37836e1b5861c2072a3981tomee boolean running = false;

52aacb450723e8271d37836e1b5861c2072a3981tomee

52aacb450723e8271d37836e1b5861c2072a3981tomee synchronized (this) {

52aacb450723e8271d37836e1b5861c2072a3981tomee switch (state) {

52aacb450723e8271d37836e1b5861c2072a3981tomee case INIT:

52aacb450723e8271d37836e1b5861c2072a3981tomee throw new IllegalStateException("consumer not open");

52aacb450723e8271d37836e1b5861c2072a3981tomee case OPEN:

52aacb450723e8271d37836e1b5861c2072a3981tomee case COMPILED:

52aacb450723e8271d37836e1b5861c2072a3981tomee throw new IllegalStateException("go() not called");

52aacb450723e8271d37836e1b5861c2072a3981tomee case GO:

52aacb450723e8271d37836e1b5861c2072a3981tomee try {

52aacb450723e8271d37836e1b5861c2072a3981tomee synchronized (LocalConsumer.class) {

52aacb450723e8271d37836e1b5861c2072a3981tomee _stop();

52aacb450723e8271d37836e1b5861c2072a3981tomee }

52aacb450723e8271d37836e1b5861c2072a3981tomee state = State.STOPPED;

127bbe13a6d36580af6a8ded154f1201a6250772tomee fireConsumerStopped(new ConsumerEvent(this,

127bbe13a6d36580af6a8ded154f1201a6250772tomee System.nanoTime()));

52aacb450723e8271d37836e1b5861c2072a3981tomee } catch (DTraceException e) {

52aacb450723e8271d37836e1b5861c2072a3981tomee if (exceptionHandler != null) {

52aacb450723e8271d37836e1b5861c2072a3981tomee exceptionHandler.handleException(e);

52aacb450723e8271d37836e1b5861c2072a3981tomee } else {

52aacb450723e8271d37836e1b5861c2072a3981tomee e.printStackTrace();

52aacb450723e8271d37836e1b5861c2072a3981tomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

52aacb450723e8271d37836e1b5861c2072a3981tomee break;

52aacb450723e8271d37836e1b5861c2072a3981tomee case STARTED:

52aacb450723e8271d37836e1b5861c2072a3981tomee running = true;

52aacb450723e8271d37836e1b5861c2072a3981tomee break;

52aacb450723e8271d37836e1b5861c2072a3981tomee case STOPPED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

52aacb450723e8271d37836e1b5861c2072a3981tomee // The work() thread that runs the native consumer

52aacb450723e8271d37836e1b5861c2072a3981tomee // loop may have terminated because of the exit()

52aacb450723e8271d37836e1b5861c2072a3981tomee // action in a DTrace program. In that case, a

52aacb450723e8271d37836e1b5861c2072a3981tomee // RuntimeException is inappropriate because there

52aacb450723e8271d37836e1b5861c2072a3981tomee // is no misuse of the API. Creating a new checked

52aacb450723e8271d37836e1b5861c2072a3981tomee // exception type to handle this case seems to offer

52aacb450723e8271d37836e1b5861c2072a3981tomee // no benefit for the trouble to the caller.

52aacb450723e8271d37836e1b5861c2072a3981tomee // Instead, the situation calls for stop() to be

52aacb450723e8271d37836e1b5861c2072a3981tomee // quietly tolerant.

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

52aacb450723e8271d37836e1b5861c2072a3981tomee if (stopCalled) {

52aacb450723e8271d37836e1b5861c2072a3981tomee throw new IllegalStateException(

52aacb450723e8271d37836e1b5861c2072a3981tomee "consumer already stopped");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee logger.fine("consumer already stopped");

52aacb450723e8271d37836e1b5861c2072a3981tomee break;

52aacb450723e8271d37836e1b5861c2072a3981tomee case CLOSED:

52aacb450723e8271d37836e1b5861c2072a3981tomee throw new IllegalStateException("consumer closed");

52aacb450723e8271d37836e1b5861c2072a3981tomee default:

52aacb450723e8271d37836e1b5861c2072a3981tomee throw new IllegalArgumentException("unknown state: " +

52aacb450723e8271d37836e1b5861c2072a3981tomee state);

52aacb450723e8271d37836e1b5861c2072a3981tomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

52aacb450723e8271d37836e1b5861c2072a3981tomee stopCalled = true;

52aacb450723e8271d37836e1b5861c2072a3981tomee }

52aacb450723e8271d37836e1b5861c2072a3981tomee

52aacb450723e8271d37836e1b5861c2072a3981tomee if (running) {

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee if (Thread.holdsLock(this)) {

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee throw new IllegalThreadStateException("The current " +

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee "thread cannot stop this LocalConsumer while " +

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee "holding the lock on this LocalConsumer");

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee }

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee

52aacb450723e8271d37836e1b5861c2072a3981tomee //

52aacb450723e8271d37836e1b5861c2072a3981tomee // Calls no libdtrace methods, so no synchronization is

52aacb450723e8271d37836e1b5861c2072a3981tomee // needed. Sets a native flag that causes the consumer

52aacb450723e8271d37836e1b5861c2072a3981tomee // thread to exit the consumer loop and call native

52aacb450723e8271d37836e1b5861c2072a3981tomee // dtrace_stop() at the end of the current interval (after

52aacb450723e8271d37836e1b5861c2072a3981tomee // grabbing the global Consumer.class lock required for any

52aacb450723e8271d37836e1b5861c2072a3981tomee // libdtrace call).

52aacb450723e8271d37836e1b5861c2072a3981tomee //

52aacb450723e8271d37836e1b5861c2072a3981tomee _interrupt();

52aacb450723e8271d37836e1b5861c2072a3981tomee

52aacb450723e8271d37836e1b5861c2072a3981tomee synchronized (stopLock) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

52aacb450723e8271d37836e1b5861c2072a3981tomee // Wait for work() to set workEnded. If the work()

52aacb450723e8271d37836e1b5861c2072a3981tomee // thread got the stopLock first, then workEnded is

52aacb450723e8271d37836e1b5861c2072a3981tomee // already set.

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

52aacb450723e8271d37836e1b5861c2072a3981tomee while (!workEnded) {

52aacb450723e8271d37836e1b5861c2072a3981tomee try {

52aacb450723e8271d37836e1b5861c2072a3981tomee stopLock.wait();

52aacb450723e8271d37836e1b5861c2072a3981tomee } catch (InterruptedException e) {

52aacb450723e8271d37836e1b5861c2072a3981tomee logger.warning(e.toString());

52aacb450723e8271d37836e1b5861c2072a3981tomee // do nothing but re-check the condition for

52aacb450723e8271d37836e1b5861c2072a3981tomee // waiting

52aacb450723e8271d37836e1b5861c2072a3981tomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

52aacb450723e8271d37836e1b5861c2072a3981tomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

43fb4b48d7d5ba4ce77cb215445844e34af5848btomee public synchronized void

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee abort()

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee {

43fb4b48d7d5ba4ce77cb215445844e34af5848btomee if ((state != State.INIT) && (state != State.CLOSED)) {

43fb4b48d7d5ba4ce77cb215445844e34af5848btomee _interrupt();

43fb4b48d7d5ba4ce77cb215445844e34af5848btomee }

43fb4b48d7d5ba4ce77cb215445844e34af5848btomee abortCalled = true;

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee }

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee /**

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee public void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee close()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee synchronized (this) {

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee if ((state == State.INIT) || (state == State.CLOSED)) {

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee state = State.CLOSED;

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee return;

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee try {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee stop();

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee } catch (IllegalStateException e) {

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee // ignore (we don't have synchronized state access because

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee // it is illegal to call stop() while holding the lock on

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee // this consumer)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee synchronized (this) {

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee if (state != State.CLOSED) {

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee synchronized (LocalConsumer.class) {

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee _close();

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee }

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee _destroy();

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee state = State.CLOSED;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee if (logger.isLoggable(Level.INFO)) {

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee logger.info("consumer table count: " + _openCount());

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee }

382dbd461c555f1c7e304a961fd0d4458d958ca2tomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee addConsumerListener(ConsumerListener l)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee listenerList.add(ConsumerListener.class, l);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee removeConsumerListener(ConsumerListener l)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee listenerList.remove(ConsumerListener.class, l);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public Aggregate

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee getAggregate() throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // include all, clear none

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return getAggregate(null, Collections. <String> emptySet());

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public Aggregate

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee getAggregate(Set <String> includedAggregationNames)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return getAggregate(includedAggregationNames,

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Collections. <String> emptySet());

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public Aggregate

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee getAggregate(Set <String> includedAggregationNames,

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Set <String> clearedAggregationNames)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee AggregateSpec spec = new AggregateSpec();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (includedAggregationNames == null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee spec.setIncludeByDefault(true);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee } else {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee spec.setIncludeByDefault(false);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (String included : includedAggregationNames) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee spec.addIncludedAggregationName(included);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (clearedAggregationNames == null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee spec.setClearByDefault(true);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee } else {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee spec.setClearByDefault(false);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (String cleared : clearedAggregationNames) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee spec.addClearedAggregationName(cleared);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return getAggregate(spec);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private synchronized Aggregate

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee getAggregate(AggregateSpec spec) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // It should be possible to request aggregation data after a

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // consumer has stopped but not after it has been closed.

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkGoCalled();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Getting the aggregate is a time-consuming request that should not

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // prevent other consumers from running concurrently. Instead,

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // native code will acquire the LocalConsumer.class monitor as

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // needed before calling libdtrace functions.

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee //

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Aggregate aggregate = _getAggregate(spec);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return aggregate;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private synchronized void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkGoCalled()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee switch (state) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case INIT:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer not open");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case OPEN:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case COMPILED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("go() not called");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case GO:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STARTED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STOPPED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee break;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case CLOSED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer closed");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private synchronized void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkGoNotCalled()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee switch (state) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case INIT:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer not open");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case OPEN:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case COMPILED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee break;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case GO:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STARTED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("go() already called");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case STOPPED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer stopped");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee case CLOSED:

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new IllegalStateException("consumer closed");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized int

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee createProcess(String command) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (command == null) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee throw new NullPointerException("command is null");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkGoNotCalled();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee int pid;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee pid = _createProcess(command);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return pid;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee grabProcess(int pid) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkGoNotCalled();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _grabProcess(pid);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized List <ProbeDescription>

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee listProbes(ProbeDescription filter) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkGoNotCalled();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee List <ProbeDescription> probeList =

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee new LinkedList <ProbeDescription> ();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (filter == ProbeDescription.EMPTY) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee filter = null;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _listProbes(probeList, filter);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return probeList;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized List <Probe>

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee listProbeDetail(ProbeDescription filter) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkGoNotCalled();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee List <Probe> probeList = new LinkedList <Probe> ();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (filter == ProbeDescription.EMPTY) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee filter = null;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _listProbeDetail(probeList, filter);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return probeList;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized List <ProbeDescription>

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee listProgramProbes(Program program) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkProgram(program);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkGoNotCalled();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee List <ProbeDescription> probeList =

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee new LinkedList <ProbeDescription> ();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _listCompiledProbes(probeList, program);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return probeList;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized List <Probe>

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee listProgramProbeDetail(Program program) throws DTraceException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkProgram(program);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkGoNotCalled();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee List <Probe> probeList = new LinkedList <Probe> ();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee _listCompiledProbeDetail(probeList, program);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return probeList;

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized String

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee lookupKernelFunction(int address)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkGoCalled();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return _lookupKernelFunction(new Integer(address));

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized String

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee lookupKernelFunction(long address)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkGoCalled();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return _lookupKernelFunction(new Long(address));

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized String

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee lookupUserFunction(int pid, int address)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkGoCalled();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return _lookupUserFunction(pid, new Integer(address));

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public synchronized String

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee lookupUserFunction(int pid, long address)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee checkGoCalled();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return _lookupUserFunction(pid, new Long(address));

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public String

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee getVersion()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (LocalConsumer.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return LocalConsumer._getVersion();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee /**

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee nextProbeData(ProbeData probeData) throws ConsumerException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireDataReceived(new DataEvent(this, probeData));

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee /**

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee dataDropped(Drop drop) throws ConsumerException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireDataDropped(new DropEvent(this, drop));

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee /**

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee errorEncountered(Error error) throws ConsumerException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireErrorEncountered(new ErrorEvent(this, error));

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee /**

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee processStateChanged(ProcessState processState) throws ConsumerException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireProcessStateChanged(new ProcessEvent(this, processState));

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee protected void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireDataReceived(DataEvent e) throws ConsumerException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Guaranteed to return a non-null array

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Object[] listeners = listenerList.getListenerList();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Process the listeners last to first, notifying

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // those that are interested in this event

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (int i = listeners.length - 2; i >= 0; i -= 2) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (listeners[i] == ConsumerListener.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee ((ConsumerListener)listeners[i + 1]).dataReceived(e);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee protected void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireDataDropped(DropEvent e) throws ConsumerException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Guaranteed to return a non-null array

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Object[] listeners = listenerList.getListenerList();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Process the listeners last to first, notifying

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // those that are interested in this event

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (int i = listeners.length - 2; i >= 0; i -= 2) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (listeners[i] == ConsumerListener.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee ((ConsumerListener)listeners[i + 1]).dataDropped(e);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee protected void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireErrorEncountered(ErrorEvent e) throws ConsumerException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Guaranteed to return a non-null array

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Object[] listeners = listenerList.getListenerList();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Process the listeners last to first, notifying

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // those that are interested in this event

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (int i = listeners.length - 2; i >= 0; i -= 2) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (listeners[i] == ConsumerListener.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee ((ConsumerListener)listeners[i + 1]).errorEncountered(e);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee protected void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireProcessStateChanged(ProcessEvent e) throws ConsumerException

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Guaranteed to return a non-null array

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Object[] listeners = listenerList.getListenerList();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Process the listeners last to first, notifying

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // those that are interested in this event

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (int i = listeners.length - 2; i >= 0; i -= 2) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (listeners[i] == ConsumerListener.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee ((ConsumerListener)listeners[i + 1]).processStateChanged(e);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee protected void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireConsumerStarted(ConsumerEvent e)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Guaranteed to return a non-null array

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Object[] listeners = listenerList.getListenerList();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Process the listeners last to first, notifying

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // those that are interested in this event

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (int i = listeners.length - 2; i >= 0; i -= 2) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (listeners[i] == ConsumerListener.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee ((ConsumerListener)listeners[i + 1]).consumerStarted(e);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee protected void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireConsumerStopped(ConsumerEvent e)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Guaranteed to return a non-null array

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Object[] listeners = listenerList.getListenerList();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Process the listeners last to first, notifying

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // those that are interested in this event

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (int i = listeners.length - 2; i >= 0; i -= 2) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (listeners[i] == ConsumerListener.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee ((ConsumerListener)listeners[i + 1]).consumerStopped(e);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Called by native code

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee intervalBegan()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireIntervalBegan(new ConsumerEvent(this, System.nanoTime()));

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee protected void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireIntervalBegan(ConsumerEvent e)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Guaranteed to return a non-null array

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Object[] listeners = listenerList.getListenerList();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Process the listeners last to first, notifying

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // those that are interested in this event

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (int i = listeners.length - 2; i >= 0; i -= 2) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (listeners[i] == ConsumerListener.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee ((ConsumerListener)listeners[i + 1]).intervalBegan(e);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Called by native code

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee private void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee intervalEnded()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireIntervalEnded(new ConsumerEvent(this, System.nanoTime()));

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee protected void

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee fireIntervalEnded(ConsumerEvent e)

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Guaranteed to return a non-null array

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee Object[] listeners = listenerList.getListenerList();

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // Process the listeners last to first, notifying

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee // those that are interested in this event

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee for (int i = listeners.length - 2; i >= 0; i -= 2) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee if (listeners[i] == ConsumerListener.class) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee ((ConsumerListener)listeners[i + 1]).intervalEnded(e);

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee /**

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee public String

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee toString()

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee {

4ae67516a1d5dc4a5dbc761762bad5b596647388tomee StringBuilder buf = new StringBuilder(LocalConsumer.class.getName());

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee synchronized (this) {

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee buf.append("[open = ");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee buf.append(isOpen());

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee buf.append(", enabled = ");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee buf.append(isEnabled());

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee buf.append(", running = ");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee buf.append(isRunning());

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee buf.append(", closed = ");

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee buf.append(isClosed());

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee }

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee buf.append(']');

fb3fb4f3d76d55b64440afd0af72775dfad3bd1dtomee return buf.toString();