Lines Matching refs:consumer
42 Consumer consumer = new LocalConsumer();
46 consumer.open();
47 consumer.compile("syscall:::entry { @[execname] = count(); } " +
49 consumer.enable();
50 consumer.go();
57 consumer.close();
63 consumer = new LocalConsumer();
65 // Should be able to abort an unopened consumer
68 consumer.addConsumerListener(new ConsumerAdapter() {
73 consumer.abort();
74 consumer.open();
75 consumer.compile("syscall:::entry { @[execname] = count(); } " +
77 consumer.enable();
78 consumer.go();
86 throw new IllegalStateException("consumer not aborted");
88 consumer.close();
94 consumer = new LocalConsumer();
98 consumer.abort();
99 consumer.open();
100 consumer.abort();
101 consumer.compile("syscall:::entry { @[execname] = count(); } " +
103 consumer.abort();
104 consumer.enable();
105 consumer.abort();
106 consumer.go();
107 consumer.abort();
108 consumer.close();
111 consumer.abort();
121 consumer = new LocalConsumer();
124 // synchronized consumer.
126 consumer.open();
127 consumer.compile("syscall:::entry { @[execname] = count(); } " +
129 consumer.enable();
130 consumer.go();
138 synchronized (consumer) {
139 consumer.close();
143 consumer.close();