| /onnv/onnv-gate/usr/src/cmd/dtrace/test/tst/common/java_api/src/ |
| TestStopLock.java | 33 * synchronized Consumer method
39 final Consumer consumer = new LocalConsumer(); local
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()
[all...] |
| TestClose.java | 32 * Regression for bug 6419880 close() hangs running consumer.
38 Consumer consumer = new LocalConsumer(); local
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()
[all...] |
| TestAbort.java | 42 Consumer consumer = new LocalConsumer(); local
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()
[all...] |
| TestStateMachine.java | 32 * Regression test for the LocalConsumer state machine. Calls Consumer
58 printState(Consumer consumer)
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)
69 printState(consumer);
73 consumer.compile("syscall:::entry")
585 final Consumer consumer = new LocalConsumer(); local
[all...] |
| TestFunctionLookup.java | 48 Consumer consumer = new LocalConsumer(); local
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()
[all...] |
| TestDrop.java | 62 sampleAggregate(Consumer consumer) throws DTraceException
64 while (consumer.isRunning() && !done.get()) {
70 consumer.getAggregate(Collections. <String> emptySet());
75 startAggregateThread(final Consumer consumer)
83 sampleAggregate(consumer);
96 consumer.close(); // blocks if lock held
125 final Consumer consumer = new LocalConsumer() local
[all...] |
| TestGetAggregate.java | 47 testIncluded(Consumer consumer, String ... aggregationNames)
63 aggregate = consumer.getAggregate(included, null);
81 if (!consumer.isRunning()) {
82 throw new IllegalStateException("consumer exited");
87 testCleared(Consumer consumer, String ... aggregationNames)
104 aggregate = consumer.getAggregate(null, cleared);
110 aggregate = consumer.getAggregate(null, cleared);
119 } while (consumer.isRunning() && n++ < INTERVALS)
157 final Consumer consumer = new LocalConsumer(); local
191 final Consumer consumer = new LocalConsumer(); local
[all...] |
| TestMaxConsumers.java | 61 Consumer[] consumers = new Consumer[n];
80 Consumer consumer = new LocalConsumer(); local
81 consumer.open();
88 consumer.close();
|
| TestEnable.java | 34 * consumer.
48 Consumer consumer = new LocalConsumer(); local
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()
[all...] |
| TestProbeData.java | 84 final Consumer consumer = new LocalConsumer(); local
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();
|
| TestMultiAggPrinta.java | 111 final Consumer consumer = new LocalConsumer(); local
112 consumer.addConsumerListener(new ConsumerAdapter() {
125 consumer.close();
132 consumer.open();
133 consumer.compile(file);
134 consumer.enable();
135 consumer.go();
|
| TestBean.java | 500 Consumer consumer = new LocalConsumer(); local
503 consumer.open();
504 p = consumer.compile(PROGRAM);
505 consumer.close();
517 Consumer consumer = new LocalConsumer(); local
524 consumer.open();
525 p = consumer.compile(file);
526 consumer.close()
[all...] |
| /onnv/onnv-gate/usr/src/lib/libdtrace_jni/java/docs/examples/ |
| TestTarget.java | 44 final Consumer consumer = new LocalConsumer(); local
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()
[all...] |
| TestAPI.java | 45 Consumer consumer = new LocalConsumer(); local
46 consumer.addConsumerListener(new ConsumerAdapter() {
53 consumer.open();
54 consumer.compile(file, macroArgs);
55 consumer.enable();
56 consumer.go();
|
| TestAPI2.java | 46 Consumer consumer = new LocalConsumer(); local
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());
|
| /onnv/onnv-gate/usr/src/lib/libslp/clib/ |
| 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
|
| /onnv/onnv-gate/usr/src/lib/libdtrace_jni/common/ |
| 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 data includes dtrace handle (consumer_t *
176 dtj_consumer_t *consumer; local
319 dtj_consumer_t *consumer; local
335 dtj_consumer_t *consumer; local
[all...] |
| /onnv/onnv-gate/usr/src/uts/common/io/mega_sas/ |
| megaraid_sas.c | 1692 uint32_t consumer; local
[all...] |
| megaraid_sas.h | 1142 uint32_t *consumer; member in struct:megasas_instance
[all...] |
| /onnv/onnv-gate/usr/src/uts/common/io/ntxn/ |
| unm_nic_main.c | 1333 uint32_t consumer, start; local
1384 u32 consumer; local
[all...] |
| /onnv/onnv-gate/usr/src/uts/common/io/mr_sas/ |
| mr_sas.c | 1545 uint32_t consumer; local
[all...] |
| mr_sas.h | 366 uint32_t *consumer; member in struct:mrsas_instance
[all...] |
