Home
last modified time | relevance | path

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

12

/illumos-gate/usr/src/cmd/dtrace/test/tst/common/java_api/src/
H A DTestAbort.java44 consumer.open(); in main()
48 consumer.go(); in main()
55 consumer.close(); in main()
71 consumer.abort(); in main()
72 consumer.open(); in main()
76 consumer.go(); in main()
97 consumer.open(); in main()
104 consumer.go(); in main()
109 consumer.abort(); in main()
124 consumer.open(); in main()
[all …]
H A DTestStateMachine.java67 printState(consumer); in beforeOpen()
82 consumer.enable(); in beforeOpen()
175 printState(consumer); in beforeCompile()
179 consumer.open(); in beforeCompile()
204 printState(consumer); in beforeEnable()
208 consumer.go(); in beforeEnable()
257 consumer.stop(); in beforeGo()
275 consumer.go(); in afterGo()
372 consumer.stop(); in afterStop()
528 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.java39 consumer.open(); in main()
42 consumer.enable(); in main()
43 consumer.go(); in main()
50 consumer.close(); in main()
56 consumer = new LocalConsumer(); in main()
59 consumer.open(); in main()
62 consumer.enable(); in main()
63 consumer.go(); in main()
73 synchronized (consumer) { in main()
74 consumer.close(); in main()
[all …]
H A DTestDrop.java62 while (consumer.isRunning() && !done.get()) { in sampleAggregate()
73 startAggregateThread(final Consumer consumer) in startAggregateThread() argument
81 sampleAggregate(consumer); in startAggregateThread()
94 consumer.close(); // blocks if lock held in startAggregateThread()
123 final Consumer consumer = new LocalConsumer() { in main() local
137 consumer.addConsumerListener(new ConsumerAdapter() { in main()
139 startAggregateThread(consumer); in main()
153 consumer.open(); in main()
156 consumer.compile(PROGRAM); in main()
157 consumer.enable(); in main()
[all …]
H A DTestStopLock.java37 final Consumer consumer = new LocalConsumer(); in main() local
38 consumer.addConsumerListener(new ConsumerAdapter() { in main()
41 consumer.isRunning(); in main()
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.stop(); in main()
58 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()
H A DTestMaxConsumers.java80 Consumer consumer = new LocalConsumer(); in main() local
81 consumer.open(); in main()
88 consumer.close(); in main()
H A DTestBean.java543 Consumer consumer = new LocalConsumer(); in getProgram() local
546 consumer.open(); in getProgram()
547 p = consumer.compile(PROGRAM); in getProgram()
548 consumer.close(); in getProgram()
560 Consumer consumer = new LocalConsumer(); in getProgram$File() local
567 consumer.open(); in getProgram$File()
568 p = consumer.compile(file); in getProgram$File()
569 consumer.close(); in getProgram$File()
/illumos-gate/usr/src/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 …]
H A Dtst.Enable.ksh.out6 java.lang.IllegalArgumentException: program not compiled by this consumer
/illumos-gate/usr/src/lib/libdtrace_jni/java/docs/examples/
H A DTestTarget.java44 final Consumer consumer = new LocalConsumer(); in main() local
45 consumer.addConsumerListener(new ConsumerAdapter() { in main()
51 Aggregate a = consumer.getAggregate(); in main()
62 consumer.close(); in main()
70 consumer.open(); in main()
72 consumer.createProcess(command); in main()
73 consumer.compile(file); in main()
74 consumer.enable(); in main()
75 consumer.go(); in main()
H A DTestAPI2.java46 Consumer consumer = new LocalConsumer(); in main() local
47 consumer.addConsumerListener(new ConsumerAdapter() { in main()
62 consumer.open(); in main()
63 consumer.compile(file, macroArgs); in main()
64 consumer.enable(); in main()
65 consumer.go(); in main()
70 a = consumer.getAggregate(); in main()
74 } while (consumer.isRunning()); in main()
H A DTestAPI.java45 Consumer consumer = new LocalConsumer(); in main() local
46 consumer.addConsumerListener(new ConsumerAdapter() { in main()
53 consumer.open(); in main()
54 consumer.compile(file, macroArgs); in main()
55 consumer.enable(); in main()
56 consumer.go(); in main()
/illumos-gate/usr/src/uts/i86pc/sys/
H A Dacpidev_rsc.h144 boolean_t consumer);
185 boolean_t consumer, acpidev_resource_handle_t *rhdlp);
194 boolean_t consumer);
/illumos-gate/usr/src/lib/libslp/clib/
H A Dslp_ua_common.c44 static void *consumer(void *);
99 if ((terr = thr_create(NULL, 0, consumer, in slp_ua_common()
114 return ((SLPError)consumer(args)); in slp_ua_common()
121 consumer(void *ap) in consumer() function
/illumos-gate/usr/src/lib/libdtrace_jni/common/
H A Ddtrace_jni.c174 dtj_consumer_t *consumer; in dtj_get_java_consumer() local
184 consumer = NULL; in dtj_get_java_consumer()
187 consumer = NULL; in dtj_get_java_consumer()
190 if (consumer == NULL) { in dtj_get_java_consumer()
317 dtj_consumer_t *consumer; in dtj_remove_consumer() local
323 return (consumer); in dtj_remove_consumer()
333 dtj_consumer_t *consumer; in dtj_remove_consumer_at() local
338 if (consumer != NULL) { in dtj_remove_consumer_at()
349 consumer = NULL; in dtj_remove_consumer_at()
352 consumer = NULL; in dtj_remove_consumer_at()
[all …]
/illumos-gate/usr/src/uts/i86pc/io/acpi/acpidev/
H A Dacpidev_resource.c68 acpidev_resource_handle_alloc(boolean_t consumer) in acpidev_resource_handle_alloc() argument
73 rhdl->acpidev_consumer = consumer; in acpidev_resource_handle_alloc()
968 boolean_t consumer, acpidev_resource_handle_t *rhdlp) in acpidev_resource_walk() argument
1002 rhdl = acpidev_resource_handle_alloc(consumer); in acpidev_resource_walk()
1003 if (consumer) { in acpidev_resource_walk()
1026 acpidev_resource_process(acpidev_walk_info_t *infop, boolean_t consumer) in acpidev_resource_process() argument
1042 consumer, &rhdl); in acpidev_resource_process()
1050 if (consumer) { in acpidev_resource_process()
/illumos-gate/usr/src/lib/libdhcputil/common/
H A Ddhcp_inittab.c111 inittab_load(uchar_t categories, char consumer, size_t *n_entries) in inittab_load() argument
113 return (inittab_lookup(categories, consumer, NULL, -1, n_entries)); in inittab_load()
127 inittab_getbyname(uchar_t categories, char consumer, const char *name) in inittab_getbyname() argument
129 return (inittab_lookup(categories, consumer, name, -1, NULL)); in inittab_getbyname()
143 inittab_getbycode(uchar_t categories, char consumer, uint16_t code) in inittab_getbycode() argument
145 return (inittab_lookup(categories, consumer, NULL, code, NULL)); in inittab_getbycode()
163 inittab_lookup(uchar_t categories, char consumer, const char *name, in inittab_lookup() argument
254 if (strchr(fields[ITAB_CONS], consumer) == NULL) in inittab_lookup()
/illumos-gate/usr/src/lib/libdhcputil/
H A DREADME.inittab131 programs, even if they are listed as a `consumer' of the given
168 inittab_load(uchar_t categories, char consumer, size_t *n_entries);
171 inittab_getbyname(uchar_t categories, char consumer, const char *name);
174 inittab_getbycode(uchar_t categories, char consumer, unsigned int code);
185 and the `consumer' field consists of one of the following:
194 to the provided consumer. Note that there is no specified order to
200 provided consumer. The dhcp_symbol_t is dynamically allocated.
/illumos-gate/usr/src/uts/common/io/ntxn/
H A Dunm_nic_main.c1332 uint32_t consumer, start; in unm_process_rcv_ring() local
1336 start = consumer = recv_ctx->statusRxConsumer; in unm_process_rcv_ring()
1343 desc = &desc_head[consumer]; in unm_process_rcv_ring()
1350 consumer = (consumer + 1) % adapter->MaxRxDescCount; in unm_process_rcv_ring()
1367 recv_ctx->statusRxConsumer = consumer; in unm_process_rcv_ring()
1371 recv_ctx->host_sds_consumer, &consumer, 4); in unm_process_rcv_ring()
1383 u32 consumer; in unm_process_cmd_ring() local
1394 consumer = *(adapter->cmdConsumer); in unm_process_cmd_ring()
1396 while (last_consumer != consumer) { in unm_process_cmd_ring()
1453 consumer = *(adapter->cmdConsumer); in unm_process_cmd_ring()
[all …]
/illumos-gate/usr/src/uts/common/io/mega_sas/
H A Dmegaraid_sas.c1692 uint32_t consumer; in megasas_isr() local
1715 consumer = *instance->consumer; in megasas_isr()
1718 producer, consumer)); in megasas_isr()
1722 while (consumer != producer) { in megasas_isr()
1723 context = instance->reply_queue[consumer]; in megasas_isr()
1727 consumer++; in megasas_isr()
1728 if (consumer == (instance->max_fw_cmds + 1)) { in megasas_isr()
1729 consumer = 0; in megasas_isr()
1735 *instance->consumer = consumer; in megasas_isr()
1955 instance->consumer = (uint32_t *)((unsigned long) in alloc_additional_dma_buffer()

12