| /illumos-gate/usr/src/cmd/dtrace/test/tst/common/java_api/src/ |
| H A D | TestAbort.java | 40 Consumer consumer = new LocalConsumer(); in main() local
44 consumer.open(); in main()
45 consumer.compile("syscall:::entry { @[execname] = count(); } " + in main()
47 consumer.enable(); in main()
48 consumer.go(); in main()
55 consumer.close(); in main()
61 consumer = new LocalConsumer(); in main()
66 consumer.addConsumerListener(new ConsumerAdapter() { in main()
71 consumer.abort(); in main()
72 consumer.open(); in main()
[all …]
|
| H A D | TestStateMachine.java | 56 printState(Consumer consumer) in printState() argument
58 System.out.println("open: " + consumer.isOpen()); in printState()
59 System.out.println("enabled: " + consumer.isEnabled()); in printState()
60 System.out.println("closed: " + consumer.isClosed()); in printState()
64 beforeOpen(Consumer consumer) in beforeOpen() argument
67 printState(consumer); in beforeOpen()
71 consumer.compile("syscall:::entry"); in beforeOpen()
82 consumer.enable(); in beforeOpen()
93 consumer.getOption(Option.bufsize); in beforeOpen()
102 consumer.setOption(Option.bufsize, Option.mb(1)); in beforeOpen()
[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 | 36 Consumer consumer = new LocalConsumer(); in main() local
39 consumer.open(); in main()
40 consumer.compile("syscall:::entry { @[execname] = count(); } " + 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()
60 consumer.compile("syscall:::entry { @[execname] = count(); } " + in main()
62 consumer.enable(); in main()
[all …]
|
| H A D | TestDrop.java | 60 sampleAggregate(Consumer consumer) throws DTraceException in sampleAggregate() argument
62 while (consumer.isRunning() && !done.get()) { in sampleAggregate()
68 consumer.getAggregate(Collections. <String> emptySet()); 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()
[all …]
|
| H A D | TestStopLock.java | 37 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 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()
|
| H A D | TestMaxConsumers.java | 80 Consumer consumer = new LocalConsumer(); in main() local
81 consumer.open(); in main()
88 consumer.close(); in main()
|
| H A D | TestBean.java | 543 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 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 …]
|
| H A D | tst.Enable.ksh.out | 6 java.lang.IllegalArgumentException: program not compiled by this consumer
|
| /illumos-gate/usr/src/lib/libdtrace_jni/java/docs/examples/ |
| H A D | TestTarget.java | 44 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 D | TestAPI2.java | 46 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 D | TestAPI.java | 45 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 D | acpidev_rsc.h | 144 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 D | slp_ua_common.c | 44 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 D | dtrace_jni.c | 174 dtj_consumer_t *consumer; in dtj_get_java_consumer() local
182 consumer = g_consumer_table[handle]; in dtj_get_java_consumer()
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()
199 jc->dtjj_consumer = consumer; in dtj_get_java_consumer()
317 dtj_consumer_t *consumer; in dtj_remove_consumer() local
322 consumer = dtj_remove_consumer_at(handle); in dtj_remove_consumer()
323 return (consumer); in dtj_remove_consumer()
333 dtj_consumer_t *consumer; in dtj_remove_consumer_at() local
[all …]
|
| /illumos-gate/usr/src/uts/i86pc/io/acpi/acpidev/ |
| H A D | acpidev_resource.c | 68 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 D | dhcp_inittab.c | 111 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 D | README.inittab | 131 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 D | unm_nic_main.c | 1332 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 D | megaraid_sas.c | 1692 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()
|