--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/src/org/dancres/blitz/tools/MonitorStats.java	Sat Mar 21 11:00:06 2009 +0000
@@ -0,0 +1,161 @@
+package org.dancres.blitz.tools;
+
+import java.io.IOException;
+
+import java.rmi.RemoteException;
+import java.rmi.RMISecurityManager;
+
+import net.jini.discovery.*;
+
+import net.jini.lookup.*;
+import net.jini.lookup.entry.Name;
+
+import net.jini.core.lookup.ServiceItem;
+import net.jini.core.lookup.ServiceTemplate;
+
+import net.jini.core.entry.Entry;
+
+import net.jini.admin.Administrable;
+
+import net.jini.space.JavaSpace;
+
+import net.jini.core.transaction.TransactionException;
+
+import org.dancres.blitz.remote.BlitzAdmin;
+
+import org.dancres.jini.util.DiscoveryUtil;
+import org.dancres.jini.util.ServiceLocator;
+
+import org.dancres.blitz.stats.*;
+
+import org.dancres.blitz.remote.StatsAdmin;
+
+/**
+   <p>MonitorStats accepts a spacename as an argument and a loop time.  It then
+   attempts to list all available statistics on the space every loop time
+   seconds.  Specifying a loop time of 0 will cause MonitorStats to dump
+   stats once and exit.</p>
+
+   <p>Typical usage:
+
+   <pre>
+   java -Xmx256m -Djava.security.policy=config/policy.all
+     -classpath /home/dan/jini/jini2_0/lib/jsk-platform.jar:/home/dan/src/jini/space/build:/home/dan/jini/jini2_0/lib/jini-ext.jar:/home/dan/jini/jini2_0/lib/sun-util.jar
+     org.dancres.blitz.tools.MonitorStats dancres 20
+   </pre>
+   
+   @see org.dancres.blitz.remote.BlitzAdmin
+ */
+public class MonitorStats {
+    private static final long MAX_DISCOVER_TIME = 15 * 1000;
+
+    public static void main(String args[]) {
+        if (System.getSecurityManager() == null)
+            System.setSecurityManager(new RMISecurityManager());
+
+        try {
+            try {
+                long myTimeout = 20 * 1000;
+
+                Object myProxy = null;
+
+                if (args.length == 2) {
+                    myProxy = ServiceLocator.getService(JavaSpace.class,
+                                                        args[0],
+                                                        MAX_DISCOVER_TIME);
+                    myTimeout = Integer.parseInt(args[1]) * 1000;
+                } else if (args.length == 3) {
+                    myProxy = ServiceLocator.getService(args[0],
+                                                        JavaSpace.class,
+                                                        args[1]);
+                    myTimeout = Integer.parseInt(args[2]) * 1000;
+                } else {
+                    System.err.println(
+                        "Wrong number of arguments - should be <spacename> <seconds> or <LUS host> <spacename> <seconds>");
+                    System.exit(-1);
+                }
+                    
+                if (myProxy != null) {
+                    System.err.println("Found space: " + myProxy);
+
+                    DiscoveryUtil.dumpInterfaces(myProxy.getClass());
+
+                    if (DiscoveryUtil.hasInterface(myProxy,
+                                                   Administrable.class)) {
+                        Administrable myAdmin = (Administrable) myProxy;
+
+                        Object myAdminProxy = myAdmin.getAdmin();
+
+                        DiscoveryUtil.dumpInterfaces(myAdminProxy.getClass());
+
+                        if (DiscoveryUtil.hasInterface(myAdminProxy,
+                                                       StatsAdmin.class)) {
+                            StatsAdmin myStatsAdmin = 
+                                (StatsAdmin) myAdminProxy;
+
+                            if (myTimeout == 0) {
+                                Stat[] myStats = myStatsAdmin.getStats();
+
+                                System.out.println("Snapshot: " +
+                                    System.currentTimeMillis());
+                                for (int i = 0; i < myStats.length; i++) {
+                                    System.out.println(myStats[i]);
+                                }
+
+                                System.out.println();
+
+                            } else {
+                                new Watcher(myStatsAdmin, myTimeout).start();
+                            }
+                        } else {
+                            System.err.println("No BlitzAdmin interface found - can't be Blitz");
+                        }
+                    } else {
+                        System.err.println("No admin interface present - can't be Blitz");
+                    }
+                }
+            } catch (InterruptedException anIE) {
+                System.err.println("!!! Whoops service not found :( !!!");
+            }
+        } catch (ClassNotFoundException aCNFE) {
+            System.err.println("ClassNotFound exception");
+            aCNFE.printStackTrace(System.err);
+        } catch (RemoteException anRE) {
+            System.err.println("Remote exception");
+            anRE.printStackTrace(System.err);
+        } catch (IOException anIOE) {
+            System.err.println("Failed to configure discovery");
+            anIOE.printStackTrace(System.err);
+        }
+    }
+
+    static class Watcher extends Thread {
+        private StatsAdmin theAdmin;
+        private long theTimeout;
+
+        Watcher(StatsAdmin anAdmin, long aTimeout) {
+            theAdmin = anAdmin;
+            theTimeout = aTimeout;
+        }
+
+        public void run() {
+            while (true) {
+                try {
+                    Stat[] myStats = theAdmin.getStats();
+
+                    System.out.println("Snapshot: " +
+                                       System.currentTimeMillis());
+                    for (int i = 0; i < myStats.length; i++) {
+                        System.out.println(myStats[i]);
+                    }
+
+                    System.out.println();
+
+                    Thread.sleep(theTimeout);
+                } catch (Exception anE) {
+                    System.err.println(anE);
+                }
+            }
+        }
+    }
+}