Home
last modified time | relevance | path

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

12345678910>>...13

/freebsd-14.2/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()
H A DTestMultiAggPrinta.java111 final Consumer consumer = new LocalConsumer(); in main() local
112 consumer.addConsumerListener(new ConsumerAdapter() { in main()
125 consumer.close(); in main()
132 consumer.open(); in main()
133 consumer.compile(file); in main()
134 consumer.enable(); in main()
135 consumer.go(); in main()
/freebsd-14.2/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-14.2/tools/regression/geom/ConfCmp/
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 Da1a.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 Da1.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
71 <consumer>
[all …]
/freebsd-14.2/sys/dev/fdt/
H A Dfdt_clock.c50 enable_disable_all(device_t consumer, boolean_t enable) in enable_disable_all() argument
58 cnode = ofw_bus_get_node(consumer); in enable_disable_all()
62 device_printf(consumer, "Warning: No clocks specified in fdt " in enable_disable_all()
72 device_printf(consumer, "Warning: can not find " in enable_disable_all()
84 device_printf(consumer, "Warning: failed to " in enable_disable_all()
95 fdt_clock_get_info(device_t consumer, int n, struct fdt_clock_info *info) in fdt_clock_get_info() argument
102 cnode = ofw_bus_get_node(consumer); in fdt_clock_get_info()
133 fdt_clock_enable_all(device_t consumer) in fdt_clock_enable_all() argument
136 return (enable_disable_all(consumer, true)); in fdt_clock_enable_all()
140 fdt_clock_disable_all(device_t consumer) in fdt_clock_disable_all() argument
[all …]
/freebsd-14.2/contrib/llvm-project/llvm/tools/llvm-diff/lib/
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-14.2/sys/dev/acpica/
H A Dacpi_powerres.c114 *acpi_pwr_find_consumer(ACPI_HANDLE consumer);
246 pc->ac_consumer = consumer; in acpi_pwr_register_consumer()
252 acpi_name(consumer))); in acpi_pwr_register_consumer()
285 acpi_name(consumer))); in acpi_pwr_deregister_consumer()
307 if (consumer == NULL) in acpi_pwr_switch_consumer()
391 acpi_name(consumer), state)); in acpi_pwr_switch_consumer()
454 acpi_name(consumer), state)); in acpi_pwr_switch_consumer()
498 if (consumer == NULL) in acpi_pwr_wake_enable()
510 if (acpi_parse_prw(consumer, &prw) != 0) in acpi_pwr_wake_enable()
723 acpi_pwr_find_consumer(ACPI_HANDLE consumer) in acpi_pwr_find_consumer() argument
[all …]
/freebsd-14.2/usr.bin/fstat/
H A Dfuser.c84 struct consumer { struct
90 STAILQ_ENTRY(consumer) next; argument
96 STAILQ_HEAD(, consumer) consumers;
110 static void printflags(struct consumer *consumer);
127 printflags(struct consumer *cons) in printflags()
163 struct consumer *consumer; in do_fuser() local
262 if (consumer->flags != 0) { in do_fuser()
263 fprintf(stdout, "%6d", consumer->pid); in do_fuser()
265 printflags(consumer); in do_fuser()
270 kill(consumer->pid, sig); in do_fuser()
[all …]
/freebsd-14.2/sys/contrib/ck/include/
H A Dck_ring.h146 unsigned int consumer, producer, delta; in _ck_ring_enqueue_reserve_sp() local
152 *size = (producer - consumer) & mask; in _ck_ring_enqueue_reserve_sp()
187 *size = (producer - consumer) & mask; in _ck_ring_enqueue_sp()
226 unsigned int consumer, producer; in _ck_ring_dequeue_sc() local
228 consumer = ring->c_head; in _ck_ring_dequeue_sc()
419 unsigned int consumer, producer; in _ck_ring_trydequeue_mc() local
434 return ck_pr_cas_uint(&ring->c_head, consumer, consumer + 1); in _ck_ring_trydequeue_mc()
444 unsigned int consumer, producer; in _ck_ring_dequeue_mc() local
469 consumer, in _ck_ring_dequeue_mc()
470 consumer + 1, in _ck_ring_dequeue_mc()
[all …]
/freebsd-14.2/sys/dev/gpio/
H A Dofw_gpiobus.c68 KASSERT(consumer != NULL && cnode > 0, in gpio_pin_get_by_ofw_propidx()
130 KASSERT(consumer != NULL && node > 0, in gpio_pin_get_by_ofw_name()
188 return (ofw_gpiobus_parse_gpios_impl(consumer, in ofw_gpiobus_parse_gpios()
189 ofw_bus_get_node(consumer), pname, NULL, pins)); in ofw_gpiobus_parse_gpios()
290 device_printf(consumer, in ofw_gpiobus_parse_gpios_impl()
321 device_printf(consumer, in ofw_gpiobus_parse_gpios_impl()
327 device_printf(consumer, in ofw_gpiobus_parse_gpios_impl()
361 device_printf(consumer, in ofw_gpiobus_parse_gpios_impl()
368 device_printf(consumer, in ofw_gpiobus_parse_gpios_impl()
379 device_printf(consumer, in ofw_gpiobus_parse_gpios_impl()
[all …]
/freebsd-14.2/sys/dev/pwm/
H A Dofw_pwm.c41 pwm_get_by_ofw_propidx(device_t consumer, phandle_t node, in pwm_get_by_ofw_propidx() argument
72 pwm_get_by_ofw_idx(device_t consumer, phandle_t node, int idx, in pwm_get_by_ofw_idx() argument
76 return (pwm_get_by_ofw_propidx(consumer, node, "pwms", idx, out_channel)); in pwm_get_by_ofw_idx()
80 pwm_get_by_ofw_property(device_t consumer, phandle_t node, in pwm_get_by_ofw_property() argument
84 return (pwm_get_by_ofw_propidx(consumer, node, prop_name, 0, out_channel)); in pwm_get_by_ofw_property()
88 pwm_get_by_ofw_name(device_t consumer, phandle_t node, const char *name, in pwm_get_by_ofw_name() argument
97 return (pwm_get_by_ofw_idx(consumer, node, idx, out_channel)); in pwm_get_by_ofw_name()
/freebsd-14.2/lib/libgeom/
H A Dgeom_xml2tree.c55 struct gconsumer *consumer; member
124 mt->consumer = calloc(1, sizeof *mt->consumer); in StartElement()
125 if (mt->consumer == NULL) { in StartElement()
132 mt->consumer->lg_id = id; in StartElement()
135 LIST_INIT(&mt->consumer->lg_config); in StartElement()
139 mt->consumer->lg_geom = ref; in StartElement()
143 mt->consumer->lg_provider = ref; in StartElement()
171 if (mt->consumer != NULL) { in StartElement()
172 mt->config = &mt->consumer->lg_config; in StartElement()
235 mt->consumer->lg_mode = p; in EndElement()
[all …]

12345678910>>...13