/opensolaris-onvv-gate/usr/src/cmd/dtrace/test/tst/common/java_api/src/ |
H A D | TestAbort.java | 42 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 D | TestClose.java | 32 * 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 D | TestStopLock.java | 39 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 D | TestEnable.java | 34 * 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 D | TestFunctionLookup.java | 48 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 D | TestStateMachine.java | 58 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 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 | 62 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 D | TestProbeData.java | 84 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 D | TestMultiAggPrinta.java | 111 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 D | TestMaxConsumers.java | 80 Consumer consumer = new LocalConsumer(); 81 consumer.open(); 88 consumer.close();
|
H A D | TestBean.java | 500 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 D | TestAPI.java | 45 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 D | TestTarget.java | 44 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 D | TestAPI2.java | 46 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 D | acpidev_rsc.h | 144 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 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
|
/opensolaris-onvv-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...] |
/opensolaris-onvv-gate/usr/src/uts/common/io/mac/ |
H A D | README | 41 a consumer.
|
/opensolaris-onvv-gate/usr/src/uts/i86pc/io/acpi/acpidev/ |
H A D | acpidev_resource.c | 66 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 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...] |
/opensolaris-onvv-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...] |
/opensolaris-onvv-gate/usr/src/uts/common/io/mr_sas/ |
H A D | mr_sas.c | 1656 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 D | megaraid_sas.c | 1693 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 D | README.inittab | 132 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.
|