bridges/test/com/sun/star/lib/uno/bridges/java_remote/StopMessageDispatcherTest.java

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: StopMessageDispatcherTest.java,v $
  10  * $Revision: 1.5 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30
  31 package com.sun.star.lib.uno.bridges.javaremote;
  32
  33 import com.sun.star.bridge.XInstanceProvider;
  34 import com.sun.star.lang.DisposedException;
  35 import com.sun.star.lib.TestBed;
  36 import com.sun.star.lib.uno.typeinfo.MethodTypeInfo;
  37 import com.sun.star.lib.uno.typeinfo.TypeInfo;
  38 import com.sun.star.uno.UnoRuntime;
  39 import com.sun.star.uno.XComponentContext;
  40 import com.sun.star.uno.XInterface;
  41 import complexlib.ComplexTestCase;
  42
  43 /* This test has to detect whether the spawned client process hangs, which can
  44  * not be done reliably.  As an approximation, it waits for 10 sec and considers
  45  * the process hanging if it has not terminated by then.
  46  */
  47 public final class StopMessageDispatcherTest extends ComplexTestCase {
  48     public StopMessageDispatcherTest() {}
  49
  50     public String[] getTestMethodNames() {
  51         return new String[] { "test" };
  52     }
  53
  54     public void test() throws Exception {
  55         assure(
  56             "test",
  57             new TestBed().execute(new Provider(), false, Client.class, 10000));
  58     }
  59
  60     public static final class Client extends TestBed.Client {
  61         public static void main(String[] args) {
  62             new Client().execute();
  63         }
  64
  65         protected boolean run(XComponentContext context) throws Throwable {
  66             XTest test = UnoRuntime.queryInterface(
  67                 XTest.class, getBridge(context).getInstance("Test"));
  68             Thread[] threads = new Thread[101];
  69             int n = Thread.enumerate(threads);
  70             if (n > 100) {
  71                 System.err.println("ERROR: too many threads");
  72                 return false;
  73             }
  74             boolean stopped = false;
  75             for (int i = 0; i < n; ++i) {
  76                 if (threads[i].getName().equals("MessageDispatcher")) {
  77                     threads[i].stop();
  78                     stopped = true;
  79                     break;
  80                 }
  81             }
  82             if (!stopped) {
  83                 System.err.println("ERROR: thread not found");
  84                 return false;
  85             }
  86             try {
  87                 test.call();
  88                 System.err.println("ERROR: no DisposedException");
  89                 return false;
  90             } catch (DisposedException e) {
  91                 return true;
  92             }
  93         }
  94
  95         private Client() {}
  96     }
  97
  98     private static final class Provider implements XInstanceProvider {
  99         public Object getInstance(String instanceName) {
 100             return new XTest() {
 101                     public void call() {}
 102                 };
 103         }
 104     }
 105
 106     public interface XTest extends XInterface {
 107         void call();
 108
 109         TypeInfo[] UNOTYPEINFO = { new MethodTypeInfo("call", 0, 0) };
 110     }
 111 }