1 files changed, 158 insertions, 0 deletions
diff --git a/sca-java-1.x/tags/java-stable-20060304/sca/core/src/main/java/org/apache/tuscany/core/context/scope/AbstractScopeContext.java b/sca-java-1.x/tags/java-stable-20060304/sca/core/src/main/java/org/apache/tuscany/core/context/scope/AbstractScopeContext.java
new file mode 100644
index 0000000000..449af4bdf8
--- /dev/null
+++ b/sca-java-1.x/tags/java-stable-20060304/sca/core/src/main/java/org/apache/tuscany/core/context/scope/AbstractScopeContext.java
@@ -0,0 +1,158 @@
+/**
+ *
+ *  Copyright 2005 The Apache Software Foundation or its licensors, as applicable.
+ *
+ *  Licensed under the Apache License, Version 2.0 (the "License");
+ *  you may not use this file except in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing, software
+ *  distributed under the License is distributed on an "AS IS" BASIS,
+ *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ *  See the License for the specific language governing permissions and
+ *  limitations under the License.
+ */
+package org.apache.tuscany.core.context.scope;
+
+import java.util.List;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import org.apache.tuscany.core.builder.RuntimeConfiguration;
+import org.apache.tuscany.core.context.AbstractContext;
+import org.apache.tuscany.core.context.InstanceContext;
+import org.apache.tuscany.core.context.QualifiedName;
+import org.apache.tuscany.core.context.EventContext;
+import org.apache.tuscany.core.context.Context;
+import org.apache.tuscany.core.context.ScopeContext;
+import org.apache.tuscany.core.context.TargetException;
+
+/**
+ * Implements functionality common to scope contexts.
+ * <p>
+ * <b>NB: </b>Minimal synchronization is performed, particularly for initializing and destroying scopes, and it is
+ * assumed the scope container will block requests until these operations have completed.
+ * 
+ * @version $Rev$ $Date$
+ */
+public abstract class AbstractScopeContext  extends AbstractContext implements ScopeContext{
+    // ----------------------------------
+    // Fields
+    // ----------------------------------
+
+    // The collection of runtime configurations for the scope
+    protected Map<String, RuntimeConfiguration<InstanceContext>> runtimeConfigurations = new ConcurrentHashMap();
+
+    // The event context the scope container is associated with
+    protected EventContext eventContext;
+
+    // ----------------------------------
+    // Constructors
+    // ----------------------------------
+
+    public AbstractScopeContext(EventContext eventContext) {
+        assert (eventContext != null) : "Event context was null";
+        this.eventContext = eventContext;
+    }
+
+    // ----------------------------------
+    // Lifecycle methods
+    // --------------------------_--------
+
+    public synchronized void start() {
+    }
+
+    public synchronized void stop() {
+    }
+
+
+    // ----------------------------------
+    // Scope methods
+    // ----------------------------------
+
+    public void registerConfigurations(List<RuntimeConfiguration<InstanceContext>> configurations) {
+        for (RuntimeConfiguration<InstanceContext> configuration : configurations) {
+            runtimeConfigurations.put(configuration.getName(), configuration);
+        }
+    }
+
+    public Object getInstance(QualifiedName qName) throws TargetException {
+        Object instance = null;
+        InstanceContext context = getContext(qName.getPartName());
+        if (context == null) {
+            TargetException e = new TargetException("Target not found");
+            e.setIdentifier(qName.getQualifiedName());
+            throw e;
+        }
+        return context.getInstance(qName);
+    }
+
+    public Object getInstance(QualifiedName qName, boolean notify) throws TargetException {
+        return getInstance(qName);
+    }
+    
+    //----------------------------------
+    // InstanceContext methods
+    //----------------------------------
+
+    public Object getImplementationInstance() throws TargetException{
+        return this;
+    }
+
+    public Object getImplementationInstance(boolean notify) throws TargetException{
+        return this;
+    }
+    
+    // ----------------------------------
+    // Protected methods
+    // ----------------------------------
+
+    protected EventContext getEventContext() {
+        return eventContext;
+    }
+
+    /**
+     * Notfies instances that are associated with a context and configured to receive callbacks that the context is
+     * being destroyed in reverse order
+     * 
+     * @param key the context key
+     */
+    protected void notifyInstanceShutdown(Object key) {
+        InstanceContext[] contexts = getShutdownContexts(key);
+        if ((contexts == null) || (contexts.length < 1)) {
+            return;
+        }
+        // shutdown destroyable instances in reverse instantiation order
+        for (int i = contexts.length - 1; i >= 0; i--) {
+            InstanceContext context = contexts[i];
+
+            if (context.getLifecycleState() == Context.RUNNING) {
+                synchronized (context) {
+                    context.setLifecycleState(Context.STOPPING);
+                    removeContextByKey(context.getName(), key);
+                    try {
+                        context.stop();
+                    } catch (TargetException e) {
+                        // TODO send a monitoring event
+                        // log.error("Error releasing instance [" + context.getName() + "]",e);
+                    }
+                }
+            }
+        }
+    }
+
+    protected void checkInit() {
+        if (lifecycleState != RUNNING) {
+            throw new IllegalStateException("Scope not running [" + lifecycleState + "]");
+        }
+    }
+
+    /**
+     * Returns an array of contexts that need to be notified of scope shutdown. The array must be in the order in which
+     * component contexts were created
+     */
+    protected abstract InstanceContext[] getShutdownContexts(Object key);
+
+}