1178476Sjb/*
2178476Sjb * CDDL HEADER START
3178476Sjb *
4178476Sjb * The contents of this file are subject to the terms of the
5178476Sjb * Common Development and Distribution License (the "License").
6178476Sjb * You may not use this file except in compliance with the License.
7178476Sjb *
8178476Sjb * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
9178476Sjb * or http://www.opensolaris.org/os/licensing.
10178476Sjb * See the License for the specific language governing permissions
11178476Sjb * and limitations under the License.
12178476Sjb *
13178476Sjb * When distributing Covered Code, include this CDDL HEADER in each
14178476Sjb * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
15178476Sjb * If applicable, add the following below this CDDL HEADER, with the
16178476Sjb * fields enclosed by brackets "[]" replaced with your own identifying
17178476Sjb * information: Portions Copyright [yyyy] [name of copyright owner]
18178476Sjb *
19178476Sjb * CDDL HEADER END
20178476Sjb */
21178476Sjb
22178476Sjb/*
23178476Sjb * Copyright 2006 Sun Microsystems, Inc.  All rights reserved.
24178476Sjb * Use is subject to license terms.
25178476Sjb *
26178476Sjb * ident	"%Z%%M%	%I%	%E% SMI"
27178476Sjb */
28178476Sjb
29178476Sjbimport org.opensolaris.os.dtrace.*;
30178476Sjb
31178476Sjb/**
32178476Sjb * Regression for bug 6419880 close() hangs running consumer.
33178476Sjb */
34178476Sjbpublic class TestClose {
35178476Sjb    public static void
36178476Sjb    main(String[] args)
37178476Sjb    {
38178476Sjb	Consumer consumer = new LocalConsumer();
39178476Sjb
40178476Sjb	try {
41178476Sjb	    consumer.open();
42178476Sjb	    consumer.compile("syscall:::entry { @[execname] = count(); } " +
43178476Sjb		    "tick-101ms { printa(@); }");
44178476Sjb	    consumer.enable();
45178476Sjb	    consumer.go();
46178476Sjb	    try {
47178476Sjb		Thread.currentThread().sleep(1000);
48178476Sjb	    } catch (InterruptedException e) {
49178476Sjb		e.printStackTrace();
50178476Sjb		System.exit(1);
51178476Sjb	    }
52178476Sjb	    consumer.close();
53178476Sjb	} catch (DTraceException e) {
54178476Sjb	    e.printStackTrace();
55178476Sjb	    System.exit(1);
56178476Sjb	}
57178476Sjb
58178476Sjb	consumer = new LocalConsumer();
59178476Sjb
60178476Sjb	try {
61178476Sjb	    consumer.open();
62178476Sjb	    consumer.compile("syscall:::entry { @[execname] = count(); } " +
63178476Sjb		    "tick-101ms { printa(@); }");
64178476Sjb	    consumer.enable();
65178476Sjb	    consumer.go();
66178476Sjb	    try {
67178476Sjb		Thread.currentThread().sleep(1000);
68178476Sjb	    } catch (InterruptedException e) {
69178476Sjb		e.printStackTrace();
70178476Sjb		System.exit(1);
71178476Sjb	    }
72178476Sjb	    try {
73178476Sjb		// Test new rule that close() is illegal while holding
74178476Sjb		// lock on consumer.
75178476Sjb		synchronized (consumer) {
76178476Sjb		    consumer.close();
77178476Sjb		}
78178476Sjb	    } catch (IllegalThreadStateException e) {
79178476Sjb		consumer.close();
80178476Sjb		System.out.println("Successful");
81178476Sjb		System.exit(0);
82178476Sjb	    }
83178476Sjb	} catch (DTraceException e) {
84178476Sjb	    e.printStackTrace();
85178476Sjb	    System.exit(1);
86178476Sjb	}
87178476Sjb	System.err.println("Failed");
88178476Sjb	System.exit(1);
89178476Sjb    }
90178476Sjb}
91