From 0ed2c1124cf1b9e49a2ec1fa0126a8df09f9e758 Mon Sep 17 00:00:00 2001
From: Andrew Branson <andrew.branson@cern.ch>
Date: Tue, 7 Oct 2014 09:18:11 +0200
Subject: Repackage to org.cristalise

---
 .../java/com/c2kernel/persistency/ProxyLoader.java | 158 ---------------------
 1 file changed, 158 deletions(-)
 delete mode 100644 src/main/java/com/c2kernel/persistency/ProxyLoader.java

(limited to 'src/main/java/com/c2kernel/persistency/ProxyLoader.java')

diff --git a/src/main/java/com/c2kernel/persistency/ProxyLoader.java b/src/main/java/com/c2kernel/persistency/ProxyLoader.java
deleted file mode 100644
index 88b6f03..0000000
--- a/src/main/java/com/c2kernel/persistency/ProxyLoader.java
+++ /dev/null
@@ -1,158 +0,0 @@
-/**
- * This file is part of the CRISTAL-iSE kernel.
- * Copyright (c) 2001-2014 The CRISTAL Consortium. All rights reserved.
- *
- * This library is free software; you can redistribute it and/or modify it
- * under the terms of the GNU Lesser General Public License as published
- * by the Free Software Foundation; either version 3 of the License, or (at
- * your option) any later version.
- *
- * This library is distributed in the hope that it will be useful, but WITHOUT
- * ANY WARRANTY; with out even the implied warranty of MERCHANTABILITY or
- * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public
- * License for more details.
- *
- * You should have received a copy of the GNU Lesser General Public License
- * along with this library; if not, write to the Free Software Foundation,
- * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
- *
- * http://www.fsf.org/licensing/licenses/lgpl.html
- */
-package com.c2kernel.persistency;
-import java.util.HashMap;
-import java.util.StringTokenizer;
-
-import com.c2kernel.common.ObjectNotFoundException;
-import com.c2kernel.common.PersistencyException;
-import com.c2kernel.entity.AgentHelper;
-import com.c2kernel.entity.C2KLocalObject;
-import com.c2kernel.entity.Item;
-import com.c2kernel.entity.ItemHelper;
-import com.c2kernel.lookup.ItemPath;
-import com.c2kernel.lookup.Lookup;
-import com.c2kernel.persistency.outcome.Outcome;
-import com.c2kernel.process.Gateway;
-import com.c2kernel.process.auth.Authenticator;
-import com.c2kernel.utils.Logger;
-
-/** Used by proxies to load clusters by queryData from the Entity.
-*   Last client storage - only used if not cached elsewhere
-*/
-
-public class ProxyLoader extends ClusterStorage {
-    HashMap<ItemPath, Item> entities = new HashMap<ItemPath, Item>();
-    Lookup lookup;
-
-    @Override
-	public void open(Authenticator auth) throws PersistencyException {
-        lookup = Gateway.getLookup();
-    }
-
-    @Override
-	public void close() throws PersistencyException {
-    }
-    // introspection
-    @Override
-	public short queryClusterSupport(String clusterType) {
-        return READ;
-    }
-
-    @Override
-	public String getName() {
-        return "Proxy Cluster Loader";
-    }
-
-    @Override
-	public String getId() {
-        return "CORBA";
-    }
-
-    // retrieve object by path
-    @Override
-	public C2KLocalObject get(ItemPath thisItem, String path) throws PersistencyException {
-        try {
-            Item thisEntity = getIOR(thisItem);
-            String type = getClusterType(path);
-
-            // fetch the xml from the item
-            String queryData = thisEntity.queryData(path);
-            if (Logger.doLog(6)) Logger.msg(6, "ProxyLoader - "+thisItem+":"+path+" = "+queryData);
-
-            if (queryData != null) {
-                if (type.equals(OUTCOME))
-                    return new Outcome(path, queryData);
-                else
-                    return (C2KLocalObject)Gateway.getMarshaller().unmarshall(queryData);
-            }
-        } catch (ObjectNotFoundException e) {
-        	return null;
-        } catch (Exception e) {
-            Logger.error(e);
-            throw new PersistencyException(e.getMessage());
-        }
-        return null;
-    }
-
-    // store object by path
-    @Override
-	public void put(ItemPath thisItem, C2KLocalObject obj) throws PersistencyException {
-        // not supported
-        throw new PersistencyException("Cannot write to items through the ProxyLoader");
-    }
-    // delete cluster
-    @Override
-	public void delete(ItemPath thisItem, String path) throws PersistencyException {
-        // not supported
-        throw new PersistencyException("Cannot write to items through the ProxyLoader");
-    }
-
-    /* navigation */
-
-    // directory listing
-    @Override
-	public String[] getClusterContents(ItemPath thisItem, String path) throws PersistencyException {
-        try {
-            Item thisEntity = getIOR(thisItem);
-            String contents = thisEntity.queryData(path+"/all");
-            StringTokenizer tok = new StringTokenizer(contents, ",");
-            String[] result = new String[tok.countTokens()];
-            for (int i=0; i<result.length; i++)
-                result[i] = tok.nextToken();
-
-            return result;
-        } catch (Exception e) {
-        	Logger.error(e);
-            throw new PersistencyException(e.getMessage());
-        }
-    }
-
-    private Item getIOR(ItemPath thisPath) throws PersistencyException {
-        if (entities.containsKey(thisPath)) {
-            // check the cache
-            Logger.msg(7, "ProxyLoader.getIOR() - "+thisPath+" cached.");
-            return entities.get(thisPath);
-        }
-
-        try {
-            Logger.msg(7, "ProxyLoader.getIOR() - Resolving "+thisPath+".");
-            org.omg.CORBA.Object ior = lookup.resolve(thisPath);
-
-            Item thisItem = null;
-            try {
-            	thisItem = ItemHelper.narrow(ior);
-            } catch (org.omg.CORBA.BAD_PARAM ex) {
-                try {
-                	thisItem =  AgentHelper.narrow(ior);
-                } catch (org.omg.CORBA.BAD_PARAM ex2) {
-                    throw new PersistencyException ("Could not narrow "+thisItem+" as a known Entity type");
-                }
-            }
-
-            Logger.msg(7, "ProxyLoader.getIOR() - Found "+thisItem+".");
-            entities.put(thisPath, thisItem);
-            return thisItem;
-        } catch (Exception e) {
-            throw new PersistencyException("Error narrowing "+thisPath+": "+e.getMessage());
-        }
-    }
-}
-- 
cgit v1.2.3