Home
last modified time | relevance | path

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

12345678910

/freebsd-13.1/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/java_api/src/
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 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 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()
H A DTestProbeData.java84 final Consumer consumer = new LocalConsumer(); in main() local
86 consumer.addConsumerListener(new ConsumerAdapter() { in main()
96 consumer.close(); in main()
101 consumer.open(); in main()
102 consumer.createProcess(command); in main()
103 consumer.compile(PROGRAM); in main()
104 consumer.enable(); in main()
105 consumer.go(); in main()
/freebsd-13.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-13.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 …]
/freebsd-13.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-13.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-13.1/contrib/llvm-project/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;
H A DDiffLog.h29 Consumer *consumer; variable
40 LogBuilder(Consumer &c, StringRef Format) : consumer(&c), Format(Format) {} in LogBuilder()
42 : consumer(L.consumer), Format(L.Format), in LogBuilder()
44 L.consumer = nullptr; in LogBuilder()
64 Consumer &consumer; variable
67 DiffLogBuilder(Consumer &c) : consumer(c) {} in DiffLogBuilder()
/freebsd-13.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()
725 acpi_pwr_find_consumer(ACPI_HANDLE consumer) in acpi_pwr_find_consumer() argument
[all …]
/freebsd-13.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-13.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 …]
/freebsd-13.1/sys/dev/gpio/
H A Dofw_gpiobus.c70 KASSERT(consumer != NULL && cnode > 0, in gpio_pin_get_by_ofw_propidx()
132 KASSERT(consumer != NULL && node > 0, in gpio_pin_get_by_ofw_name()
190 return (ofw_gpiobus_parse_gpios_impl(consumer, in ofw_gpiobus_parse_gpios()
191 ofw_bus_get_node(consumer), pname, NULL, pins)); in ofw_gpiobus_parse_gpios()
292 device_printf(consumer, in ofw_gpiobus_parse_gpios_impl()
323 device_printf(consumer, in ofw_gpiobus_parse_gpios_impl()
329 device_printf(consumer, in ofw_gpiobus_parse_gpios_impl()
363 device_printf(consumer, in ofw_gpiobus_parse_gpios_impl()
370 device_printf(consumer, in ofw_gpiobus_parse_gpios_impl()
381 device_printf(consumer, in ofw_gpiobus_parse_gpios_impl()
[all …]
/freebsd-13.1/sys/dev/pwm/
H A Dofw_pwm.c43 pwm_get_by_ofw_propidx(device_t consumer, phandle_t node, in pwm_get_by_ofw_propidx() argument
74 pwm_get_by_ofw_idx(device_t consumer, phandle_t node, int idx, in pwm_get_by_ofw_idx() argument
78 return (pwm_get_by_ofw_propidx(consumer, node, "pwms", idx, out_channel)); in pwm_get_by_ofw_idx()
82 pwm_get_by_ofw_property(device_t consumer, phandle_t node, in pwm_get_by_ofw_property() argument
86 return (pwm_get_by_ofw_propidx(consumer, node, prop_name, 0, out_channel)); in pwm_get_by_ofw_property()
90 pwm_get_by_ofw_name(device_t consumer, phandle_t node, const char *name, in pwm_get_by_ofw_name() argument
99 return (pwm_get_by_ofw_idx(consumer, node, idx, out_channel)); in pwm_get_by_ofw_name()
/freebsd-13.1/lib/libgeom/
H A Dgeom_xml2tree.c56 struct gconsumer *consumer; member
125 mt->consumer = calloc(1, sizeof *mt->consumer); in StartElement()
126 if (mt->consumer == NULL) { in StartElement()
133 mt->consumer->lg_id = id; in StartElement()
136 LIST_INIT(&mt->consumer->lg_config); in StartElement()
140 mt->consumer->lg_geom = ref; in StartElement()
144 mt->consumer->lg_provider = ref; in StartElement()
172 if (mt->consumer != NULL) { in StartElement()
173 mt->config = &mt->consumer->lg_config; in StartElement()
236 mt->consumer->lg_mode = p; in EndElement()
[all …]

12345678910