Home
last modified time | relevance | path

Searched refs:consumer (Results 1 – 25 of 145) sorted by relevance

123456

/freebsd-12.1/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/java_api/src/
H A DTestStateMachine.java69 printState(consumer); in beforeOpen()
84 consumer.enable(); in beforeOpen()
177 printState(consumer); in beforeCompile()
181 consumer.open(); in beforeCompile()
206 printState(consumer); in beforeEnable()
210 consumer.go(); in beforeEnable()
259 consumer.stop(); in beforeGo()
277 consumer.go(); in afterGo()
374 consumer.stop(); in afterStop()
530 consumer.go(); in afterClose()
[all …]
H A DTestAbort.java46 consumer.open(); in main()
50 consumer.go(); in main()
57 consumer.close(); in main()
73 consumer.abort(); in main()
74 consumer.open(); in main()
78 consumer.go(); in main()
99 consumer.open(); in main()
106 consumer.go(); in main()
111 consumer.abort(); in main()
126 consumer.open(); in main()
[all …]
H A DTestEnable.java51 consumer.open(); in main()
58 consumer.go(); in main()
69 consumer.enable(); in main()
80 consumer.enable(p0); in main()
93 consumer.go(); in main()
104 consumer.enable(); in main()
133 consumer.go(); in main()
134 consumer.close(); in main()
138 consumer.open(); in main()
143 consumer.go(); in main()
[all …]
H A DTestFunctionLookup.java48 Consumer consumer = new LocalConsumer(); in main() local
50 consumer.open(); in main()
52 consumer.enable(); in main()
53 consumer.go(); in main()
60 a = consumer.getAggregate(); in main()
78 consumer.close(); in main()
84 consumer = new LocalConsumer(); in main()
86 consumer.open(); in main()
89 consumer.enable(); in main()
90 consumer.go(); in main()
[all …]
H A DTestGetAggregate.java81 if (!consumer.isRunning()) { in testIncluded()
146 if (!consumer.isRunning()) { in testCleared()
169 consumer.abort(); in startIncludedTest()
177 consumer.open(); in startIncludedTest()
179 consumer.compile(programString); in startIncludedTest()
180 consumer.enable(); in startIncludedTest()
181 consumer.go(); in startIncludedTest()
203 consumer.abort(); in startClearedTest()
211 consumer.open(); in startClearedTest()
214 consumer.enable(); in startClearedTest()
[all …]
H A DTestClose.java41 consumer.open(); in main()
44 consumer.enable(); in main()
45 consumer.go(); in main()
52 consumer.close(); in main()
58 consumer = new LocalConsumer(); in main()
61 consumer.open(); in main()
64 consumer.enable(); in main()
65 consumer.go(); in main()
75 synchronized (consumer) { in main()
76 consumer.close(); in main()
[all …]
H A DTestDrop.java64 while (consumer.isRunning() && !done.get()) { in sampleAggregate()
75 startAggregateThread(final Consumer consumer) in startAggregateThread() argument
83 sampleAggregate(consumer); in startAggregateThread()
96 consumer.close(); // blocks if lock held in startAggregateThread()
125 final Consumer consumer = new LocalConsumer() { in main() local
139 consumer.addConsumerListener(new ConsumerAdapter() { in main()
141 startAggregateThread(consumer); in main()
155 consumer.open(); in main()
158 consumer.compile(PROGRAM); in main()
159 consumer.enable(); in main()
[all …]
H A DTestStopLock.java39 final Consumer consumer = new LocalConsumer(); in main() local
40 consumer.addConsumerListener(new ConsumerAdapter() { in main()
43 consumer.isRunning(); in main()
48 consumer.open(); in main()
49 consumer.compile("syscall:::entry { @[execname] = count(); } " + in main()
51 consumer.enable(); in main()
52 consumer.go(); in main()
59 consumer.stop(); in main()
60 consumer.close(); in main()
/freebsd-12.1/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/java_api/
H A Dtst.StateMachine.ksh.out5 java.lang.IllegalStateException: consumer not open
6 java.lang.IllegalStateException: consumer not open
7 java.lang.IllegalStateException: consumer not open
8 java.lang.IllegalStateException: consumer not open
9 java.lang.IllegalStateException: consumer not open
10 java.lang.IllegalStateException: consumer not open
11 java.lang.IllegalStateException: consumer not open
12 java.lang.IllegalStateException: consumer not open
13 java.lang.IllegalStateException: consumer not open
57 java.lang.IllegalStateException: consumer closed
[all …]
/freebsd-12.1/tools/regression/geom/ConfCmp/
H A Da1.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
71 <consumer>
[all …]
H A Da1a.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
71 <consumer>
[all …]
H A Da1b.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
71 <consumer>
[all …]
H A Da1c.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
71 <consumer>
[all …]
H A Da1d.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
71 <consumer>
[all …]
H A Da2d.conf9 <consumer id="0x80ba240">
13 </consumer>
23 </consumer>
33 </consumer>
43 </consumer>
53 </consumer>
57 </consumer>
67 </consumer>
77 </consumer>
95 </consumer>
[all …]
H A Da2.conf9 <consumer id="0x80ba240">
13 </consumer>
19 <consumer id="0x80ba200">
23 </consumer>
33 </consumer>
43 </consumer>
53 </consumer>
63 </consumer>
73 </consumer>
91 </consumer>
[all …]
H A Da2a.conf9 <consumer id="0x90ba240">
13 </consumer>
19 <consumer id="0x90ba200">
23 </consumer>
33 </consumer>
43 </consumer>
53 </consumer>
63 </consumer>
73 </consumer>
91 </consumer>
[all …]
H A Da2b.conf9 <consumer id="0x80ba240">
13 </consumer>
19 <consumer id="0x80ba200">
23 </consumer>
33 </consumer>
43 </consumer>
53 </consumer>
63 </consumer>
73 </consumer>
91 </consumer>
[all …]
H A Da2c.conf9 <consumer id="0x80ba240">
13 </consumer>
19 <consumer id="0x80ba200">
23 </consumer>
33 </consumer>
42 </consumer>
52 </consumer>
62 </consumer>
72 </consumer>
90 </consumer>
[all …]
/freebsd-12.1/sys/dev/fdt/
H A Dfdt_clock.c52 enable_disable_all(device_t consumer, boolean_t enable) in enable_disable_all() argument
60 cnode = ofw_bus_get_node(consumer); in enable_disable_all()
64 device_printf(consumer, "Warning: No clocks specified in fdt " in enable_disable_all()
74 device_printf(consumer, "Warning: can not find " in enable_disable_all()
86 device_printf(consumer, "Warning: failed to " in enable_disable_all()
97 fdt_clock_get_info(device_t consumer, int n, struct fdt_clock_info *info) in fdt_clock_get_info() argument
104 cnode = ofw_bus_get_node(consumer); in fdt_clock_get_info()
135 fdt_clock_enable_all(device_t consumer) in fdt_clock_enable_all() argument
138 return (enable_disable_all(consumer, true)); in fdt_clock_enable_all()
142 fdt_clock_disable_all(device_t consumer) in fdt_clock_disable_all() argument
[all …]
/freebsd-12.1/sys/mips/mediatek/
H A Dfdt_reset.c53 assert_deassert_all(device_t consumer, boolean_t assert) in assert_deassert_all() argument
61 rnode = ofw_bus_get_node(consumer); in assert_deassert_all()
65 device_printf(consumer, "Warning: No resets specified in fdt " in assert_deassert_all()
75 device_printf(consumer, "Warning: can not find " in assert_deassert_all()
87 device_printf(consumer, "Warning: failed to " in assert_deassert_all()
98 fdt_reset_assert_all(device_t consumer) in fdt_reset_assert_all() argument
101 return (assert_deassert_all(consumer, true)); in fdt_reset_assert_all()
105 fdt_reset_deassert_all(device_t consumer) in fdt_reset_deassert_all() argument
108 return (assert_deassert_all(consumer, false)); in fdt_reset_deassert_all()
/freebsd-12.1/sys/dev/acpica/
H A Dacpi_powerres.c116 *acpi_pwr_find_consumer(ACPI_HANDLE consumer);
248 pc->ac_consumer = consumer; in acpi_pwr_register_consumer()
254 acpi_name(consumer))); in acpi_pwr_register_consumer()
287 acpi_name(consumer))); in acpi_pwr_deregister_consumer()
309 if (consumer == NULL) in acpi_pwr_switch_consumer()
393 acpi_name(consumer), state)); in acpi_pwr_switch_consumer()
456 acpi_name(consumer), state)); in acpi_pwr_switch_consumer()
500 if (consumer == NULL) in acpi_pwr_wake_enable()
512 if (acpi_parse_prw(consumer, &prw) != 0) in acpi_pwr_wake_enable()
726 acpi_pwr_find_consumer(ACPI_HANDLE consumer) in acpi_pwr_find_consumer() argument
[all …]
/freebsd-12.1/contrib/llvm/tools/llvm-diff/
H A DDifferenceEngine.h38 Engine.consumer.enterContext(L, R); in Context()
42 Engine.consumer.exitContext(); in ~Context()
60 DifferenceEngine(Consumer &consumer) in DifferenceEngine() argument
61 : consumer(consumer), globalValueOracle(nullptr) {} in DifferenceEngine()
66 consumer.log(text); in log()
69 return LogBuilder(consumer, text); in logf()
71 Consumer& getConsumer() const { return consumer; } in getConsumer()
85 Consumer &consumer;
/freebsd-12.1/sys/contrib/ck/include/
H A Dck_ring.h95 unsigned int consumer, producer, delta; in _ck_ring_enqueue_sp() local
101 *size = (producer - consumer) & mask; in _ck_ring_enqueue_sp()
140 unsigned int consumer, producer; in _ck_ring_dequeue_sc() local
142 consumer = ring->c_head; in _ck_ring_dequeue_sc()
247 *size = (producer - consumer) & mask; in _ck_ring_enqueue_mp()
274 unsigned int consumer, producer; in _ck_ring_trydequeue_mc() local
289 return ck_pr_cas_uint(&ring->c_head, consumer, consumer + 1); in _ck_ring_trydequeue_mc()
299 unsigned int consumer, producer; in _ck_ring_dequeue_mc() local
324 consumer, in _ck_ring_dequeue_mc()
325 consumer + 1, in _ck_ring_dequeue_mc()
[all …]
/freebsd-12.1/usr.bin/fstat/
H A Dfuser.c86 struct consumer { struct
92 STAILQ_ENTRY(consumer) next; argument
98 STAILQ_HEAD(, consumer) consumers;
112 static void printflags(struct consumer *consumer);
129 printflags(struct consumer *cons) in printflags()
165 struct consumer *consumer; in do_fuser() local
265 if (consumer->flags != 0) { in do_fuser()
266 fprintf(stdout, "%6d", consumer->pid); in do_fuser()
268 printflags(consumer); in do_fuser()
273 kill(consumer->pid, sig); in do_fuser()
[all …]

123456