/illumos-gate/usr/src/cmd/dtrace/test/tst/common/java_api/src/ |
H A D | TestGetAggregate.java | 47 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 D | TestDrop.java | 60 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 D | TestStateMachine.java | 56 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 D | slp_ua_common.c | 46 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 D | acpidev_resource.c | 68 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 D | dhcp_inittab.c | 102 * 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 D | dtrace_jni.c | 58 * 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 D | LocalConsumer.java | 37 * 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 D | unm_nic_main.c | 1332 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 D | megaraid_sas.c | 1692 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 D | megaraid_sas.h | 1142 uint32_t *consumer; member in struct:megasas_instance
|
/illumos-gate/usr/src/uts/common/io/mr_sas/ |
H A D | mr_sas.c | 2306 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 D | mr_sas.h | 463 uint32_t *consumer; member in struct:mrsas_instance
|