Searched defs:consumer (Results 1 - 13 of 13) sorted by relevance

/illumos-gate/usr/src/cmd/dtrace/test/tst/common/java_api/src/
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.java60 sampleAggregate(Consumer consumer) throws DTraceException argument
62 while (consumer.isRunning() && !done.get()) {
68 consumer.getAggregate(Collections. <String> emptySet());
73 startAggregateThread(final Consumer consumer) argument
81 sampleAggregate(consumer);
94 consumer.close(); // blocks if lock held
123 final Consumer consumer = new LocalConsumer() {
137 consumer.addConsumerListener(new ConsumerAdapter() {
139 startAggregateThread(consumer);
153 consumer
[all...]
H A DTestStateMachine.java56 printState(Consumer consumer) argument
58 System.out.println("open: " + consumer.isOpen());
59 System.out.println("enabled: " + consumer.isEnabled());
60 System.out.println("closed: " + consumer.isClosed());
64 beforeOpen(Consumer consumer) argument
67 printState(consumer);
71 consumer.compile("syscall:::entry");
82 consumer.enable();
93 consumer.getOption(Option.bufsize);
102 consumer
172 beforeCompile(Consumer consumer) argument
201 beforeEnable(Consumer consumer) argument
219 beforeGo(Consumer consumer) argument
268 afterGo(Consumer consumer, Program program) argument
365 afterStop(Consumer consumer, Program program) argument
409 afterClose(Consumer consumer, Program program) argument
[all...]
/illumos-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
/illumos-gate/usr/src/uts/i86pc/io/acpi/acpidev/
H A Dacpidev_resource.c68 acpidev_resource_handle_alloc(boolean_t consumer) argument
73 rhdl->acpidev_consumer = consumer;
762 "!acpidev: unsupported consumer resource type %u, ignored.",
771 ACPIDEV_DEBUG(CE_NOTE, "!acpidev: consumer encountered "
902 ACPIDEV_DEBUG(CE_NOTE, "!acpidev: consumer encountered "
921 ACPIDEV_DEBUG(CE_NOTE, "!acpidev: consumer encountered "
947 ACPIDEV_DEBUG(CE_NOTE, "!acpidev: consumer encountered "
968 boolean_t consumer, acpidev_resource_handle_t *rhdlp)
1002 rhdl = acpidev_resource_handle_alloc(consumer);
1003 if (consumer) {
967 acpidev_resource_walk(ACPI_HANDLE hdl, char *method, boolean_t consumer, acpidev_resource_handle_t *rhdlp) argument
1026 acpidev_resource_process(acpidev_walk_info_t *infop, boolean_t consumer) argument
[all...]
/illumos-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...]
/illumos-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...]
/illumos-gate/usr/src/lib/libdtrace_jni/java/src/org/opensolaris/os/dtrace/
H A DLocalConsumer.java37 * DTrace consumer.
162 // Per-consumer lock used in native code to prevent conflict between
163 // the native consumer loop and the getAggregate() thread without
164 // locking this LocalConsumer. A distinct per-consumer lock allows
166 // when the consumer loop grabs the per-consumer lock before
173 // method does not return until this consumer has actually stopped.
175 // deadlock this consumer:
176 // 1. stop() grabs the lock on this consumer before determining if
177 // this consumer i
1381 Identifier(LocalConsumer consumer) argument
[all...]
/illumos-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...]
/illumos-gate/usr/src/uts/common/io/mega_sas/
H A Dmegaraid_sas.c1692 uint32_t consumer; local
1715 consumer = *instance->consumer;
1717 con_log(CL_ANN1, (CE_CONT, " producer %x consumer %x ",
1718 producer, consumer));
1722 while (consumer != producer) {
1723 context = instance->reply_queue[consumer];
1727 consumer++;
1728 if (consumer == (instance->max_fw_cmds + 1)) {
1729 consumer
[all...]
H A Dmegaraid_sas.h1142 uint32_t *consumer; member in struct:megasas_instance
/illumos-gate/usr/src/uts/common/io/mr_sas/
H A Dmr_sas.c2306 uint32_t consumer; local
2359 consumer = ddi_get32(instance->mfi_internal_dma_obj.acc_handle,
2360 instance->consumer);
2362 con_log(CL_ANN, (CE_CONT, " producer %x consumer %x ",
2363 producer, consumer));
2364 if (producer == consumer) {
2365 con_log(CL_ANN, (CE_WARN, "producer == consumer case"));
2367 uint32_t, consumer);
2373 while (consumer != producer) {
2375 &instance->reply_queue[consumer]);
[all...]
H A Dmr_sas.h463 uint32_t *consumer; member in struct:mrsas_instance

Completed in 117 milliseconds