27 */
28
29 import org.opensolaris.os.dtrace.*;
30
31 /**
32 * Regression for bug 6419880 close() hangs running consumer.
33 */
34 public class TestClose {
35 public static void
36 main(String[] args)
37 {
38 Consumer consumer = new LocalConsumer();
39
40 try {
41 consumer.open();
42 consumer.compile("syscall:::entry { @[execname] = count(); } " +
43 "tick-101ms { printa(@); }");
44 consumer.enable();
45 consumer.go();
46 try {
47 Thread.currentThread().sleep(1000);
48 } catch (InterruptedException e) {
49 e.printStackTrace();
50 System.exit(1);
51 }
52 consumer.close();
53 } catch (DTraceException e) {
54 e.printStackTrace();
55 System.exit(1);
56 }
57
58 consumer = new LocalConsumer();
59
60 try {
61 consumer.open();
62 consumer.compile("syscall:::entry { @[execname] = count(); } " +
63 "tick-101ms { printa(@); }");
64 consumer.enable();
65 consumer.go();
66 try {
67 Thread.currentThread().sleep(1000);
68 } catch (InterruptedException e) {
69 e.printStackTrace();
70 System.exit(1);
71 }
72 try {
73 // Test new rule that close() is illegal while holding
74 // lock on consumer.
75 synchronized (consumer) {
76 consumer.close();
77 }
78 } catch (IllegalThreadStateException e) {
79 consumer.close();
80 System.out.println("Successful");
81 System.exit(0);
82 }
83 } catch (DTraceException e) {
84 e.printStackTrace();
85 System.exit(1);
86 }
87 System.err.println("Failed");
|
27 */
28
29 import org.opensolaris.os.dtrace.*;
30
31 /**
32 * Regression for bug 6419880 close() hangs running consumer.
33 */
34 public class TestClose {
35 public static void
36 main(String[] args)
37 {
38 Consumer consumer = new LocalConsumer();
39
40 try {
41 consumer.open();
42 consumer.compile("syscall:::entry { @[execname] = count(); } " +
43 "tick-101ms { printa(@); }");
44 consumer.enable();
45 consumer.go();
46 try {
47 Thread.sleep(1000);
48 } catch (InterruptedException e) {
49 e.printStackTrace();
50 System.exit(1);
51 }
52 consumer.close();
53 } catch (DTraceException e) {
54 e.printStackTrace();
55 System.exit(1);
56 }
57
58 consumer = new LocalConsumer();
59
60 try {
61 consumer.open();
62 consumer.compile("syscall:::entry { @[execname] = count(); } " +
63 "tick-101ms { printa(@); }");
64 consumer.enable();
65 consumer.go();
66 try {
67 Thread.sleep(1000);
68 } catch (InterruptedException e) {
69 e.printStackTrace();
70 System.exit(1);
71 }
72 try {
73 // Test new rule that close() is illegal while holding
74 // lock on consumer.
75 synchronized (consumer) {
76 consumer.close();
77 }
78 } catch (IllegalThreadStateException e) {
79 consumer.close();
80 System.out.println("Successful");
81 System.exit(0);
82 }
83 } catch (DTraceException e) {
84 e.printStackTrace();
85 System.exit(1);
86 }
87 System.err.println("Failed");
|