summaryrefslogtreecommitdiff
path: root/gnu/java/rmi/server/ActivatableServerRef.java
diff options
context:
space:
mode:
authorAudrius Meskauskas <audriusa@Bioinformatics.org>2006-03-17 12:19:25 +0000
committerAudrius Meskauskas <audriusa@Bioinformatics.org>2006-03-17 12:19:25 +0000
commit616d94e82c815801ba158e5e3731aa53905bbf1e (patch)
treed3f3e62aa4e814263450fce60d5b76223c0d85ab /gnu/java/rmi/server/ActivatableServerRef.java
parent6c99d6627576eafb4301a1f3822afa2840c67369 (diff)
downloadclasspath-616d94e82c815801ba158e5e3731aa53905bbf1e.tar.gz
2006-03-17 Audrius Meskauskas <AudriusA@Bioinformatics.org>
* java/rmi/activation/Activatable.java: Implemented. java/rmi/activation/ActivationDesc.java: Implemented. java/rmi/activation/ActivationGroup.java: Implemented. java/rmi/activation/ActivationGroupDesc.java: Implemented. java/rmi/activation/ActivationID.java: Implemented. java/rmi/activation/ActivationSystem.java: Implemented. * gnu/java/rmi/server/UnicastServerRef.java (exportObject, incommingMessageCall): Documented. * java/rmi/activation/package.html: Documented. * java/rmi/server/ObjID.java (objNum, space): Made package protected. * gnu/java/rmi/server/UnicastServer.java: Rewritten. * gnu/java/rmi/server/CombinedClassLoader.java (constructor): Iteration bug fix. * gnu/java/rmi/activation/ActivationSystemTransient.java: New file. gnu/java/rmi/activation/BidiTable.java: New file. gnu/java/rmi/activation/DefaultActivationGroup.java: New file. gnu/java/rmi/activation/DefaultActivationSystem.java: New file. gnu/java/rmi/server/ActivatableServerRef.java: New file.
Diffstat (limited to 'gnu/java/rmi/server/ActivatableServerRef.java')
-rw-r--r--gnu/java/rmi/server/ActivatableServerRef.java146
1 files changed, 146 insertions, 0 deletions
diff --git a/gnu/java/rmi/server/ActivatableServerRef.java b/gnu/java/rmi/server/ActivatableServerRef.java
new file mode 100644
index 000000000..6463f40d2
--- /dev/null
+++ b/gnu/java/rmi/server/ActivatableServerRef.java
@@ -0,0 +1,146 @@
+/* ActivatableServerRef.java -- The activatable server reference
+ Copyright (C) 2006 Free Software Foundation, Inc.
+
+This file is part of GNU Classpath.
+
+GNU Classpath is free software; you can redistribute it and/or modify
+it under the terms of the GNU General Public License as published by
+the Free Software Foundation; either version 2, or (at your option)
+any later version.
+
+GNU Classpath is distributed in the hope that it will be useful, but
+WITHOUT ANY WARRANTY; without even the implied warranty of
+MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+General Public License for more details.
+
+You should have received a copy of the GNU General Public License
+along with GNU Classpath; see the file COPYING. If not, write to the
+Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
+02110-1301 USA.
+
+Linking this library statically or dynamically with other modules is
+making a combined work based on this library. Thus, the terms and
+conditions of the GNU General Public License cover the whole
+combination.
+
+As a special exception, the copyright holders of this library give you
+permission to link this library with independent modules to produce an
+executable, regardless of the license terms of these independent
+modules, and to copy and distribute the resulting executable under
+terms of your choice, provided that you also meet, for each linked
+independent module, the terms and conditions of the license of that
+module. An independent module is a module which is not derived from
+or based on this library. If you modify this library, you may extend
+this exception to your version of the library, but you are not
+obligated to do so. If you do not wish to do so, delete this
+exception statement from your version. */
+
+
+package gnu.java.rmi.server;
+
+import java.rmi.Remote;
+import java.rmi.RemoteException;
+import java.rmi.activation.ActivationID;
+import java.rmi.server.ObjID;
+import java.rmi.server.RMIServerSocketFactory;
+
+/**
+ * The activatable server reference works like UnicastServerReference, but it
+ * additionally activates the associated object on demand, during the first
+ * incoming call. When UnicastServerReference takes the working reference,
+ * the ActivatableServerRef takes the activation id instead.
+ *
+ * @author Audrius Meskauskas (Audriusa@Bioinformatics.org)
+ */
+public class ActivatableServerRef extends UnicastServerRef
+{
+ /**
+ * Use SVUID for interoperability
+ */
+ private static final long serialVersionUID = 1;
+
+ /**
+ * The object activation id.
+ */
+ public ActivationID actId;
+
+ /**
+ * Used by serialization only
+ */
+ public ActivatableServerRef()
+ {
+ super();
+ }
+
+ /**
+ * Create the new activatable server reference that will activate object on
+ * the first call using the given activation id.
+ */
+ public ActivatableServerRef(ObjID id, ActivationID anId, int aPort,
+ RMIServerSocketFactory ssFactory)
+ throws RemoteException
+ {
+ super(id, aPort, ssFactory);
+ actId = anId;
+
+ // The object ID will be placed in the object map and should deliver
+ // incoming call to {@link #incommingMessageCall}. The object itself
+ // is currently null.
+ UnicastServer.exportActivatableObject(this);
+ }
+
+ /**
+ * Inactivate the object (stop the server).
+ */
+ public void inactivate()
+ {
+ manager.stopServer();
+ }
+
+ /**
+ * Activate the object (normally during the first call).
+ */
+ protected void activate() throws RemoteException
+ {
+ try
+ {
+ Remote self = actId.activate(false);
+
+ // This will call UnicastServer.exportObject, replacing null by
+ // the activated object (self) in the object map.
+ exportObject(self);
+ }
+ catch (RemoteException rex)
+ {
+ throw rex;
+ }
+ catch (Exception exc)
+ {
+ RemoteException rx = new RemoteException("Activation failed.");
+ rx.initCause(exc);
+ throw rx;
+ }
+ }
+
+ /**
+ * If the object is not active, activate it first.
+ */
+ public Object incomingMessageCall(UnicastConnection conn, int method,
+ long hash) throws Exception
+ {
+ if (myself == null)
+ activate();
+ return super.incomingMessageCall(conn, method, hash);
+ }
+
+ /**
+ * Export object and ensure it is present in the server activation table
+ * as well.
+ */
+ public Remote exportObject(Remote obj) throws RemoteException
+ {
+ Remote r = super.exportObject(obj);
+ UnicastServer.registerActivatable(this);
+ return r;
+ }
+}