Lines Matching refs:consumer

58     printState(Consumer consumer)
60 System.out.println("open: " + consumer.isOpen());
61 System.out.println("enabled: " + consumer.isEnabled());
62 System.out.println("closed: " + consumer.isClosed());
66 beforeOpen(Consumer consumer)
69 printState(consumer);
73 consumer.compile("syscall:::entry");
84 consumer.enable();
95 consumer.getOption(Option.bufsize);
104 consumer.setOption(Option.bufsize, Option.mb(1));
113 consumer.unsetOption(Option.quiet);
124 consumer.createProcess("date");
133 consumer.grabProcess(1);
144 consumer.listProbes(ProbeDescription.EMPTY);
155 consumer.getAggregate();
166 consumer.getVersion(); // allowed
174 beforeCompile(Consumer consumer)
177 printState(consumer);
181 consumer.open();
192 consumer.enable();
203 beforeEnable(Consumer consumer)
206 printState(consumer);
210 consumer.go();
221 beforeGo(Consumer consumer)
224 printState(consumer);
228 consumer.getAggregate();
239 consumer.lookupKernelFunction(1);
248 consumer.lookupUserFunction(1, 1);
259 consumer.stop();
270 afterGo(Consumer consumer, Program program)
273 printState(consumer);
277 consumer.go();
288 consumer.createProcess("date");
297 consumer.grabProcess(1);
308 consumer.listProbes(ProbeDescription.EMPTY);
319 consumer.compile("syscall:::entry");
330 consumer.enable();
341 consumer.getAggregate();
349 consumer.getProgramInfo(program);
357 consumer.getOption(Option.quiet);
358 consumer.setOption(Option.quiet);
359 consumer.unsetOption(Option.quiet);
367 afterStop(Consumer consumer, Program program)
370 printState(consumer);
374 consumer.stop();
385 consumer.getAggregate();
393 consumer.getProgramInfo(program);
401 consumer.getOption(Option.quiet);
402 consumer.setOption(Option.quiet);
403 consumer.unsetOption(Option.quiet);
411 afterClose(Consumer consumer, Program program)
414 printState(consumer);
418 consumer.open();
429 consumer.compile("syscall:::entry");
440 consumer.enable();
451 consumer.getOption(Option.bufsize);
460 consumer.setOption(Option.bufsize, Option.mb(1));
469 consumer.unsetOption(Option.quiet);
480 consumer.createProcess("date");
489 consumer.grabProcess(1);
500 consumer.listProbes(ProbeDescription.EMPTY);
511 consumer.getAggregate();
522 consumer.getVersion(); // allowed
530 consumer.go();
541 consumer.lookupKernelFunction(1);
550 consumer.lookupUserFunction(1, 1);
561 consumer.stop();
572 consumer.getProgramInfo(program);
585 final Consumer consumer = new LocalConsumer();
586 consumer.addConsumerListener(new ConsumerAdapter() {
589 consumer.isRunning());
590 afterGo(consumer, program);
594 consumer.isRunning());
599 beforeOpen(consumer);
600 consumer.open();
601 beforeCompile(consumer);
602 program = consumer.compile(
605 beforeEnable(consumer);
606 consumer.enable();
607 beforeGo(consumer);
608 System.out.println("before go, running: " + consumer.isRunning());
609 consumer.go();
617 consumer.stop();
618 System.out.println("after stop, running: " + consumer.isRunning());
619 afterStop(consumer, program);
620 consumer.close();
621 afterClose(consumer, program);