| /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()
|
| /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/contrib/libarchive/libarchive/test/ |
| H A D | test_write_format_xar_bugs.c | 40 struct fuzz_consumer consumer; in replay_xar_writer() local
57 fuzz_consumer_init(&consumer, raw, rawsize); in replay_xar_writer()
58 opts = fuzz_consume_byte(&consumer); in replay_xar_writer()
59 num_entries = (fuzz_consume_byte(&consumer) % 5) + 1; in replay_xar_writer()
96 for (i = 0; i < num_entries && fuzz_consumer_remaining(&consumer) > 4; in replay_xar_writer()
105 path = fuzz_consume_string(&consumer, 200); in replay_xar_writer()
110 ftype = fuzz_consume_byte(&consumer) % 4; in replay_xar_writer()
111 raw_mode = fuzz_consume_u16(&consumer) & 07777; in replay_xar_writer()
121 fuzz_consume_string(&consumer, 32)); in replay_xar_writer()
123 fuzz_consume_string(&consumer, 32)); in replay_xar_writer()
[all …]
|
| H A D | test_write_format_mtree_null_deref.c | 40 struct fuzz_consumer consumer; in DEFINE_TEST() local
57 fuzz_consumer_init(&consumer, raw, rawsize); in DEFINE_TEST()
58 opts = fuzz_consume_byte(&consumer); in DEFINE_TEST()
59 num_entries = (fuzz_consume_byte(&consumer) % 8) + 1; in DEFINE_TEST()
98 for (i = 0; i < num_entries && fuzz_consumer_remaining(&consumer) > 2; in DEFINE_TEST()
106 name = fuzz_consume_string(&consumer, 128); in DEFINE_TEST()
111 ftype = fuzz_consume_byte(&consumer) % 5; in DEFINE_TEST()
125 fuzz_consume_string(&consumer, 64)); in DEFINE_TEST()
131 fuzz_consume_u16(&consumer)); in DEFINE_TEST()
139 archive_entry_set_uid(entry, fuzz_consume_byte(&consumer)); in DEFINE_TEST()
[all …]
|
| H A D | test_write_format_iso9660_bugs.c | 40 struct fuzz_consumer consumer; in replay_iso9660_writer() local
57 fuzz_consumer_init(&consumer, raw, rawsize); in replay_iso9660_writer()
58 opts1 = fuzz_consume_byte(&consumer); in replay_iso9660_writer()
59 opts2 = fuzz_consume_byte(&consumer); in replay_iso9660_writer()
60 num_entries = (fuzz_consume_byte(&consumer) % 6) + 1; in replay_iso9660_writer()
111 for (i = 0; i < num_entries && fuzz_consumer_remaining(&consumer) > 2; in replay_iso9660_writer()
119 name = fuzz_consume_string(&consumer, 128); in replay_iso9660_writer()
124 ftype = fuzz_consume_byte(&consumer) % 4; in replay_iso9660_writer()
138 fuzz_consume_string(&consumer, 64)); in replay_iso9660_writer()
149 1700000000 + fuzz_consume_u16(&consumer), 0); in replay_iso9660_writer()
[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;
|
| /freebsd/usr.bin/fstat/ |
| H A D | fuser.c | 83 struct consumer { struct
89 STAILQ_ENTRY(consumer) next; argument
95 STAILQ_HEAD(, consumer) consumers;
109 static void printflags(struct consumer *consumer);
125 printflags(struct consumer *cons) in printflags()
161 struct consumer *consumer; in do_fuser() local
250 STAILQ_FOREACH(consumer, &reqfiles[i].consumers, next) { in do_fuser()
251 if (consumer->flags != 0) { in do_fuser()
252 fprintf(stdout, "%6d", consumer->pid); in do_fuser()
254 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 | 59 gpio_pin_get_by_ofw_propidx(device_t consumer, phandle_t cnode, in gpio_pin_get_by_ofw_propidx() argument
68 KASSERT(consumer != NULL && cnode > 0, in gpio_pin_get_by_ofw_propidx()
109 gpio_pin_get_by_ofw_idx(device_t consumer, phandle_t node, in gpio_pin_get_by_ofw_idx() argument
113 return (gpio_pin_get_by_ofw_propidx(consumer, node, "gpios", idx, pin)); in gpio_pin_get_by_ofw_idx()
117 gpio_pin_get_by_ofw_property(device_t consumer, phandle_t node, in gpio_pin_get_by_ofw_property() argument
121 return (gpio_pin_get_by_ofw_propidx(consumer, node, name, 0, pin)); in gpio_pin_get_by_ofw_property()
125 gpio_pin_get_by_ofw_name(device_t consumer, phandle_t node, in gpio_pin_get_by_ofw_name() argument
130 KASSERT(consumer != NULL && node > 0, in gpio_pin_get_by_ofw_name()
136 return (gpio_pin_get_by_ofw_idx(consumer, node, idx, pin)); in gpio_pin_get_by_ofw_name()
184 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()
|