1 /*
   2  * CDDL HEADER START
   3  *
   4  * The contents of this file are subject to the terms of the
   5  * Common Development and Distribution License (the "License").
   6  * You may not use this file except in compliance with the License.
   7  *
   8  * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
   9  * or http://www.opensolaris.org/os/licensing.
  10  * See the License for the specific language governing permissions
  11  * and limitations under the License.
  12  *
  13  * When distributing Covered Code, include this CDDL HEADER in each
  14  * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
  15  * If applicable, add the following below this CDDL HEADER, with the
  16  * fields enclosed by brackets "[]" replaced with your own identifying
  17  * information: Portions Copyright [yyyy] [name of copyright owner]
  18  *
  19  * CDDL HEADER END
  20  */
  21 
  22 /*
  23  * Copyright 2006 Sun Microsystems, Inc.  All rights reserved.
  24  * Use is subject to license terms.
  25  *
  26  * ident        "%Z%%M% %I%     %E% SMI"
  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");
  88         System.exit(1);
  89     }
  90 }