Home
last modified time | relevance | path

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

123456

/NextBSD/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/java_api/src/
HDTestStateMachine.java58 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 …]
HDTestAbort.java42 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 …]
HDTestEnable.java48 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 …]
HDTestFunctionLookup.java48 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 …]
HDTestGetAggregate.java47 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 …]
HDTestClose.java38 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 …]
HDTestDrop.java62 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 …]
HDTestStopLock.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()
HDTestProbeData.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()
/NextBSD/cddl/contrib/opensolaris/cmd/dtrace/test/tst/common/java_api/
HDtst.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
18 java.lang.IllegalStateException: consumer already open
[all …]
/NextBSD/tools/regression/geom/ConfCmp/
HDa1c.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all …]
HDa1.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all …]
HDa1a.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all …]
HDa1b.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all …]
HDa1d.conf11 <consumer>
16 </consumer>
23 <consumer>
28 </consumer>
35 <consumer>
40 </consumer>
47 <consumer>
52 </consumer>
59 <consumer>
64 </consumer>
[all …]
HDa2d.conf9 <consumer id="0x80ba240">
13 </consumer>
19 <consumer id="0x80ba200">
23 </consumer>
29 <consumer id="0x80ba1c0">
33 </consumer>
39 <consumer id="0x80ba180">
43 </consumer>
49 <consumer id="0x80ba140">
53 </consumer>
[all …]
HDa2b.conf9 <consumer id="0x80ba240">
13 </consumer>
19 <consumer id="0x80ba200">
23 </consumer>
29 <consumer id="0x80ba1c0">
33 </consumer>
39 <consumer id="0x80ba180">
43 </consumer>
49 <consumer id="0x80ba140">
53 </consumer>
[all …]
HDa2a.conf9 <consumer id="0x90ba240">
13 </consumer>
19 <consumer id="0x90ba200">
23 </consumer>
29 <consumer id="0x90ba1c0">
33 </consumer>
39 <consumer id="0x90ba180">
43 </consumer>
49 <consumer id="0x90ba140">
53 </consumer>
[all …]
HDa2c.conf9 <consumer id="0x80ba240">
13 </consumer>
19 <consumer id="0x80ba200">
23 </consumer>
29 <consumer id="0x80ba1c0">
33 </consumer>
39 <consumer id="0x80ba180">
42 </consumer>
48 <consumer id="0x80ba140">
52 </consumer>
[all …]
HDa2.conf9 <consumer id="0x80ba240">
13 </consumer>
19 <consumer id="0x80ba200">
23 </consumer>
29 <consumer id="0x80ba1c0">
33 </consumer>
39 <consumer id="0x80ba180">
43 </consumer>
49 <consumer id="0x80ba140">
53 </consumer>
[all …]
/NextBSD/sys/dev/fdt/
HDfdt_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 …]
/NextBSD/sys/dev/acpica/
HDacpi_powerres.c100 static ACPI_STATUS acpi_pwr_register_consumer(ACPI_HANDLE consumer);
102 static ACPI_STATUS acpi_pwr_deregister_consumer(ACPI_HANDLE consumer);
116 *acpi_pwr_find_consumer(ACPI_HANDLE consumer);
232 acpi_pwr_register_consumer(ACPI_HANDLE consumer) in acpi_pwr_register_consumer() argument
240 if (acpi_pwr_find_consumer(consumer) != NULL) in acpi_pwr_register_consumer()
248 pc->ac_consumer = consumer; in acpi_pwr_register_consumer()
254 acpi_name(consumer))); in acpi_pwr_register_consumer()
267 acpi_pwr_deregister_consumer(ACPI_HANDLE consumer) in acpi_pwr_deregister_consumer() argument
275 if ((pc = acpi_pwr_find_consumer(consumer)) == NULL) in acpi_pwr_deregister_consumer()
287 acpi_name(consumer))); in acpi_pwr_deregister_consumer()
[all …]
/NextBSD/contrib/llvm/tools/llvm-diff/
HDDifferenceEngine.h39 Engine.consumer.enterContext(L, R); in Context()
43 Engine.consumer.exitContext(); in ~Context()
61 DifferenceEngine(Consumer &consumer) in DifferenceEngine() argument
62 : consumer(consumer), globalValueOracle(nullptr) {} in DifferenceEngine()
67 consumer.log(text); in log()
70 return LogBuilder(consumer, text); in logf()
72 Consumer& getConsumer() const { return consumer; } in getConsumer()
86 Consumer &consumer;
/NextBSD/usr.bin/fstat/
HDfuser.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 STAILQ_FOREACH(consumer, &reqfiles[i].consumers, next) { in do_fuser()
263 if (consumer->flags != 0) { in do_fuser()
264 fprintf(stdout, "%6d", consumer->pid); in do_fuser()
266 printflags(consumer); in do_fuser()
[all …]
/NextBSD/lib/libgeom/
HDgeom_xml2tree.c54 struct gconsumer *consumer; member
122 if (!strcmp(name, "consumer") && mt->consumer == NULL) { in StartElement()
123 mt->consumer = calloc(1, sizeof *mt->consumer); in StartElement()
124 if (mt->consumer == NULL) { in StartElement()
131 mt->consumer->lg_id = id; in StartElement()
132 LIST_INSERT_HEAD(&mt->geom->lg_consumer, mt->consumer, in StartElement()
134 LIST_INIT(&mt->consumer->lg_config); in StartElement()
137 if (!strcmp(name, "geom") && mt->consumer != NULL) { in StartElement()
138 mt->consumer->lg_geom = ref; in StartElement()
141 if (!strcmp(name, "provider") && mt->consumer != NULL) { in StartElement()
[all …]

123456