| /freebsd/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/java_api/src/ |
| H A D | TestStateMachine.java | 58 printState(Consumer consumer) in printState() argument
60 System.out.println("open: " + consumer.isOpen()); in printState()
61 System.out.println("enabled: " + consumer.isEnabled()); in printState()
62 System.out.println("closed: " + consumer.isClosed()); in printState()
66 beforeOpen(Consumer consumer) in beforeOpen() argument
69 printState(consumer); in beforeOpen()
73 consumer.compile("syscall:::entry"); in beforeOpen()
84 consumer.enable(); in beforeOpen()
95 consumer.getOption(Option.bufsize); in beforeOpen()
104 consumer.setOption(Option.bufsize, Option.mb(1)); in beforeOpen()
[all …]
|
| H A D | TestAbort.java | 42 Consumer consumer = new LocalConsumer(); in main() local
46 consumer.open(); in main()
47 consumer.compile("syscall:::entry { @[execname] = count(); } " + in main()
49 consumer.enable(); in main()
50 consumer.go(); in main()
57 consumer.close(); in main()
63 consumer = new LocalConsumer(); in main()
68 consumer.addConsumerListener(new ConsumerAdapter() { in main()
73 consumer.abort(); in main()
74 consumer.open(); in main()
[all …]
|
| H A D | TestEnable.java | 48 Consumer consumer = new LocalConsumer(); in main() local
51 consumer.open(); in main()
52 Program p0 = consumer.compile("dtrace:::BEGIN"); in main()
53 Program p1 = consumer.compile("syscall:::entry"); in main()
54 Program p2 = consumer.compile("dtrace:::END"); in main()
55 consumer.enable(p0); in main()
56 consumer.enable(p1); in main()
58 consumer.go(); in main()
69 consumer.enable(); in main()
80 consumer.enable(p0); in main()
[all …]
|
| H A D | TestFunctionLookup.java | 48 Consumer consumer = new LocalConsumer(); in main() local
50 consumer.open(); in main()
51 consumer.compile(kernelLookupProgram); in main()
52 consumer.enable(); in main()
53 consumer.go(); in main()
60 a = consumer.getAggregate(); in main()
66 f = consumer.lookupKernelFunction(addr); in main()
69 f = consumer.lookupKernelFunction(addr); in main()
78 consumer.close(); in main()
84 consumer = new LocalConsumer(); in main()
[all …]
|
| H A D | TestGetAggregate.java | 47 testIncluded(Consumer consumer, String ... aggregationNames) in testIncluded() argument
63 aggregate = consumer.getAggregate(included, null); in testIncluded()
81 if (!consumer.isRunning()) { in testIncluded()
87 testCleared(Consumer consumer, String ... aggregationNames) in testCleared() argument
104 aggregate = consumer.getAggregate(null, cleared); in testCleared()
110 aggregate = consumer.getAggregate(null, cleared); in testCleared()
119 } while (consumer.isRunning() && n++ < INTERVALS); in testCleared()
146 if (!consumer.isRunning()) { in testCleared()
157 final Consumer consumer = new LocalConsumer(); in startIncludedTest() local
158 consumer.addConsumerListener(new ConsumerAdapter() { in startIncludedTest()
[all …]
|
| H A D | TestClose.java | 38 Consumer consumer = new LocalConsumer(); in main() local
41 consumer.open(); in main()
42 consumer.compile("syscall:::entry { @[execname] = count(); } " + 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()
62 consumer.compile("syscall:::entry { @[execname] = count(); } " + in main()
64 consumer.enable(); in main()
[all …]
|
| H A D | TestDrop.java | 62 sampleAggregate(Consumer consumer) throws DTraceException in sampleAggregate() argument
64 while (consumer.isRunning() && !done.get()) { in sampleAggregate()
70 consumer.getAggregate(Collections. <String> emptySet()); 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()
[all …]
|
| H A D | TestStopLock.java | 39 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 D | TestProbeData.java | 84 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 D | TestMultiAggPrinta.java | 111 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/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/java_api/ |
| H A D | tst.StateMachine.ksh.out | 5 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
18 java.lang.IllegalStateException: consumer already open
[all …]
|
| /freebsd/tools/regression/geom/ConfCmp/ |
| H A D | a1.conf | 11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all …]
|
| H A D | a1a.conf | 11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all …]
|
| H A D | a1d.conf | 11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all …]
|
| H A D | a1b.conf | 11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all …]
|
| H A D | a1c.conf | 11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all …]
|
| /freebsd/sys/dev/fdt/ |
| H A D | fdt_clock.c | 49 enable_disable_all(device_t consumer, boolean_t enable) in enable_disable_all() argument
57 cnode = ofw_bus_get_node(consumer); in enable_disable_all()
61 device_printf(consumer, "Warning: No clocks specified in fdt " in enable_disable_all()
71 device_printf(consumer, "Warning: can not find " in enable_disable_all()
83 device_printf(consumer, "Warning: failed to " in enable_disable_all()
94 fdt_clock_get_info(device_t consumer, int n, struct fdt_clock_info *info) in fdt_clock_get_info() argument
101 cnode = ofw_bus_get_node(consumer); in fdt_clock_get_info()
132 fdt_clock_enable_all(device_t consumer) in fdt_clock_enable_all() argument
135 return (enable_disable_all(consumer, true)); in fdt_clock_enable_all()
139 fdt_clock_disable_all(device_t consumer) in fdt_clock_disable_all() argument
[all …]
|
| /freebsd/sys/dev/acpica/ |
| H A D | acpi_powerres.c | 98 static ACPI_STATUS acpi_pwr_register_consumer(ACPI_HANDLE consumer);
100 static ACPI_STATUS acpi_pwr_deregister_consumer(ACPI_HANDLE consumer);
114 *acpi_pwr_find_consumer(ACPI_HANDLE consumer);
230 acpi_pwr_register_consumer(ACPI_HANDLE consumer) in acpi_pwr_register_consumer() argument
238 if (acpi_pwr_find_consumer(consumer) != NULL) in acpi_pwr_register_consumer()
246 pc->ac_consumer = consumer; in acpi_pwr_register_consumer()
252 acpi_name(consumer))); in acpi_pwr_register_consumer()
265 acpi_pwr_deregister_consumer(ACPI_HANDLE consumer) in acpi_pwr_deregister_consumer() argument
273 if ((pc = acpi_pwr_find_consumer(consumer)) == NULL) in acpi_pwr_deregister_consumer()
285 acpi_name(consumer))); in acpi_pwr_deregister_consumer()
[all …]
|
| /freebsd/contrib/llvm-project/llvm/tools/llvm-diff/lib/ |
| H A D | DifferenceEngine.h | 38 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 D | DiffLog.h | 29 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/usr.bin/fstat/ |
| H A D | fuser.c | 84 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
261 STAILQ_FOREACH(consumer, &reqfiles[i].consumers, next) { in do_fuser()
262 if (consumer->flags != 0) { in do_fuser()
263 fprintf(stdout, "%6d", consumer->pid); in do_fuser()
265 printflags(consumer); in do_fuser()
[all …]
|
| /freebsd/sys/contrib/ck/include/ |
| H A D | ck_ring.h | 146 unsigned int consumer, producer, delta; in _ck_ring_enqueue_reserve_sp() local
148 consumer = ck_pr_load_uint(&ring->c_head); in _ck_ring_enqueue_reserve_sp()
152 *size = (producer - consumer) & mask; in _ck_ring_enqueue_reserve_sp()
154 if (CK_CC_UNLIKELY((delta & mask) == (consumer & mask))) in _ck_ring_enqueue_reserve_sp()
181 unsigned int consumer, producer, delta; in _ck_ring_enqueue_sp() local
183 consumer = ck_pr_load_uint(&ring->c_head); in _ck_ring_enqueue_sp()
187 *size = (producer - consumer) & mask; in _ck_ring_enqueue_sp()
189 if (CK_CC_UNLIKELY((delta & mask) == (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()
[all …]
|
| /freebsd/sys/dev/gpio/ |
| H A D | ofw_gpiobus.c | 58 gpio_pin_get_by_ofw_propidx(device_t consumer, phandle_t cnode, in gpio_pin_get_by_ofw_propidx() argument
67 KASSERT(consumer != NULL && cnode > 0, in gpio_pin_get_by_ofw_propidx()
108 gpio_pin_get_by_ofw_idx(device_t consumer, phandle_t node, in gpio_pin_get_by_ofw_idx() argument
112 return (gpio_pin_get_by_ofw_propidx(consumer, node, "gpios", idx, pin)); in gpio_pin_get_by_ofw_idx()
116 gpio_pin_get_by_ofw_property(device_t consumer, phandle_t node, in gpio_pin_get_by_ofw_property() argument
120 return (gpio_pin_get_by_ofw_propidx(consumer, node, name, 0, pin)); in gpio_pin_get_by_ofw_property()
124 gpio_pin_get_by_ofw_name(device_t consumer, phandle_t node, in gpio_pin_get_by_ofw_name() argument
129 KASSERT(consumer != NULL && node > 0, in gpio_pin_get_by_ofw_name()
135 return (gpio_pin_get_by_ofw_idx(consumer, node, idx, pin)); in gpio_pin_get_by_ofw_name()
183 ofw_gpiobus_parse_gpios(device_t consumer, char *pname, in ofw_gpiobus_parse_gpios() argument
[all …]
|
| /freebsd/sys/dev/pwm/ |
| H A D | ofw_pwm.c | 40 pwm_get_by_ofw_propidx(device_t consumer, phandle_t node, in pwm_get_by_ofw_propidx() argument
71 pwm_get_by_ofw_idx(device_t consumer, phandle_t node, int idx, in pwm_get_by_ofw_idx() argument
75 return (pwm_get_by_ofw_propidx(consumer, node, "pwms", idx, out_channel)); in pwm_get_by_ofw_idx()
79 pwm_get_by_ofw_property(device_t consumer, phandle_t node, in pwm_get_by_ofw_property() argument
83 return (pwm_get_by_ofw_propidx(consumer, node, prop_name, 0, out_channel)); in pwm_get_by_ofw_property()
87 pwm_get_by_ofw_name(device_t consumer, phandle_t node, const char *name, in pwm_get_by_ofw_name() argument
96 return (pwm_get_by_ofw_idx(consumer, node, idx, out_channel)); in pwm_get_by_ofw_name()
|
| /freebsd/lib/libgeom/ |
| H A D | geom_xml2tree.c | 55 struct gconsumer *consumer; member
123 if (!strcmp(name, "consumer") && mt->consumer == NULL) { in StartElement()
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()
133 LIST_INSERT_HEAD(&mt->geom->lg_consumer, mt->consumer, in StartElement()
135 LIST_INIT(&mt->consumer->lg_config); in StartElement()
138 if (!strcmp(name, "geom") && mt->consumer != NULL) { in StartElement()
139 mt->consumer->lg_geom = ref; in StartElement()
142 if (!strcmp(name, "provider") && mt->consumer != NULL) { in StartElement()
[all …]
|