Symbol: consumer
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
101
consumer.abort();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
102
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
103
consumer.abort();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
104
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
105
consumer.abort();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
106
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
109
consumer.abort();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
119
consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
124
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
125
consumer.compile("syscall:::entry { @[execname] = count(); } " +
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
127
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
128
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
136
synchronized (consumer) {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
137
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
141
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
40
Consumer consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
44
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
45
consumer.compile("syscall:::entry { @[execname] = count(); } " +
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
47
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
48
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
55
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
61
consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
66
consumer.addConsumerListener(new ConsumerAdapter() {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
71
consumer.abort();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
72
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
73
consumer.compile("syscall:::entry { @[execname] = count(); } " +
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
75
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
76
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
86
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
92
consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
96
consumer.abort();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
97
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
98
consumer.abort();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestAbort.java
99
consumer.compile("syscall:::entry { @[execname] = count(); } " +
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestBean.java
544
Consumer consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestBean.java
547
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestBean.java
548
p = consumer.compile(PROGRAM);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestBean.java
549
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestBean.java
561
Consumer consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestBean.java
568
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestBean.java
569
p = consumer.compile(file);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestBean.java
570
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
36
Consumer consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
39
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
40
consumer.compile("syscall:::entry { @[execname] = count(); } " +
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
42
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
43
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
50
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
56
consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
59
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
60
consumer.compile("syscall:::entry { @[execname] = count(); } " +
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
62
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
63
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
73
synchronized (consumer) {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
74
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestClose.java
77
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
123
final Consumer consumer = new LocalConsumer() {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
137
consumer.addConsumerListener(new ConsumerAdapter() {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
139
startAggregateThread(consumer);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
153
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
154
consumer.setOption(Option.aggsize, Option.kb(1));
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
155
consumer.setOption(Option.aggrate, Option.millis(101));
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
156
consumer.compile(PROGRAM);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
157
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
158
consumer.go(new ExceptionHandler() {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
60
sampleAggregate(Consumer consumer) throws DTraceException
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
62
while (consumer.isRunning() && !done.get()) {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
68
consumer.getAggregate(Collections. <String> emptySet());
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
73
startAggregateThread(final Consumer consumer)
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
81
sampleAggregate(consumer);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestDrop.java
94
consumer.close(); // blocks if lock held
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
104
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
120
consumer.enable(p3x);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
132
consumer.enable(p3);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
133
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
134
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
137
consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
138
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
139
consumer.compile("dtrace:::BEGIN");
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
140
consumer.compile("syscall:::entry");
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
141
consumer.compile("dtrace:::END");
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
142
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
143
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
144
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
48
Consumer consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
51
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
52
Program p0 = consumer.compile("dtrace:::BEGIN");
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
53
Program p1 = consumer.compile("syscall:::entry");
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
54
Program p2 = consumer.compile("dtrace:::END");
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
55
consumer.enable(p0);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
56
consumer.enable(p1);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
58
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
69
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
80
consumer.enable(p0);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
90
consumer.enable(p2);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
91
Program p3 = consumer.compile("syscall:::return");
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestEnable.java
93
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
100
f = consumer.lookupUserFunction(pid, addr);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
103
f = consumer.lookupUserFunction(pid, addr);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
108
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
48
Consumer consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
50
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
51
consumer.compile(kernelLookupProgram);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
52
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
53
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
60
a = consumer.getAggregate();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
66
f = consumer.lookupKernelFunction(addr);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
69
f = consumer.lookupKernelFunction(addr);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
78
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
84
consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
86
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
87
int pid = consumer.createProcess(cmd);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
88
consumer.compile(userLookupProgram);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
89
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
90
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestFunctionLookup.java
92
Aggregate a = consumer.getAggregate();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
104
aggregate = consumer.getAggregate(null, cleared);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
110
aggregate = consumer.getAggregate(null, cleared);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
119
} while (consumer.isRunning() && n++ < INTERVALS);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
146
if (!consumer.isRunning()) {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
157
final Consumer consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
158
consumer.addConsumerListener(new ConsumerAdapter() {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
163
testIncluded(consumer, ANONYMOUS_AGGREGATION);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
169
consumer.abort();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
177
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
178
consumer.setOption(Option.aggrate, Option.millis(TICK));
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
179
consumer.compile(programString);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
180
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
181
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
191
final Consumer consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
192
consumer.addConsumerListener(new ConsumerAdapter() {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
197
testCleared(consumer, ANONYMOUS_AGGREGATION);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
203
consumer.abort();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
211
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
212
consumer.setOption(Option.aggrate, Option.millis(TICK));
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
213
consumer.compile(programString);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
214
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
215
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
47
testIncluded(Consumer consumer, String ... aggregationNames)
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
63
aggregate = consumer.getAggregate(included, null);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
81
if (!consumer.isRunning()) {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestGetAggregate.java
87
testCleared(Consumer consumer, String ... aggregationNames)
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestMaxConsumers.java
80
Consumer consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestMaxConsumers.java
81
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestMaxConsumers.java
88
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestMultiAggPrinta.java
111
final Consumer consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestMultiAggPrinta.java
112
consumer.addConsumerListener(new ConsumerAdapter() {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestMultiAggPrinta.java
126
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestMultiAggPrinta.java
133
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestMultiAggPrinta.java
134
consumer.compile(file);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestMultiAggPrinta.java
135
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestMultiAggPrinta.java
136
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestProbeData.java
101
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestProbeData.java
102
consumer.createProcess(command);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestProbeData.java
103
consumer.compile(PROGRAM);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestProbeData.java
104
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestProbeData.java
105
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestProbeData.java
84
final Consumer consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestProbeData.java
86
consumer.addConsumerListener(new ConsumerAdapter() {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestProbeData.java
96
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
102
consumer.setOption(Option.bufsize, Option.mb(1));
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
111
consumer.unsetOption(Option.quiet);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
122
consumer.createProcess("date");
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
131
consumer.grabProcess(1);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
142
consumer.listProbes(ProbeDescription.EMPTY);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
153
consumer.getAggregate();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
164
consumer.getVersion(); // allowed
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
172
beforeCompile(Consumer consumer)
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
175
printState(consumer);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
179
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
190
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
201
beforeEnable(Consumer consumer)
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
204
printState(consumer);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
208
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
219
beforeGo(Consumer consumer)
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
222
printState(consumer);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
226
consumer.getAggregate();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
237
consumer.lookupKernelFunction(1);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
246
consumer.lookupUserFunction(1, 1);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
257
consumer.stop();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
268
afterGo(Consumer consumer, Program program)
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
271
printState(consumer);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
275
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
286
consumer.createProcess("date");
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
295
consumer.grabProcess(1);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
306
consumer.listProbes(ProbeDescription.EMPTY);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
317
consumer.compile("syscall:::entry");
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
328
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
339
consumer.getAggregate();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
347
consumer.getProgramInfo(program);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
355
consumer.getOption(Option.quiet);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
356
consumer.setOption(Option.quiet);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
357
consumer.unsetOption(Option.quiet);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
365
afterStop(Consumer consumer, Program program)
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
368
printState(consumer);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
372
consumer.stop();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
383
consumer.getAggregate();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
391
consumer.getProgramInfo(program);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
399
consumer.getOption(Option.quiet);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
400
consumer.setOption(Option.quiet);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
401
consumer.unsetOption(Option.quiet);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
409
afterClose(Consumer consumer, Program program)
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
412
printState(consumer);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
416
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
427
consumer.compile("syscall:::entry");
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
438
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
449
consumer.getOption(Option.bufsize);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
458
consumer.setOption(Option.bufsize, Option.mb(1));
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
467
consumer.unsetOption(Option.quiet);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
478
consumer.createProcess("date");
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
487
consumer.grabProcess(1);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
498
consumer.listProbes(ProbeDescription.EMPTY);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
509
consumer.getAggregate();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
520
consumer.getVersion(); // allowed
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
528
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
539
consumer.lookupKernelFunction(1);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
548
consumer.lookupUserFunction(1, 1);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
559
consumer.stop();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
56
printState(Consumer consumer)
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
570
consumer.getProgramInfo(program);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
58
System.out.println("open: " + consumer.isOpen());
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
583
final Consumer consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
584
consumer.addConsumerListener(new ConsumerAdapter() {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
587
consumer.isRunning());
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
588
afterGo(consumer, program);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
59
System.out.println("enabled: " + consumer.isEnabled());
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
592
consumer.isRunning());
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
597
beforeOpen(consumer);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
598
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
599
beforeCompile(consumer);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
60
System.out.println("closed: " + consumer.isClosed());
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
600
program = consumer.compile(
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
603
beforeEnable(consumer);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
604
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
605
beforeGo(consumer);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
606
System.out.println("before go, running: " + consumer.isRunning());
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
607
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
615
consumer.stop();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
616
System.out.println("after stop, running: " + consumer.isRunning());
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
617
afterStop(consumer, program);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
618
consumer.close();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
619
afterClose(consumer, program);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
64
beforeOpen(Consumer consumer)
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
67
printState(consumer);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
71
consumer.compile("syscall:::entry");
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
82
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStateMachine.java
93
consumer.getOption(Option.bufsize);
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStopLock.java
37
final Consumer consumer = new LocalConsumer();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStopLock.java
38
consumer.addConsumerListener(new ConsumerAdapter() {
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStopLock.java
41
consumer.isRunning();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStopLock.java
46
consumer.open();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStopLock.java
47
consumer.compile("syscall:::entry { @[execname] = count(); } " +
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStopLock.java
49
consumer.enable();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStopLock.java
50
consumer.go();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStopLock.java
57
consumer.stop();
usr/src/cmd/dtrace/test/tst/common/java_api/src/TestStopLock.java
58
consumer.close();
usr/src/lib/libdhcputil/common/dhcp_inittab.c
111
inittab_load(uchar_t categories, char consumer, size_t *n_entries)
usr/src/lib/libdhcputil/common/dhcp_inittab.c
113
return (inittab_lookup(categories, consumer, NULL, -1, n_entries));
usr/src/lib/libdhcputil/common/dhcp_inittab.c
127
inittab_getbyname(uchar_t categories, char consumer, const char *name)
usr/src/lib/libdhcputil/common/dhcp_inittab.c
129
return (inittab_lookup(categories, consumer, name, -1, NULL));
usr/src/lib/libdhcputil/common/dhcp_inittab.c
143
inittab_getbycode(uchar_t categories, char consumer, uint16_t code)
usr/src/lib/libdhcputil/common/dhcp_inittab.c
145
return (inittab_lookup(categories, consumer, NULL, code, NULL));
usr/src/lib/libdhcputil/common/dhcp_inittab.c
163
inittab_lookup(uchar_t categories, char consumer, const char *name,
usr/src/lib/libdhcputil/common/dhcp_inittab.c
254
if (strchr(fields[ITAB_CONS], consumer) == NULL)
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
174
dtj_consumer_t *consumer;
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
182
consumer = g_consumer_table[handle];
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
184
consumer = NULL;
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
187
consumer = NULL;
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
190
if (consumer == NULL) {
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
199
jc->dtjj_consumer = consumer;
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
317
dtj_consumer_t *consumer;
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
322
consumer = dtj_remove_consumer_at(handle);
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
323
return (consumer);
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
333
dtj_consumer_t *consumer;
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
337
consumer = g_consumer_table[handle];
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
338
if (consumer != NULL) {
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
349
consumer = NULL;
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
352
consumer = NULL;
usr/src/lib/libdtrace_jni/common/dtrace_jni.c
355
return (consumer);
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI.java
45
Consumer consumer = new LocalConsumer();
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI.java
46
consumer.addConsumerListener(new ConsumerAdapter() {
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI.java
53
consumer.open();
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI.java
54
consumer.compile(file, macroArgs);
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI.java
55
consumer.enable();
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI.java
56
consumer.go();
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI2.java
46
Consumer consumer = new LocalConsumer();
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI2.java
47
consumer.addConsumerListener(new ConsumerAdapter() {
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI2.java
62
consumer.open();
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI2.java
63
consumer.compile(file, macroArgs);
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI2.java
64
consumer.enable();
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI2.java
65
consumer.go();
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI2.java
70
a = consumer.getAggregate();
usr/src/lib/libdtrace_jni/java/docs/examples/TestAPI2.java
74
} while (consumer.isRunning());
usr/src/lib/libdtrace_jni/java/docs/examples/TestTarget.java
44
final Consumer consumer = new LocalConsumer();
usr/src/lib/libdtrace_jni/java/docs/examples/TestTarget.java
45
consumer.addConsumerListener(new ConsumerAdapter() {
usr/src/lib/libdtrace_jni/java/docs/examples/TestTarget.java
51
Aggregate a = consumer.getAggregate();
usr/src/lib/libdtrace_jni/java/docs/examples/TestTarget.java
62
consumer.close();
usr/src/lib/libdtrace_jni/java/docs/examples/TestTarget.java
70
consumer.open();
usr/src/lib/libdtrace_jni/java/docs/examples/TestTarget.java
72
consumer.createProcess(command);
usr/src/lib/libdtrace_jni/java/docs/examples/TestTarget.java
73
consumer.compile(file);
usr/src/lib/libdtrace_jni/java/docs/examples/TestTarget.java
74
consumer.enable();
usr/src/lib/libdtrace_jni/java/docs/examples/TestTarget.java
75
consumer.go();
usr/src/lib/libdtrace_jni/java/src/org/opensolaris/os/dtrace/LocalConsumer.java
1381
Identifier(LocalConsumer consumer)
usr/src/lib/libdtrace_jni/java/src/org/opensolaris/os/dtrace/LocalConsumer.java
1390
tag = consumer.getTag();
usr/src/lib/libslp/clib/slp_ua_common.c
114
return ((SLPError)consumer(args));
usr/src/lib/libslp/clib/slp_ua_common.c
44
static void *consumer(void *);
usr/src/lib/libslp/clib/slp_ua_common.c
99
if ((terr = thr_create(NULL, 0, consumer,
usr/src/uts/common/io/mega_sas/megaraid_sas.c
1692
uint32_t consumer;
usr/src/uts/common/io/mega_sas/megaraid_sas.c
1715
consumer = *instance->consumer;
usr/src/uts/common/io/mega_sas/megaraid_sas.c
1718
producer, consumer));
usr/src/uts/common/io/mega_sas/megaraid_sas.c
1722
while (consumer != producer) {
usr/src/uts/common/io/mega_sas/megaraid_sas.c
1723
context = instance->reply_queue[consumer];
usr/src/uts/common/io/mega_sas/megaraid_sas.c
1727
consumer++;
usr/src/uts/common/io/mega_sas/megaraid_sas.c
1728
if (consumer == (instance->max_fw_cmds + 1)) {
usr/src/uts/common/io/mega_sas/megaraid_sas.c
1729
consumer = 0;
usr/src/uts/common/io/mega_sas/megaraid_sas.c
1735
*instance->consumer = consumer;
usr/src/uts/common/io/mega_sas/megaraid_sas.c
1955
instance->consumer = (uint32_t *)((unsigned long)
usr/src/uts/common/io/mega_sas/megaraid_sas.h
1142
uint32_t *consumer;
usr/src/uts/common/io/mr_sas/mr_sas.c
2306
uint32_t consumer;
usr/src/uts/common/io/mr_sas/mr_sas.c
2359
consumer = ddi_get32(instance->mfi_internal_dma_obj.acc_handle,
usr/src/uts/common/io/mr_sas/mr_sas.c
2360
instance->consumer);
usr/src/uts/common/io/mr_sas/mr_sas.c
2363
producer, consumer));
usr/src/uts/common/io/mr_sas/mr_sas.c
2364
if (producer == consumer) {
usr/src/uts/common/io/mr_sas/mr_sas.c
2367
uint32_t, consumer);
usr/src/uts/common/io/mr_sas/mr_sas.c
2373
while (consumer != producer) {
usr/src/uts/common/io/mr_sas/mr_sas.c
2375
&instance->reply_queue[consumer]);
usr/src/uts/common/io/mr_sas/mr_sas.c
2392
consumer++;
usr/src/uts/common/io/mr_sas/mr_sas.c
2393
if (consumer == (instance->max_fw_cmds + 1)) {
usr/src/uts/common/io/mr_sas/mr_sas.c
2394
consumer = 0;
usr/src/uts/common/io/mr_sas/mr_sas.c
2398
instance->consumer, consumer);
usr/src/uts/common/io/mr_sas/mr_sas.c
3017
instance->consumer = (uint32_t *)((unsigned long)
usr/src/uts/common/io/mr_sas/mr_sas.c
7021
instance->consumer, 0);
usr/src/uts/common/io/mr_sas/mr_sas.c
7026
*instance->consumer));
usr/src/uts/common/io/mr_sas/mr_sas.h
466
uint32_t *consumer;
usr/src/uts/common/io/ntxn/unm_nic_main.c
1332
uint32_t consumer, start;
usr/src/uts/common/io/ntxn/unm_nic_main.c
1336
start = consumer = recv_ctx->statusRxConsumer;
usr/src/uts/common/io/ntxn/unm_nic_main.c
1343
desc = &desc_head[consumer];
usr/src/uts/common/io/ntxn/unm_nic_main.c
1350
consumer = (consumer + 1) % adapter->MaxRxDescCount;
usr/src/uts/common/io/ntxn/unm_nic_main.c
1367
recv_ctx->statusRxConsumer = consumer;
usr/src/uts/common/io/ntxn/unm_nic_main.c
1371
recv_ctx->host_sds_consumer, &consumer, 4);
usr/src/uts/common/io/ntxn/unm_nic_main.c
1383
u32 consumer;
usr/src/uts/common/io/ntxn/unm_nic_main.c
1394
consumer = *(adapter->cmdConsumer);
usr/src/uts/common/io/ntxn/unm_nic_main.c
1396
while (last_consumer != consumer) {
usr/src/uts/common/io/ntxn/unm_nic_main.c
1453
consumer = *(adapter->cmdConsumer);
usr/src/uts/common/io/ntxn/unm_nic_main.c
1454
done = (adapter->lastCmdConsumer == consumer);
usr/src/uts/i86pc/io/acpi/acpidev/acpidev_resource.c
1002
rhdl = acpidev_resource_handle_alloc(consumer);
usr/src/uts/i86pc/io/acpi/acpidev/acpidev_resource.c
1003
if (consumer) {
usr/src/uts/i86pc/io/acpi/acpidev/acpidev_resource.c
1026
acpidev_resource_process(acpidev_walk_info_t *infop, boolean_t consumer)
usr/src/uts/i86pc/io/acpi/acpidev/acpidev_resource.c
1042
consumer, &rhdl);
usr/src/uts/i86pc/io/acpi/acpidev/acpidev_resource.c
1050
if (consumer) {
usr/src/uts/i86pc/io/acpi/acpidev/acpidev_resource.c
68
acpidev_resource_handle_alloc(boolean_t consumer)
usr/src/uts/i86pc/io/acpi/acpidev/acpidev_resource.c
73
rhdl->acpidev_consumer = consumer;
usr/src/uts/i86pc/io/acpi/acpidev/acpidev_resource.c
968
boolean_t consumer, acpidev_resource_handle_t *rhdlp)
usr/src/uts/i86pc/sys/acpidev_rsc.h
144
boolean_t consumer);
usr/src/uts/i86pc/sys/acpidev_rsc.h
185
boolean_t consumer, acpidev_resource_handle_t *rhdlp);
usr/src/uts/i86pc/sys/acpidev_rsc.h
194
boolean_t consumer);