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 * Test for bug 6399888 stop() hangs if ConsumerListener calls
33178476Sjb * synchronized Consumer method
34178476Sjb */
35178476Sjbpublic class TestStopLock {
36178476Sjb    public static void
37178476Sjb    main(String[] args)
38178476Sjb    {
39178476Sjb	final Consumer consumer = new LocalConsumer();
40178476Sjb	consumer.addConsumerListener(new ConsumerAdapter() {
41178476Sjb	    @Override
42178476Sjb	    public void intervalBegan(ConsumerEvent e) {
43178476Sjb		consumer.isRunning();
44178476Sjb	    }
45178476Sjb	});
46178476Sjb
47178476Sjb	try {
48178476Sjb	    consumer.open();
49178476Sjb	    consumer.compile("syscall:::entry { @[execname] = count(); } " +
50178476Sjb		    "tick-101ms { printa(@); }");
51178476Sjb	    consumer.enable();
52178476Sjb	    consumer.go();
53178476Sjb	    try {
54178476Sjb		Thread.currentThread().sleep(500);
55178476Sjb	    } catch (InterruptedException e) {
56178476Sjb		e.printStackTrace();
57178476Sjb		System.exit(1);
58178476Sjb	    }
59178476Sjb	    consumer.stop();
60178476Sjb	    consumer.close();
61178476Sjb	} catch (DTraceException e) {
62178476Sjb	    e.printStackTrace();
63178476Sjb	    System.exit(1);
64178476Sjb	}
65178476Sjb	System.out.println("Successful");
66178476Sjb    }
67178476Sjb}
68