1 /*
2 * Copyright (c) 1998, 2008, Oracle and/or its affiliates. All rights reserved.
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4 *
5 * This code is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License version 2 only, as
7 * published by the Free Software Foundation.
8 *
9 * This code is distributed in the hope that it will be useful, but WITHOUT
10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
12 * version 2 for more details (a copy is included in the LICENSE file that
13 * accompanied this code).
14 *
15 * You should have received a copy of the GNU General Public License version
16 * 2 along with this work; if not, write to the Free Software Foundation,
17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18 *
19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20 * or visit www.oracle.com if you need additional information or have any
21 * questions.
22 */
57 public synchronized int getNumDeactivated() throws RemoteException {
58 return(num_deactivated);
59 }
60
61 public synchronized void incNumDeactivated() {
62 num_deactivated++;
63 }
64
65 }
66
67 public class UnregisterGroup
68 extends Activatable
69 implements ActivateMe, Runnable
70 {
71
72 private static Exception exception = null;
73 private static String error = null;
74 private static boolean done = false;
75 private static ActivateMe lastResortExitObj = null;
76 private static final int NUM_OBJECTS = 10;
77 private static int PORT = 2006;
78
79 public UnregisterGroup(ActivationID id, MarshalledObject mobj)
80 throws Exception
81 {
82 super(id, 0);
83 }
84
85 public void ping()
86 {}
87
88 public void unregister() throws Exception {
89 super.unregister(super.getID());
90 }
91
92 /**
93 * Spawns a thread to deactivate the object.
94 */
95 public void shutdown() throws Exception {
96 (new Thread(this,"UnregisterGroup")).start();
97 }
99 /**
100 * To support exiting of group VM as a last resort
101 */
102 public void justGoAway() {
103 System.exit(0);
104 }
105
106 /**
107 * Thread to deactivate object. First attempts to make object
108 * inactive (via the inactive method). If that fails (the
109 * object may still have pending/executing calls), then
110 * unexport the object forcibly.
111 */
112 public void run() {
113
114 ActivationLibrary.deactivate(this, getID());
115 System.err.println("\tActivationLibrary.deactivate returned");
116
117 try {
118 CallbackInterface cobj =
119 (CallbackInterface)Naming.lookup("//:" + PORT + "/Callback");
120 cobj.inc();
121 } catch (Exception e) {
122 System.err.println("cobj.inc exception");
123 e.printStackTrace();
124 }
125
126 }
127
128 public static void main(String[] args) {
129
130 Registry registry;
131
132 System.err.println("\nRegression test for bug 4134233\n");
133
134 TestLibrary.suggestSecurityManager("java.rmi.RMISecurityManager");
135 RMID rmid = null;
136
137 try {
138 RMID.removeLog();
139 rmid = RMID.createRMID();
218 TestLibrary.bomb("test failed: not completed before timeout", null);
219 } else {
220 System.err.println("Test passed");
221 }
222
223
224 } catch (Exception e) {
225 TestLibrary.bomb("test failed", e);
226 } finally {
227 if (lastResortExitObj != null) {
228 try {
229 lastResortExitObj.justGoAway();
230 } catch (Exception munch) {
231 }
232 }
233
234 // Wait for the object deactivation to take place first
235 try {
236
237 // create reg and export callback object
238 registry = LocateRegistry.createRegistry(PORT);
239 Callback robj = new Callback();
240 registry.bind("Callback", robj);
241
242 //get the callback object
243 int maxwait=30;
244 int nd = robj.getNumDeactivated();
245 while ((nd < NUM_OBJECTS) && (maxwait> 0)) {
246 System.err.println("num_deactivated="+nd);
247 try {
248 Thread.sleep(1000);
249 } catch (InterruptedException ie) {}
250 maxwait--;
251 nd = robj.getNumDeactivated();
252 }
253 } catch (Exception ce) {
254 System.err.println("E:"+ce);
255 ce.printStackTrace();
256 }
257
258 ActivationLibrary.rmidCleanup(rmid);
|
1 /*
2 * Copyright (c) 1998, 2012, Oracle and/or its affiliates. All rights reserved.
3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4 *
5 * This code is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License version 2 only, as
7 * published by the Free Software Foundation.
8 *
9 * This code is distributed in the hope that it will be useful, but WITHOUT
10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
12 * version 2 for more details (a copy is included in the LICENSE file that
13 * accompanied this code).
14 *
15 * You should have received a copy of the GNU General Public License version
16 * 2 along with this work; if not, write to the Free Software Foundation,
17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18 *
19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20 * or visit www.oracle.com if you need additional information or have any
21 * questions.
22 */
57 public synchronized int getNumDeactivated() throws RemoteException {
58 return(num_deactivated);
59 }
60
61 public synchronized void incNumDeactivated() {
62 num_deactivated++;
63 }
64
65 }
66
67 public class UnregisterGroup
68 extends Activatable
69 implements ActivateMe, Runnable
70 {
71
72 private static Exception exception = null;
73 private static String error = null;
74 private static boolean done = false;
75 private static ActivateMe lastResortExitObj = null;
76 private static final int NUM_OBJECTS = 10;
77 private static int registryPort = -1;
78
79 public UnregisterGroup(ActivationID id, MarshalledObject mobj)
80 throws Exception
81 {
82 super(id, 0);
83 }
84
85 public void ping()
86 {}
87
88 public void unregister() throws Exception {
89 super.unregister(super.getID());
90 }
91
92 /**
93 * Spawns a thread to deactivate the object.
94 */
95 public void shutdown() throws Exception {
96 (new Thread(this,"UnregisterGroup")).start();
97 }
99 /**
100 * To support exiting of group VM as a last resort
101 */
102 public void justGoAway() {
103 System.exit(0);
104 }
105
106 /**
107 * Thread to deactivate object. First attempts to make object
108 * inactive (via the inactive method). If that fails (the
109 * object may still have pending/executing calls), then
110 * unexport the object forcibly.
111 */
112 public void run() {
113
114 ActivationLibrary.deactivate(this, getID());
115 System.err.println("\tActivationLibrary.deactivate returned");
116
117 try {
118 CallbackInterface cobj =
119 (CallbackInterface)Naming.lookup("//:" + registryPort + "/Callback");
120 cobj.inc();
121 } catch (Exception e) {
122 System.err.println("cobj.inc exception");
123 e.printStackTrace();
124 }
125
126 }
127
128 public static void main(String[] args) {
129
130 Registry registry;
131
132 System.err.println("\nRegression test for bug 4134233\n");
133
134 TestLibrary.suggestSecurityManager("java.rmi.RMISecurityManager");
135 RMID rmid = null;
136
137 try {
138 RMID.removeLog();
139 rmid = RMID.createRMID();
218 TestLibrary.bomb("test failed: not completed before timeout", null);
219 } else {
220 System.err.println("Test passed");
221 }
222
223
224 } catch (Exception e) {
225 TestLibrary.bomb("test failed", e);
226 } finally {
227 if (lastResortExitObj != null) {
228 try {
229 lastResortExitObj.justGoAway();
230 } catch (Exception munch) {
231 }
232 }
233
234 // Wait for the object deactivation to take place first
235 try {
236
237 // create reg and export callback object
238 registry = TestLibrary.createRegistryOnUnusedPort();
239 registryPort = TestLibrary.getRegistryPort(registry);
240 Callback robj = new Callback();
241 registry.bind("Callback", robj);
242
243 //get the callback object
244 int maxwait=30;
245 int nd = robj.getNumDeactivated();
246 while ((nd < NUM_OBJECTS) && (maxwait> 0)) {
247 System.err.println("num_deactivated="+nd);
248 try {
249 Thread.sleep(1000);
250 } catch (InterruptedException ie) {}
251 maxwait--;
252 nd = robj.getNumDeactivated();
253 }
254 } catch (Exception ce) {
255 System.err.println("E:"+ce);
256 ce.printStackTrace();
257 }
258
259 ActivationLibrary.rmidCleanup(rmid);
|