592             public void consumerStopped(ConsumerEvent e) {
 593                 System.out.println("consumerStopped, running: " +
 594                         consumer.isRunning());
 595             }
 596         });
 597 
 598         try {
 599             beforeOpen(consumer);
 600             consumer.open();
 601             beforeCompile(consumer);
 602             program = consumer.compile(
 603                     "syscall:::entry { @[execname] = count(); } " +
 604                     "tick-101ms { printa(@); }");
 605             beforeEnable(consumer);
 606             consumer.enable();
 607             beforeGo(consumer);
 608             System.out.println("before go, running: " + consumer.isRunning());
 609             consumer.go();
 610             // Avoid race, call afterGo() in ConsumerListener
 611             try {
 612                 Thread.currentThread().sleep(300);
 613             } catch (InterruptedException e) {
 614                 e.printStackTrace();
 615                 exit(1);
 616             }
 617             consumer.stop();
 618             System.out.println("after stop, running: " + consumer.isRunning());
 619             afterStop(consumer, program);
 620             consumer.close();
 621             afterClose(consumer, program);
 622         } catch (DTraceException e) {
 623             e.printStackTrace();
 624             exit(1);
 625         }
 626     }
 627 }

 592             public void consumerStopped(ConsumerEvent e) {
 593                 System.out.println("consumerStopped, running: " +
 594                         consumer.isRunning());
 595             }
 596         });
 597 
 598         try {
 599             beforeOpen(consumer);
 600             consumer.open();
 601             beforeCompile(consumer);
 602             program = consumer.compile(
 603                     "syscall:::entry { @[execname] = count(); } " +
 604                     "tick-101ms { printa(@); }");
 605             beforeEnable(consumer);
 606             consumer.enable();
 607             beforeGo(consumer);
 608             System.out.println("before go, running: " + consumer.isRunning());
 609             consumer.go();
 610             // Avoid race, call afterGo() in ConsumerListener
 611             try {
 612                 Thread.sleep(300);
 613             } catch (InterruptedException e) {
 614                 e.printStackTrace();
 615                 exit(1);
 616             }
 617             consumer.stop();
 618             System.out.println("after stop, running: " + consumer.isRunning());
 619             afterStop(consumer, program);
 620             consumer.close();
 621             afterClose(consumer, program);
 622         } catch (DTraceException e) {
 623             e.printStackTrace();
 624             exit(1);
 625         }
 626     }
 627 }