Lines Matching refs:consumer
32 * Regression for bug 6419880 close() hangs running consumer.
38 Consumer consumer = new LocalConsumer();
41 consumer.open();
42 consumer.compile("syscall:::entry { @[execname] = count(); } " +
44 consumer.enable();
45 consumer.go();
52 consumer.close();
58 consumer = new LocalConsumer();
61 consumer.open();
62 consumer.compile("syscall:::entry { @[execname] = count(); } " +
64 consumer.enable();
65 consumer.go();
74 // lock on consumer.
75 synchronized (consumer) {
76 consumer.close();
79 consumer.close();