Searched refs:consumer (Results 1 - 25 of 28) sorted by relevance

12

/opensolaris-onvv-gate/usr/src/cmd/dtrace/test/tst/common/java_api/src/
H A DTestAbort.java42 Consumer consumer = new LocalConsumer();
46 consumer.open();
47 consumer.compile("syscall:::entry { @[execname] = count(); } " +
49 consumer.enable();
50 consumer.go();
57 consumer.close();
63 consumer = new LocalConsumer();
65 // Should be able to abort an unopened consumer
68 consumer.addConsumerListener(new ConsumerAdapter() {
73 consumer
[all...]
H A DTestClose.java32 * Regression for bug 6419880 close() hangs running consumer.
38 Consumer consumer = new LocalConsumer();
41 consumer.open();
42 consumer.compile("syscall:::entry { @[execname] = count(); } " +
44 consumer.enable();
45 consumer.go();
52 consumer.close();
58 consumer = new LocalConsumer();
61 consumer.open();
62 consumer
[all...]
H A DTestStopLock.java39 final Consumer consumer = new LocalConsumer();
40 consumer.addConsumerListener(new ConsumerAdapter() {
43 consumer.isRunning();
48 consumer.open();
49 consumer.compile("syscall:::entry { @[execname] = count(); } " +
51 consumer.enable();
52 consumer.go();
59 consumer.stop();
60 consumer.close();
H A DTestEnable.java34 * consumer.
48 Consumer consumer = new LocalConsumer();
51 consumer.open();
52 Program p0 = consumer.compile("dtrace:::BEGIN");
53 Program p1 = consumer.compile("syscall:::entry");
54 Program p2 = consumer.compile("dtrace:::END");
55 consumer.enable(p0);
56 consumer.enable(p1);
58 consumer.go();
69 consumer
[all...]
H A DTestFunctionLookup.java48 Consumer consumer = new LocalConsumer();
50 consumer.open();
51 consumer.compile(kernelLookupProgram);
52 consumer.enable();
53 consumer.go();
60 a = consumer.getAggregate();
66 f = consumer.lookupKernelFunction(addr);
69 f = consumer.lookupKernelFunction(addr);
78 consumer.close();
84 consumer
[all...]
H A DTestStateMachine.java58 printState(Consumer consumer) argument
60 System.out.println("open: " + consumer.isOpen());
61 System.out.println("enabled: " + consumer.isEnabled());
62 System.out.println("closed: " + consumer.isClosed());
66 beforeOpen(Consumer consumer) argument
69 printState(consumer);
73 consumer.compile("syscall:::entry");
84 consumer.enable();
95 consumer.getOption(Option.bufsize);
104 consumer
174 beforeCompile(Consumer consumer) argument
203 beforeEnable(Consumer consumer) argument
221 beforeGo(Consumer consumer) argument
270 afterGo(Consumer consumer, Program program) argument
367 afterStop(Consumer consumer, Program program) argument
411 afterClose(Consumer consumer, Program program) argument
[all...]
H A DTestGetAggregate.java47 testIncluded(Consumer consumer, String ... aggregationNames) argument
63 aggregate = consumer.getAggregate(included, null);
81 if (!consumer.isRunning()) {
82 throw new IllegalStateException("consumer exited");
87 testCleared(Consumer consumer, String ... aggregationNames) argument
104 aggregate = consumer.getAggregate(null, cleared);
110 aggregate = consumer.getAggregate(null, cleared);
119 } while (consumer.isRunning() && n++ < INTERVALS);
146 if (!consumer.isRunning()) {
147 throw new IllegalStateException("consumer exite
[all...]
H A DTestDrop.java62 sampleAggregate(Consumer consumer) throws DTraceException argument
64 while (consumer.isRunning() && !done.get()) {
70 consumer.getAggregate(Collections. <String> emptySet());
75 startAggregateThread(final Consumer consumer) argument
83 sampleAggregate(consumer);
96 consumer.close(); // blocks if lock held
125 final Consumer consumer = new LocalConsumer() {
139 consumer.addConsumerListener(new ConsumerAdapter() {
141 startAggregateThread(consumer);
155 consumer
[all...]
H A DTestProbeData.java84 final Consumer consumer = new LocalConsumer();
86 consumer.addConsumerListener(new ConsumerAdapter() {
96 consumer.close();
101 consumer.open();
102 consumer.createProcess(command);
103 consumer.compile(PROGRAM);
104 consumer.enable();
105 consumer.go();
H A DTestMultiAggPrinta.java111 final Consumer consumer = new LocalConsumer();
112 consumer.addConsumerListener(new ConsumerAdapter() {
125 consumer.close();
132 consumer.open();
133 consumer.compile(file);
134 consumer.enable();
135 consumer.go();
H A DTestMaxConsumers.java80 Consumer consumer = new LocalConsumer();
81 consumer.open();
88 consumer.close();
H A DTestBean.java500 Consumer consumer = new LocalConsumer();
503 consumer.open();
504 p = consumer.compile(PROGRAM);
505 consumer.close();
517 Consumer consumer = new LocalConsumer();
524 consumer.open();
525 p = consumer.compile(file);
526 consumer.close();
/opensolaris-onvv-gate/usr/src/lib/libdtrace_jni/java/docs/examples/
H A DTestAPI.java45 Consumer consumer = new LocalConsumer();
46 consumer.addConsumerListener(new ConsumerAdapter() {
53 consumer.open();
54 consumer.compile(file, macroArgs);
55 consumer.enable();
56 consumer.go();
H A DTestTarget.java44 final Consumer consumer = new LocalConsumer();
45 consumer.addConsumerListener(new ConsumerAdapter() {
51 Aggregate a = consumer.getAggregate();
62 consumer.close();
70 consumer.open();
72 consumer.createProcess(command);
73 consumer.compile(file);
74 consumer.enable();
75 consumer.go();
H A DTestAPI2.java46 Consumer consumer = new LocalConsumer();
47 consumer.addConsumerListener(new ConsumerAdapter() {
62 consumer.open();
63 consumer.compile(file, macroArgs);
64 consumer.enable();
65 consumer.go();
70 a = consumer.getAggregate();
74 } while (consumer.isRunning());
/opensolaris-onvv-gate/usr/src/uts/i86pc/sys/
H A Dacpidev_rsc.h144 boolean_t consumer);
185 boolean_t consumer, acpidev_resource_handle_t *rhdlp);
190 * properties for resource consumer.
194 boolean_t consumer);
/opensolaris-onvv-gate/usr/src/lib/libslp/clib/
H A Dslp_ua_common.c46 static SLPError consumer(void *);
101 /* kick off the consumer thread */
103 NULL, 0, (void *(*)(void *))consumer,
118 return (consumer(args));
124 static SLPError consumer(void *ap) { function
/opensolaris-onvv-gate/usr/src/lib/libdtrace_jni/common/
H A Ddtrace_jni.c58 * C, such as after notifying the java consumer of new data. Failure to do this
67 * It is important to stop a DTrace consumer and remove it if an exception
68 * occurs. This API guarantees that a consumer is stopped automatically if it
80 * MonitorExit() or the application will hang (all consumer threads). The
81 * consumer loop and the getAggregate() method require a per-consumer lock
101 #define FIRST_HANDLE 0 /* sequence-generated consumer ID */
103 #define INITIAL_CAPACITY 8 /* initial size of consumer array */
109 * key: caller's consumer handle (int)
110 * value: per-consumer dat
176 dtj_consumer_t *consumer; local
319 dtj_consumer_t *consumer; local
335 dtj_consumer_t *consumer; local
[all...]
/opensolaris-onvv-gate/usr/src/uts/common/io/mac/
H A DREADME41 a consumer.
/opensolaris-onvv-gate/usr/src/uts/i86pc/io/acpi/acpidev/
H A Dacpidev_resource.c66 acpidev_resource_handle_alloc(boolean_t consumer) argument
71 rhdl->acpidev_consumer = consumer;
749 "!acpidev: unsupported consumer resource type %u, ignored.",
758 ACPIDEV_DEBUG(CE_NOTE, "!acpidev: consumer encountered "
889 ACPIDEV_DEBUG(CE_NOTE, "!acpidev: consumer encountered "
908 ACPIDEV_DEBUG(CE_NOTE, "!acpidev: consumer encountered "
930 ACPIDEV_DEBUG(CE_NOTE, "!acpidev: consumer encountered "
951 boolean_t consumer, acpidev_resource_handle_t *rhdlp)
985 rhdl = acpidev_resource_handle_alloc(consumer);
986 if (consumer) {
950 acpidev_resource_walk(ACPI_HANDLE hdl, char *method, boolean_t consumer, acpidev_resource_handle_t *rhdlp) argument
1009 acpidev_resource_process(acpidev_walk_info_t *infop, boolean_t consumer) argument
[all...]
/opensolaris-onvv-gate/usr/src/lib/libdhcputil/common/
H A Ddhcp_inittab.c102 * input: uchar_t: the categories the consumer is interested in
103 * char: the consumer type of the caller
110 inittab_load(uchar_t categories, char consumer, size_t *n_entries) argument
112 return (inittab_lookup(categories, consumer, NULL, -1, n_entries));
118 * input: int: the categories the consumer is interested in
119 * char: the consumer type of the caller
120 * char *: the name of the inittab entry the consumer wants
126 inittab_getbyname(uchar_t categories, char consumer, const char *name) argument
128 return (inittab_lookup(categories, consumer, name, -1, NULL));
134 * input: uchar_t: the categories the consumer i
142 inittab_getbycode(uchar_t categories, char consumer, uint16_t code) argument
162 inittab_lookup(uchar_t categories, char consumer, const char *name, int32_t code, size_t *n_entriesp) argument
[all...]
/opensolaris-onvv-gate/usr/src/uts/common/io/ntxn/
H A Dunm_nic_main.c1332 uint32_t consumer, start; local
1336 start = consumer = recv_ctx->statusRxConsumer;
1343 desc = &desc_head[consumer];
1350 consumer = (consumer + 1) % adapter->MaxRxDescCount;
1366 /* update the consumer index in phantom */
1367 recv_ctx->statusRxConsumer = consumer;
1371 recv_ctx->host_sds_consumer, &consumer, 4);
1383 u32 consumer; local
1394 consumer
[all...]
/opensolaris-onvv-gate/usr/src/uts/common/io/mr_sas/
H A Dmr_sas.c1656 uint32_t consumer; local
1695 consumer = ddi_get32(instance->mfi_internal_dma_obj.acc_handle,
1696 instance->consumer);
1698 con_log(CL_ANN1, (CE_NOTE, " producer %x consumer %x ",
1699 producer, consumer));
1700 if (producer == consumer) {
1701 con_log(CL_ANN1, (CE_WARN, "producer = consumer case"));
1703 uint32_t, consumer);
1709 while (consumer != producer) {
1711 &instance->reply_queue[consumer]);
[all...]
/opensolaris-onvv-gate/usr/src/uts/common/io/mega_sas/
H A Dmegaraid_sas.c1693 uint32_t consumer; local
1716 consumer = *instance->consumer;
1718 con_log(CL_ANN1, (CE_CONT, " producer %x consumer %x ",
1719 producer, consumer));
1723 while (consumer != producer) {
1724 context = instance->reply_queue[consumer];
1728 consumer++;
1729 if (consumer == (instance->max_fw_cmds + 1)) {
1730 consumer
[all...]
/opensolaris-onvv-gate/usr/src/lib/libdhcputil/
H A DREADME.inittab132 programs, even if they are listed as a `consumer' of the given
169 inittab_load(uchar_t categories, char consumer, size_t *n_entries);
172 inittab_getbyname(uchar_t categories, char consumer, const char *name);
175 inittab_getbycode(uchar_t categories, char consumer, unsigned int code);
186 and the `consumer' field consists of one of the following:
195 to the provided consumer. Note that there is no specified order to
201 provided consumer. The dhcp_symbol_t is dynamically allocated.

Completed in 226 milliseconds

12