Searched refs:consumer (Results 1 - 25 of 101) sorted by relevance

12345

/freebsd-10-stable/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/java_api/src/
H A DTestAbort.java42 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
[all...]
H A DTestClose.java32 * 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
[all...]
H A DTestStopLock.java39 final Consumer consumer = new LocalConsumer();
40 consumer.addConsumerListener(new ConsumerAdapter() {
43 consumer.isRunning();
48 consumer.open();
49 consumer.compile("syscall:::entry { @[execname] = count(); } " +
51 consumer.enable();
52 consumer.go();
59 consumer.stop();
60 consumer.close();
H A DTestEnable.java34 * consumer.
48 Consumer consumer = new LocalConsumer();
51 consumer.open();
52 Program p0 = consumer.compile("dtrace:::BEGIN");
53 Program p1 = consumer.compile("syscall:::entry");
54 Program p2 = consumer.compile("dtrace:::END");
55 consumer.enable(p0);
56 consumer.enable(p1);
58 consumer.go();
69 consumer
[all...]
H A DTestFunctionLookup.java48 Consumer consumer = new LocalConsumer();
50 consumer.open();
51 consumer.compile(kernelLookupProgram);
52 consumer.enable();
53 consumer.go();
60 a = consumer.getAggregate();
66 f = consumer.lookupKernelFunction(addr);
69 f = consumer.lookupKernelFunction(addr);
78 consumer.close();
84 consumer
[all...]
H A DTestStateMachine.java58 printState(Consumer consumer) argument
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) argument
69 printState(consumer);
73 consumer.compile("syscall:::entry");
84 consumer.enable();
95 consumer.getOption(Option.bufsize);
104 consumer
174 beforeCompile(Consumer consumer) argument
203 beforeEnable(Consumer consumer) argument
221 beforeGo(Consumer consumer) argument
270 afterGo(Consumer consumer, Program program) argument
367 afterStop(Consumer consumer, Program program) argument
411 afterClose(Consumer consumer, Program program) argument
[all...]
H A DTestGetAggregate.java47 testIncluded(Consumer consumer, String ... aggregationNames) argument
63 aggregate = consumer.getAggregate(included, null);
81 if (!consumer.isRunning()) {
82 throw new IllegalStateException("consumer exited");
87 testCleared(Consumer consumer, String ... aggregationNames) argument
104 aggregate = consumer.getAggregate(null, cleared);
110 aggregate = consumer.getAggregate(null, cleared);
119 } while (consumer.isRunning() && n++ < INTERVALS);
146 if (!consumer.isRunning()) {
147 throw new IllegalStateException("consumer exite
[all...]
H A DTestDrop.java62 sampleAggregate(Consumer consumer) throws DTraceException argument
64 while (consumer.isRunning() && !done.get()) {
70 consumer.getAggregate(Collections. <String> emptySet());
75 startAggregateThread(final Consumer consumer) argument
83 sampleAggregate(consumer);
96 consumer.close(); // blocks if lock held
125 final Consumer consumer = new LocalConsumer() {
139 consumer.addConsumerListener(new ConsumerAdapter() {
141 startAggregateThread(consumer);
155 consumer
[all...]
H A DTestProbeData.java84 final Consumer consumer = new LocalConsumer();
86 consumer.addConsumerListener(new ConsumerAdapter() {
96 consumer.close();
101 consumer.open();
102 consumer.createProcess(command);
103 consumer.compile(PROGRAM);
104 consumer.enable();
105 consumer.go();
H A DTestMultiAggPrinta.java111 final Consumer consumer = new LocalConsumer();
112 consumer.addConsumerListener(new ConsumerAdapter() {
125 consumer.close();
132 consumer.open();
133 consumer.compile(file);
134 consumer.enable();
135 consumer.go();
/freebsd-10-stable/sys/dev/fdt/
H A Dfdt_clock.h34 * Get info about the Nth clock listed in consumer's "clocks" property.
38 int fdt_clock_get_info(device_t consumer, int n, struct fdt_clock_info *info);
41 * Look up "clocks" property in consumer's fdt data and enable or disable all
44 int fdt_clock_enable_all(device_t consumer);
45 int fdt_clock_disable_all(device_t consumer);
H A Dfdt_clock.c52 enable_disable_all(device_t consumer, boolean_t enable) argument
60 cnode = ofw_bus_get_node(consumer);
64 device_printf(consumer, "Warning: No clocks specified in fdt "
74 device_printf(consumer, "Warning: can not find "
86 device_printf(consumer, "Warning: failed to "
97 fdt_clock_get_info(device_t consumer, int n, struct fdt_clock_info *info) argument
104 cnode = ofw_bus_get_node(consumer);
135 fdt_clock_enable_all(device_t consumer) argument
138 return (enable_disable_all(consumer, true));
142 fdt_clock_disable_all(device_t consumer) argument
[all...]
/freebsd-10-stable/contrib/llvm/tools/llvm-diff/
H A DDifferenceEngine.h39 Engine.consumer.enterContext(L, R);
43 Engine.consumer.exitContext();
61 DifferenceEngine(Consumer &consumer) argument
62 : consumer(consumer), globalValueOracle(0) {}
67 consumer.log(text);
70 return LogBuilder(consumer, text);
72 Consumer& getConsumer() const { return consumer; }
86 Consumer &consumer; member in class:llvm::DifferenceEngine
H A DDiffLog.h30 Consumer &consumer; member in class:llvm::LogBuilder
42 : consumer(c), Format(Format) {}
61 Consumer &consumer; member in class:llvm::DiffLogBuilder
64 DiffLogBuilder(Consumer &c) : consumer(c) {}
/freebsd-10-stable/tools/regression/geom/ConfCmp/
H A Da2d.conf9 <consumer id="0x80ba240">
13 </consumer>
19 <consumer id="0x80ba200">
23 </consumer>
29 <consumer id="0x80ba1c0">
33 </consumer>
39 <consumer id="0x80ba180">
43 </consumer>
49 <consumer id="0x80ba140">
53 </consumer>
[all...]
H A Da2.conf9 <consumer id="0x80ba240">
13 </consumer>
19 <consumer id="0x80ba200">
23 </consumer>
29 <consumer id="0x80ba1c0">
33 </consumer>
39 <consumer id="0x80ba180">
43 </consumer>
49 <consumer id="0x80ba140">
53 </consumer>
[all...]
H A Da2a.conf9 <consumer id="0x90ba240">
13 </consumer>
19 <consumer id="0x90ba200">
23 </consumer>
29 <consumer id="0x90ba1c0">
33 </consumer>
39 <consumer id="0x90ba180">
43 </consumer>
49 <consumer id="0x90ba140">
53 </consumer>
[all...]
H A Da2b.conf9 <consumer id="0x80ba240">
13 </consumer>
19 <consumer id="0x80ba200">
23 </consumer>
29 <consumer id="0x80ba1c0">
33 </consumer>
39 <consumer id="0x80ba180">
43 </consumer>
49 <consumer id="0x80ba140">
53 </consumer>
[all...]
H A Da2c.conf9 <consumer id="0x80ba240">
13 </consumer>
19 <consumer id="0x80ba200">
23 </consumer>
29 <consumer id="0x80ba1c0">
33 </consumer>
39 <consumer id="0x80ba180">
42 </consumer>
48 <consumer id="0x80ba140">
52 </consumer>
[all...]
H A Da1.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all...]
H A Da1a.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all...]
H A Da1b.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all...]
H A Da1c.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all...]
H A Da1d.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all...]
/freebsd-10-stable/usr.bin/fstat/
H A Dfuser.c84 struct consumer { struct
90 STAILQ_ENTRY(consumer) next;
96 STAILQ_HEAD(, consumer) consumers;
110 static void printflags(struct consumer *consumer);
127 printflags(struct consumer *cons)
163 struct consumer *consumer; local
262 STAILQ_FOREACH(consumer, &reqfiles[i].consumers, next) {
263 if (consumer
[all...]

Completed in 110 milliseconds

12345