1 files changed, 162 insertions, 0 deletions
diff --git a/sca-java-2.x/tags/2.0.1-RC1/modules/interface-java/src/main/java/org/apache/tuscany/sca/interfacedef/java/impl/JavaInterfaceFactoryImpl.java b/sca-java-2.x/tags/2.0.1-RC1/modules/interface-java/src/main/java/org/apache/tuscany/sca/interfacedef/java/impl/JavaInterfaceFactoryImpl.java
new file mode 100644
index 0000000000..21c21e075d
--- /dev/null
+++ b/sca-java-2.x/tags/2.0.1-RC1/modules/interface-java/src/main/java/org/apache/tuscany/sca/interfacedef/java/impl/JavaInterfaceFactoryImpl.java
@@ -0,0 +1,162 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you 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.sca.interfacedef.java.impl;
+
+import java.lang.reflect.Method;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.Iterator;
+import java.util.List;
+import java.util.Map;
+import java.util.Set;
+import java.util.WeakHashMap;
+
+import org.apache.tuscany.sca.interfacedef.InvalidInterfaceException;
+import org.apache.tuscany.sca.interfacedef.java.JavaInterface;
+import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceContract;
+import org.apache.tuscany.sca.interfacedef.java.JavaInterfaceFactory;
+import org.apache.tuscany.sca.interfacedef.java.JavaOperation;
+import org.apache.tuscany.sca.interfacedef.java.introspect.JavaInterfaceVisitor;
+import org.oasisopen.sca.ServiceRuntimeException;
+
+/**
+ * A factory for the Java model.
+ *
+ * @version $Rev$ $Date$
+ */
+public abstract class JavaInterfaceFactoryImpl implements JavaInterfaceFactory {
+    
+    private List<JavaInterfaceVisitor> visitors = new ArrayList<JavaInterfaceVisitor>();
+    private JavaInterfaceIntrospectorImpl introspector;
+    private Map<Class<?>, JavaInterface> normalCache  = Collections.synchronizedMap(new WeakHashMap<Class<?>, JavaInterface>());
+    private Map<Class<?>, JavaInterface> forceRemotableCache  = Collections.synchronizedMap(new WeakHashMap<Class<?>, JavaInterface>());
+
+    public JavaInterfaceFactoryImpl() {
+        introspector = new JavaInterfaceIntrospectorImpl(this);
+    }
+
+    public JavaInterface createJavaInterface() {
+        return new JavaInterfaceImpl();
+    }
+
+    public JavaInterface createJavaInterface(Class<?> interfaceClass) throws InvalidInterfaceException {
+        return createJavaInterface(interfaceClass, false);
+    }
+
+    /**
+     * Creates a new Java interface model from an interface class.
+     *
+     * The forceRemotable argument allows the caller to force the interface to be remotable. 
+     * The ServiceProcessor and ReferenceProcessor introspectors use this argument to
+     * propagate a @Remotable annotation on an implementation class, field, or setter method
+     * to the corresponding service or reference interface.  The remotable flag must be set
+     * on the interface model prior to instrospection since some introspectors build
+     * different models for remotable vs local interfaces.  This also means separate caches
+     * must be kept for interfaces that are processed normally vs. those forced to be remotable.
+     */
+    public JavaInterface createJavaInterface(Class<?> interfaceClass, boolean forceRemotable) throws InvalidInterfaceException {
+        // TODO: Review if the sharing of JavaInterface is ok
+        synchronized (interfaceClass) {
+            Map<Class<?>, JavaInterface> cache = (forceRemotable ? forceRemotableCache : normalCache);
+            JavaInterface javaInterface = cache.get(interfaceClass);
+            if (javaInterface == null) {
+                javaInterface = createJavaInterface();
+                if (forceRemotable) {
+                   javaInterface.setRemotable(true);
+                }
+                introspector.introspectInterface(javaInterface, interfaceClass);
+                // Now that all introspection is complete we can mark the interface resolved
+                javaInterface.setUnresolved(false);
+                cache.put(interfaceClass, javaInterface);
+            }
+            return javaInterface;
+        }
+    }
+    
+    public void createJavaInterface(JavaInterface javaInterface, Class<?> interfaceClass) throws InvalidInterfaceException {
+        introspector.introspectInterface(javaInterface, interfaceClass);
+    }
+    
+    public JavaInterfaceContract createJavaInterfaceContract() {
+        return new JavaInterfaceContractImpl();
+    }
+
+    public void addInterfaceVisitor(JavaInterfaceVisitor extension) {
+        visitors.add(extension);
+    }
+
+    public void removeInterfaceVisitor(JavaInterfaceVisitor extension) {
+        visitors.remove(extension);
+    }
+
+    public List<JavaInterfaceVisitor> getInterfaceVisitors() {
+        return visitors;
+    }
+
+    public JavaOperation createJavaOperation(Method method) {
+        JavaOperation op =  new JavaOperationImpl();
+        op.setJavaMethod(method);
+        op.setName(method.getName());
+        return op;
+    }
+    
+    /**
+     * Removes all the cached information relating to a contribution. The 
+     * contribution is identified by the contribution classloader passed in 
+     * as a parameter. This is used when a contribution is removed from 
+     * the runtime. 
+     * 
+     * @param contributionClassloader
+     */
+    public void removeInterfacesForContribution(ClassLoader contributionClassloader){
+        removeInterfacesFromCache(contributionClassloader, normalCache);
+        removeInterfacesFromCache(contributionClassloader, forceRemotableCache);
+    }
+    
+    private void removeInterfacesFromCache(ClassLoader contributionClassloader, Map<Class<?>, JavaInterface> cache){
+        try {
+            synchronized(cache) {
+                Set<Class<?>> clsSet = cache.keySet();
+                Iterator<Class<?>> i = clsSet.iterator();
+                while (i.hasNext()) {
+                    Class<?> cls = i.next();
+                    if (cls.getClassLoader() == contributionClassloader) {
+                        i.remove();
+                    }
+                }
+            }
+        } catch(Exception e) {
+            throw new ServiceRuntimeException(e);
+        }
+    }
+    
+    /**
+     * For testing so we can check that the cache is being cleared
+     */
+    public Map<Class<?>, JavaInterface> getNormalCache(){
+        return normalCache;
+    }
+    
+    /**
+     * For testing so we can check that the cache is being cleared
+     */
+    public Map<Class<?>, JavaInterface> getForceRemotableCache(){
+        return forceRemotableCache;
+    }
+}