From 0ed2c1124cf1b9e49a2ec1fa0126a8df09f9e758 Mon Sep 17 00:00:00 2001 From: Andrew Branson Date: Tue, 7 Oct 2014 09:18:11 +0200 Subject: Repackage to org.cristalise --- src/main/java/com/c2kernel/utils/ActDefCache.java | 67 --- .../java/com/c2kernel/utils/CastorArrayList.java | 74 ---- .../java/com/c2kernel/utils/CastorHashMap.java | 101 ----- .../java/com/c2kernel/utils/CastorXMLUtility.java | 188 --------- src/main/java/com/c2kernel/utils/DateUtility.java | 138 ------- .../java/com/c2kernel/utils/DescriptionObject.java | 31 -- .../com/c2kernel/utils/DescriptionObjectCache.java | 104 ----- .../java/com/c2kernel/utils/FileStringUtility.java | 450 --------------------- .../com/c2kernel/utils/GTimeStampComparator.java | 45 --- src/main/java/com/c2kernel/utils/KeyValuePair.java | 107 ----- src/main/java/com/c2kernel/utils/Language.java | 86 ---- .../java/com/c2kernel/utils/LocalObjectLoader.java | 110 ----- src/main/java/com/c2kernel/utils/Logger.java | 206 ---------- .../java/com/c2kernel/utils/ObjectProperties.java | 215 ---------- src/main/java/com/c2kernel/utils/SoftCache.java | 139 ------- .../java/com/c2kernel/utils/StateMachineCache.java | 66 --- .../java/com/c2kernel/utils/TransientCache.java | 149 ------- src/main/java/com/c2kernel/utils/WeakCache.java | 154 ------- .../java/com/c2kernel/utils/XmlElementParser.java | 125 ------ .../c2kernel/utils/server/SimpleTCPIPServer.java | 129 ------ .../com/c2kernel/utils/server/SocketHandler.java | 35 -- 21 files changed, 2719 deletions(-) delete mode 100644 src/main/java/com/c2kernel/utils/ActDefCache.java delete mode 100644 src/main/java/com/c2kernel/utils/CastorArrayList.java delete mode 100644 src/main/java/com/c2kernel/utils/CastorHashMap.java delete mode 100644 src/main/java/com/c2kernel/utils/CastorXMLUtility.java delete mode 100644 src/main/java/com/c2kernel/utils/DateUtility.java delete mode 100644 src/main/java/com/c2kernel/utils/DescriptionObject.java delete mode 100644 src/main/java/com/c2kernel/utils/DescriptionObjectCache.java delete mode 100644 src/main/java/com/c2kernel/utils/FileStringUtility.java delete mode 100644 src/main/java/com/c2kernel/utils/GTimeStampComparator.java delete mode 100644 src/main/java/com/c2kernel/utils/KeyValuePair.java delete mode 100644 src/main/java/com/c2kernel/utils/Language.java delete mode 100644 src/main/java/com/c2kernel/utils/LocalObjectLoader.java delete mode 100644 src/main/java/com/c2kernel/utils/Logger.java delete mode 100644 src/main/java/com/c2kernel/utils/ObjectProperties.java delete mode 100644 src/main/java/com/c2kernel/utils/SoftCache.java delete mode 100644 src/main/java/com/c2kernel/utils/StateMachineCache.java delete mode 100644 src/main/java/com/c2kernel/utils/TransientCache.java delete mode 100644 src/main/java/com/c2kernel/utils/WeakCache.java delete mode 100644 src/main/java/com/c2kernel/utils/XmlElementParser.java delete mode 100644 src/main/java/com/c2kernel/utils/server/SimpleTCPIPServer.java delete mode 100644 src/main/java/com/c2kernel/utils/server/SocketHandler.java (limited to 'src/main/java/com/c2kernel/utils') diff --git a/src/main/java/com/c2kernel/utils/ActDefCache.java b/src/main/java/com/c2kernel/utils/ActDefCache.java deleted file mode 100644 index 785a50d..0000000 --- a/src/main/java/com/c2kernel/utils/ActDefCache.java +++ /dev/null @@ -1,67 +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.utils; - -import com.c2kernel.common.InvalidDataException; -import com.c2kernel.common.ObjectNotFoundException; -import com.c2kernel.common.PersistencyException; -import com.c2kernel.entity.proxy.ItemProxy; -import com.c2kernel.lifecycle.ActivityDef; -import com.c2kernel.persistency.ClusterStorage; -import com.c2kernel.persistency.outcome.Viewpoint; -import com.c2kernel.process.Gateway; - -public class ActDefCache extends DescriptionObjectCache { - - - @Override - public String getDefRoot() { - return "/desc/ActivityDesc"; - } - - @Override - public ActivityDef loadObject(String name, int version, ItemProxy proxy) throws ObjectNotFoundException, InvalidDataException { - ActivityDef thisActDef; - String actType = proxy.getProperty("Complexity"); - Viewpoint actView = (Viewpoint)proxy.getObject(ClusterStorage.VIEWPOINT + "/" + actType + "ActivityDef/" + version); - String marshalledAct; - try { - marshalledAct = actView.getOutcome().getData(); - } catch (PersistencyException ex) { - Logger.error(ex); - throw new ObjectNotFoundException("Problem loading "+name+" v"+version+": "+ex.getMessage()); - } - try { - thisActDef = (ActivityDef)Gateway.getMarshaller().unmarshall(marshalledAct); - thisActDef.getProperties().put("Version", version); - } catch (Exception ex) { - Logger.error(ex); - throw new InvalidDataException("Could not unmarshall '"+name+"' v"+version+": "+ex.getMessage()); - } - thisActDef.setName(name); - thisActDef.setVersion(version); - return thisActDef; - } - -} \ No newline at end of file diff --git a/src/main/java/com/c2kernel/utils/CastorArrayList.java b/src/main/java/com/c2kernel/utils/CastorArrayList.java deleted file mode 100644 index bd9799f..0000000 --- a/src/main/java/com/c2kernel/utils/CastorArrayList.java +++ /dev/null @@ -1,74 +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.utils; - -import java.util.ArrayList; - -/************************************************************************** - * Wrapper for a root element to an ArrayList. Castor Marshalls arraylists - * as multiple elements, so this class is needed to provide a root element - * to stop it crashing. - * - * $Revision: 1.4 $ - * $Date: 2004/01/22 11:17:42 $ - * - * Copyright (C) 2003 CERN - European Organization for Nuclear Research - * All rights reserved. - **************************************************************************/ -// -abstract public class CastorArrayList { - public ArrayList list; - - public CastorArrayList() { - super(); - list = new ArrayList(); - } - - @Override - public int hashCode() { - final int prime = 31; - int result = 1; - result = prime * result + ((list == null) ? 0 : list.hashCode()); - return result; - } - - @Override - public boolean equals(Object obj) { - if (this == obj) - return true; - if (obj == null) - return false; - if (getClass() != obj.getClass()) - return false; - CastorArrayList other = (CastorArrayList) obj; - if (list == null) { - if (other.list != null) - return false; - } else if (!list.equals(other.list)) - return false; - return true; - } - - public CastorArrayList(ArrayList list) { - this(); - this.list = list; - } -} diff --git a/src/main/java/com/c2kernel/utils/CastorHashMap.java b/src/main/java/com/c2kernel/utils/CastorHashMap.java deleted file mode 100644 index aed3a3d..0000000 --- a/src/main/java/com/c2kernel/utils/CastorHashMap.java +++ /dev/null @@ -1,101 +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.utils; - -import java.util.ArrayList; -import java.util.HashMap; -import java.util.Iterator; - - -// This subclass of hashtable can be marshalled -// and unmarshalled with Castor -public class CastorHashMap extends HashMap -{ - public CastorHashMap() - { - clear(); - } - - ArrayList abstractPropNames = new ArrayList(); - - public KeyValuePair[] getKeyValuePairs() - { - int numKeys = size(); - - KeyValuePair[] keyValuePairs = new KeyValuePair[numKeys]; - Iterator keyIter = keySet().iterator(); - int i = 0; - - for(i=0; i(); - } - - - public void setKeyValuePair(KeyValuePair keyValuePair) - { - put(keyValuePair.getKey(), keyValuePair.getValue()); - if (keyValuePair.isAbstract()) - abstractPropNames.add(keyValuePair.getKey()); - else - abstractPropNames.remove(keyValuePair.getKey()); - } - - public ArrayList getAbstract() { - return abstractPropNames; - } - - - public void put(String key, Object value, boolean isAbstract) { - super.put(key, value); - if (isAbstract) - abstractPropNames.add(key); - else - abstractPropNames.remove(key); - - } -} diff --git a/src/main/java/com/c2kernel/utils/CastorXMLUtility.java b/src/main/java/com/c2kernel/utils/CastorXMLUtility.java deleted file mode 100644 index a084ea9..0000000 --- a/src/main/java/com/c2kernel/utils/CastorXMLUtility.java +++ /dev/null @@ -1,188 +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.utils; - -//Java -import java.io.IOException; -import java.io.StringReader; -import java.io.StringWriter; -import java.net.MalformedURLException; -import java.net.URL; -import java.util.HashSet; -import java.util.Properties; -import java.util.StringTokenizer; - -import org.exolab.castor.mapping.Mapping; -import org.exolab.castor.mapping.MappingException; -import org.exolab.castor.xml.MarshalException; -import org.exolab.castor.xml.Marshaller; -import org.exolab.castor.xml.Unmarshaller; -import org.exolab.castor.xml.ValidationException; -import org.exolab.castor.xml.XMLContext; - -import com.c2kernel.common.InvalidDataException; -import com.c2kernel.persistency.outcome.Outcome; -import com.c2kernel.process.resource.ResourceLoader; - - -/************************************************************************** - * Loads all mapfiles, and wraps marshalling/unmarshalling - * - * @author $Author: abranson $ $Date: 2004/10/20 14:10:21 $ - * @version $Revision: 1.12 $ - **************************************************************************/ -public class CastorXMLUtility -{ - - public static final String CASTOR_XML_SERIALIZER_FACTORY = "org.exolab.castor.xml.serializer.factory"; - private XMLContext mappingContext; - - /** - * Looks for a file called 'index.xml' at the given URL, and loads every - * file listed in there by relative path - * - * @param aResourceLoader - * the resource loader able to return the right class loader - * @param aAppProperties - * the application properties containing optional castor - * configuration - * @param mapURL - * the root URL for the mapfiles - * @throws InvalidDataException - */ - public CastorXMLUtility(final ResourceLoader aResourceLoader, - final Properties aAppProperties, final URL mapURL) - throws InvalidDataException { - - - // load index - Logger.msg(3,String.format( "CastorXMLUtility. Loading maps from [%s]",mapURL)); - String index; - try { - index = FileStringUtility.url2String( new URL(mapURL, "index") ); - } catch (Exception e) { - throw new InvalidDataException(String.format("Could not load map index from [%s]",mapURL)); - } - - // retrieve the class loader of the class "CastorXMLUtility" - ClassLoader defaultClassLoader = aResourceLoader - .getClassLoader(CastorXMLUtility.class.getName()); - - Logger.msg(3, String.format( - "CastorXMLUtility.: defaultClassLoader=[%s]", - defaultClassLoader)); - - - StringTokenizer sTokenizer = new StringTokenizer(index); - int wNbMap = sTokenizer.countTokens(); - - // init the castor mapping using the classloader of the class "CastorXMLUtility" - Mapping thisMapping = new Mapping(defaultClassLoader); - HashSet loadedMapURLs = new HashSet(); - try { - int wMapIdx=0; - while( sTokenizer.hasMoreTokens() ) { - String thisMap = sTokenizer.nextToken(); - String thisMapURL = new URL(mapURL, thisMap).toString(); - wMapIdx++; - if( !loadedMapURLs.contains(thisMapURL) ) { - Logger.msg( 3, - String.format("CastorXMLUtility.: Adding mapping file (%d/%d):[%s]", wMapIdx, wNbMap, thisMapURL)); - thisMapping.loadMapping( new URL(thisMapURL) ); - loadedMapURLs.add( thisMapURL ); - } - else { - Logger.msg(3,"Map file already loaded:"+thisMapURL); - } - } - - mappingContext = new XMLContext(); - - mappingContext.setClassLoader(defaultClassLoader); - - // if the aAppProperties contains castor properties then - if (aAppProperties!= null && aAppProperties.containsKey(CASTOR_XML_SERIALIZER_FACTORY)) { - - mappingContext.setProperty(CASTOR_XML_SERIALIZER_FACTORY, - aAppProperties - .getProperty(CASTOR_XML_SERIALIZER_FACTORY)); - - Logger.msg(3, String.format( - "CastorXMLUtility.: castor prop: %s=[%s]", - CASTOR_XML_SERIALIZER_FACTORY, mappingContext - .getProperty(CASTOR_XML_SERIALIZER_FACTORY))); - - } - - mappingContext.addMapping(thisMapping); - } catch (MappingException ex) { - Logger.error(ex); - throw new InvalidDataException("XML Mapping files are not valid: "+ex.getMessage()); - } catch (MalformedURLException ex) { - Logger.error(ex); - throw new InvalidDataException("Mapping file location invalid: "+ex.getMessage()); - } catch (IOException ex) { - Logger.error(ex); - throw new InvalidDataException("Could not read XML mapping files: "+ex.getMessage()); - } - - Logger.msg(1, String.format("Loaded [%d] maps from [%s]", loadedMapURLs.size(), mapURL)); - } - - /************************************************************************** - * Marshalls a mapped object to string. The mapping must be loaded before. - * See updateMapping(). - **************************************************************************/ - public String marshall( Object obj ) - throws IOException, - MappingException, - MarshalException, - ValidationException - { - if (obj == null) return ""; - if (obj instanceof Outcome) - return ((Outcome)obj).getData(); - StringWriter sWriter = new StringWriter(); - Marshaller marshaller = mappingContext.createMarshaller(); - - marshaller.setWriter(sWriter); - marshaller.setMarshalAsDocument( false ); - marshaller.marshal( obj ); - - return sWriter.toString(); - } - - /************************************************************************** - * Unmarshalls a mapped object from string. The mapping must be loaded before. - * See updateMapping(). - **************************************************************************/ - public Object unmarshall( String data ) - throws IOException, - MappingException, - MarshalException, - ValidationException - { - if (data.equals("")) return null; - StringReader sReader = new StringReader( data ); - Unmarshaller unmarshaller = mappingContext.createUnmarshaller(); - return unmarshaller.unmarshal( sReader ); - } -} diff --git a/src/main/java/com/c2kernel/utils/DateUtility.java b/src/main/java/com/c2kernel/utils/DateUtility.java deleted file mode 100644 index 09ee195..0000000 --- a/src/main/java/com/c2kernel/utils/DateUtility.java +++ /dev/null @@ -1,138 +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.utils; -import com.c2kernel.common.GTimeStamp; -/** - * @version $Revision: 1.8 $ $Date: 2005/05/10 15:14:55 $ - * @author $Author: abranson $ - */ -public class DateUtility -{ - public static GTimeStamp setToNow(GTimeStamp date) - { - java.util.Calendar now = java.util.Calendar.getInstance(); - date.mYear = now.get(java.util.Calendar.YEAR); - date.mMonth = now.get(java.util.Calendar.MONTH) + 1; - date.mDay = now.get(java.util.Calendar.DAY_OF_MONTH); - date.mHour = now.get(java.util.Calendar.HOUR_OF_DAY); - date.mMinute = now.get(java.util.Calendar.MINUTE); - date.mSecond = now.get(java.util.Calendar.SECOND); - date.mTimeOffset = now.get(java.util.Calendar.ZONE_OFFSET); - return date; - } - - public static String getSQLFormat(GTimeStamp timeStamp) - { - StringBuffer time = new StringBuffer().append(timeStamp.mYear).append("-"); - if (timeStamp.mMonth < 10) - time.append("0"); - time.append(timeStamp.mMonth).append("-"); - if (timeStamp.mDay < 10) - time.append("0"); - time.append(timeStamp.mDay).append(" "); - if (timeStamp.mHour < 10) - time.append("0"); - time.append(timeStamp.mHour).append(":"); - if (timeStamp.mMinute < 10) - time.append("0"); - time.append(timeStamp.mMinute).append(":"); - if (timeStamp.mSecond < 10) - time.append("0"); - time.append(timeStamp.mSecond); - return time.toString(); - } - - public static int getNbDayInYear(GTimeStamp date) - { - int centuary = date.mYear / 100; - int cdivby4 = centuary / 4; - int ydivby4 = date.mYear / 4; - if (centuary * 100 - date.mYear == 0) - { - if (centuary == cdivby4 * 4) - return 366; - else - return 365; - } - else if (date.mYear == ydivby4 * 4) - return 366; - else - return 365; - } - public static int getNbDayInMonth(GTimeStamp date) - { - switch (date.mMonth) - { - case 2 : - if (getNbDayInYear(date) == 365) - return 28; - else - return 29; - case 4 : - return 30; - case 6 : - return 30; - case 9 : - return 30; - case 11 : - return 30; - default : - return 31; - } - } - - public static long diff(GTimeStamp date1, GTimeStamp date2) - { - GTimeStamp tmp = new GTimeStamp(date1.mYear, date1.mMonth, date1.mDay, date1.mHour, date1.mMinute, date1.mSecond, date1.mTimeOffset); - while (tmp.mYear - date2.mYear < 0) - { - while (tmp.mMonth < 13) - { - tmp.mDay = tmp.mDay - getNbDayInMonth(tmp); - tmp.mMonth++; - } - tmp.mMonth = 1; - tmp.mYear++; - } - while (tmp.mYear - date2.mYear > 0) - { - while (tmp.mMonth > 1) - { - tmp.mMonth--; - tmp.mDay = tmp.mDay + getNbDayInMonth(tmp); - } - tmp.mMonth = 12; - tmp.mDay = tmp.mDay + getNbDayInMonth(tmp); - tmp.mYear--; - } - while (tmp.mMonth - date2.mMonth < 0) - { - tmp.mDay = tmp.mDay - getNbDayInMonth(tmp); - tmp.mMonth++; - } - while (tmp.mMonth - date2.mMonth > 0) - { - tmp.mMonth--; - tmp.mDay = tmp.mDay + getNbDayInMonth(tmp); - } - return (((tmp.mDay - date2.mDay) * 24 + tmp.mHour - date2.mHour) * 60 + tmp.mMinute - date2.mMinute) * 60 + tmp.mSecond - date2.mSecond; - } -} diff --git a/src/main/java/com/c2kernel/utils/DescriptionObject.java b/src/main/java/com/c2kernel/utils/DescriptionObject.java deleted file mode 100644 index 25db952..0000000 --- a/src/main/java/com/c2kernel/utils/DescriptionObject.java +++ /dev/null @@ -1,31 +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.utils; - -public interface DescriptionObject { - - public String getName(); - public int getVersion(); - - public void setName(String name); - public void setVersion(int version); - -} diff --git a/src/main/java/com/c2kernel/utils/DescriptionObjectCache.java b/src/main/java/com/c2kernel/utils/DescriptionObjectCache.java deleted file mode 100644 index d3eb5ec..0000000 --- a/src/main/java/com/c2kernel/utils/DescriptionObjectCache.java +++ /dev/null @@ -1,104 +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.utils; - -import com.c2kernel.common.InvalidDataException; -import com.c2kernel.common.ObjectNotFoundException; -import com.c2kernel.entity.proxy.ProxyObserver; -import com.c2kernel.entity.proxy.ItemProxy; -import com.c2kernel.entity.proxy.MemberSubscription; -import com.c2kernel.persistency.ClusterStorage; -import com.c2kernel.persistency.outcome.Viewpoint; - -public abstract class DescriptionObjectCache { - - SoftCache> cache = new SoftCache>(); - - public D get(String name, int version) throws ObjectNotFoundException, InvalidDataException { - D thisDef; - synchronized(cache) { - CacheEntry thisDefEntry = cache.get(name+"_"+version); - if (thisDefEntry == null) { - Logger.msg(6, name+" v"+version+" not found in cache. Retrieving."); - ItemProxy defItem = LocalObjectLoader.loadLocalObjectDef(getDefRoot(), name); - thisDef = loadObject(name, version, defItem); - cache.put(name+"_"+version, new CacheEntry(thisDef, defItem, this)); - } - else { - Logger.msg(6, name+" v"+version+" found in cache."); - thisDef = thisDefEntry.def; - } - } - return thisDef; - } - - public abstract String getDefRoot(); - - public abstract D loadObject(String name, int version, ItemProxy proxy) throws ObjectNotFoundException, InvalidDataException; - - public void removeObject(String id) { - synchronized(cache) { - if (cache.keySet().contains(id)) { - Logger.msg(7, "ActDefCache: Removing activity def "+id+" from cache"); - cache.remove(id); - } - } - } - - public class CacheEntry implements ProxyObserver { - public String id; - public ItemProxy proxy; - public E def; - public DescriptionObjectCache parent; - public CacheEntry(E def, ItemProxy proxy, DescriptionObjectCache parent) { - this.id = def.getName()+"_"+def.getVersion(); - this.def = def; - this.parent = parent; - this.proxy = proxy; - proxy.subscribe(new MemberSubscription(this, ClusterStorage.VIEWPOINT, false)); - } - @Override - public void finalize() { - parent.removeObject(id); - proxy.unsubscribe(this); - } - @Override - public void add(Viewpoint contents) { - parent.removeObject(id); - } - - @Override - public void remove(String oldId) { - parent.removeObject(oldId); - } - - @Override - public String toString() { - return "Cache entry: "+id; - } - @Override - public void control(String control, String msg) { - } - } -} \ No newline at end of file diff --git a/src/main/java/com/c2kernel/utils/FileStringUtility.java b/src/main/java/com/c2kernel/utils/FileStringUtility.java deleted file mode 100644 index 8361726..0000000 --- a/src/main/java/com/c2kernel/utils/FileStringUtility.java +++ /dev/null @@ -1,450 +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.utils; - -//Java -import java.io.BufferedReader; -import java.io.BufferedWriter; -import java.io.File; -import java.io.FileInputStream; -import java.io.FileNotFoundException; -import java.io.FileReader; -import java.io.FileWriter; -import java.io.IOException; -import java.io.InputStream; -import java.io.InputStreamReader; -import java.lang.reflect.Array; -import java.net.MalformedURLException; -import java.net.URL; -import java.util.ArrayList; -import java.util.Hashtable; -import java.util.StringTokenizer; -import java.util.Vector; - -/************************************************************************** - * - * @author $Author: abranson $ $Date: 2004/10/20 14:10:21 $ - * @version $Revision: 1.31 $ - **************************************************************************/ -public class FileStringUtility -{ - /************************************************************************** - * Reads a file and converts it to String - **************************************************************************/ - static public String file2String(File file) throws FileNotFoundException, IOException - { - FileInputStream fis = new FileInputStream(file); - byte[] bArray = (byte[]) Array.newInstance(byte.class, (int) file.length()); - Logger.msg(8, "FileStringUtility.file2String() - Reading file '" + file.getAbsolutePath()+"'"); - - fis.read(bArray, 0, (int) file.length()); - fis.close(); - - Logger.msg(9, "FileStringUtility.file2String() - file '" + file.getAbsolutePath() + "' read."); - - return new String(bArray); - } - - /************************************************************************** - * Reads a file and converts it to String - **************************************************************************/ - static public String file2String(String fileName) throws FileNotFoundException, IOException - { - return file2String(new File(fileName)); - } - - /************************************************************************** - * Reads a file and converts it to String - **************************************************************************/ - static public String url2String(java.net.URL location) throws IOException - { - BufferedReader in = new BufferedReader(new InputStreamReader(location.openStream(), "UTF-8")); - StringBuffer strbuf = new StringBuffer(); - String line = in.readLine(); - while (line != null) { - strbuf.append(line).append('\n'); - line = in.readLine(); - } - return strbuf.toString(); - } - - /************************************************************************** - * Reads a file and converts each line to String[] - **************************************************************************/ - static public String[] file2StringArray(File file) throws FileNotFoundException, IOException - { - FileReader fr = new FileReader(file); - BufferedReader buf = new BufferedReader(fr); - Vector lines = new Vector(); - String thisLine = null; - while ((thisLine = buf.readLine()) != null) - lines.addElement(thisLine); - buf.close(); - String[] lineArray = new String[lines.size()]; - for (int i = 0; i < lines.size(); i++) - lineArray[i] = lines.get(i); - return lineArray; - } - - /************************************************************************** - * Reads a file and converts it to String[] - **************************************************************************/ - static public String[] file2StringArray(String fileName) throws FileNotFoundException, IOException - { - return file2StringArray(new File(fileName)); - } - - /************************************************************************** - * Saves a string to a text file - **************************************************************************/ - static public void string2File(File file, String data) throws FileNotFoundException, IOException - { - FileWriter thisFile = new FileWriter(file); - BufferedWriter thisFileBuffer = new BufferedWriter(thisFile); - - Logger.msg(9, "FileStringUtility.string2File() - writing file '" + file.getAbsolutePath()+"'"); - - thisFileBuffer.write(data); - thisFileBuffer.close(); - - Logger.msg(9, "FileStringUtility.string2File() - file '" + file.getAbsolutePath() + "' complete."); - } - - /************************************************************************** - * Saves a string to a text file - **************************************************************************/ - static public void string2File(String fileName, String data) throws FileNotFoundException, IOException - { - string2File(new File(fileName), data); - } - - /************************************************************************** - * checks for existing directory - **************************************************************************/ - static public boolean checkDir(String dirPath) - { - File dir = new File(dirPath); - - if (dir.isFile()) - { - Logger.error("FileStringUtility.checkDir() - '" + dir.getAbsolutePath() + "' is a file."); - return false; - } - else if (!dir.exists()) - { - Logger.msg(9, "FileStringUtility.checkDir() - directory '" + dir.getAbsolutePath() + "' does not exist."); - return false; - } - - return true; - } - - /************************************************************************** - * creating a new directory - **************************************************************************/ - static public boolean createNewDir(String dirPath) - { - File dir = new File(dirPath); - - if (dir.isFile()) - { - Logger.error("FileStringUtility.createNewDir() - '" + dir.getAbsolutePath() + "' is a file."); - return false; - } - else if (dir.exists()) - { - Logger.msg(8, "FileStringUtility.createNewDir() - '" + dir.getAbsolutePath() + "' already exists."); - return false; - } - else - { - if (!dir.mkdirs()) - { - Logger.error("FileStringUtility - Could not create new directory '" + dir.getAbsolutePath() + "'"); - return false; - } - } - return true; - } - - /************************************************************************** - * deleting a existing directory - **************************************************************************/ - static public boolean deleteDir(String dirPath) - { - File dir = new File(dirPath); - - if (!checkDir(dirPath)) - { - Logger.msg(8, "FileStringUtility.deleteDir() - directory '" + dir.getAbsolutePath() + "' does not exist."); - return false; - } - - if (!dir.delete()) - { - //prints the possible reason - if (dir.list().length != 0) - { - Logger.error("FileStringUtility.deleteDir() - cannot delete non-empty directory '" + dir.getAbsolutePath() + "'"); - } - else - { - Logger.error("FileStringUtility.deleteDir() - directory '" + dir.getAbsolutePath() + "' could not be deleted."); - } - return false; - } - - return true; - } - - /************************************************************************** - * deleting a existing directory with its structure - * - * @param dirPath the directory which should be deleted - * @param force if true forces to delete the entry (ie. the dirPath) even if - * it is a file - * @param recursive if true deletes the complete directory structure - **************************************************************************/ - static public boolean deleteDir(String dirPath, boolean force, boolean recursive) - { - File dir = new File(dirPath); - File files[]; - - if (!dir.exists()) - { - Logger.error("FileStringUtility.deleteDir() - directory '" + dir.getAbsolutePath() + "' does not exist."); - return false; - } - - if (dir.isFile()) - { - - if (force) - { //delete the entry even if it is a file - dir.delete(); - return true; - } - else - { - Logger.error("FileStringUtility.deleteDir() - '" + dir.getAbsolutePath() + "' was a file."); - return false; - } - } - - if (recursive) - { - files = dir.listFiles(); - - for (File file : files) - deleteDir(file.getAbsolutePath(), true, true); - } - - return deleteDir(dirPath); - } - - /************************************************************************** - * List all file names in the directory recursively, relative to the - * starting directory. - * - * @param dirPath starting directory - * @param recursive goes into the subdirectories - **************************************************************************/ - static public ArrayList listDir(String dirPath, boolean withDirs, boolean recursive) - { - ArrayList fileNames = new ArrayList(); - File dir = new File(dirPath); - File files[]; - String fileName; - - if (!checkDir(dirPath)) - { - Logger.msg(8, "FileStringUtility.listDir() - directory '" + dir.getAbsolutePath() + "' does not exist."); - return null; - } - - files = dir.listFiles(); - - for (File file : files) { - fileName = file.getName(); - - if (file.isFile()) - { - fileNames.add(dirPath + "/" + fileName); - } - else - { - if (recursive) - fileNames.addAll(listDir(dirPath + "/" + fileName, withDirs, recursive)); - - if (withDirs) - fileNames.add(dirPath + "/" + fileName); - } - } - - return fileNames; - } - - /************************************************************************** - * Open a URL or File as an InputStream - **************************************************************************/ - static public InputStream openTextStream(String source) - { - java.io.InputStream in = null; - java.net.URL url = null; - - // Try to open URL connection first - try - { - try - { - url = new URL(source); - in = url.openStream(); - } - catch (MalformedURLException e) - { - // Try to open plain file, if `configFile' is not a - // URL specification - in = new FileInputStream(source); - } - } - catch (java.io.IOException ex) - { - Logger.error("FileStringUtility.openTextStream() - could not load text stream:" + source); - } - return in; - } - - /************************************************************************** - * Load the contents of the configuration file - **************************************************************************/ - static public java.util.Properties loadConfigFile(String configFile) - { - java.io.BufferedInputStream bin = null; - java.io.InputStream in = openTextStream(configFile); - java.util.Properties props = new java.util.Properties(); - - if (in != null) - { - try - { - bin = new java.io.BufferedInputStream(in); - props.load(bin); - in.close(); - } - catch (IOException ex) - { - Logger.error("FileStringUtility.loadConfigFile() - could not load configuration file '" + configFile+"'"); - } - } - return props; - } - - /************************************************************************** - * Load the contents of the language file - * *************************************************************************/ - static public Hashtable loadLanguageFile(String configFile) - { - try - { - String language = FileStringUtility.file2String(configFile); - Hashtable props = new Hashtable(); - StringTokenizer tok = new StringTokenizer(language, "\n"); - while (tok.hasMoreTokens()) - { - String t = tok.nextToken(); - int sep = t.indexOf("="); - if (sep >0)props.put(t.substring(0,sep),t.substring(sep+1)); - } - return props; - } - catch (Exception e) - { - Logger.error("FileStringUtility.loadLanguageFile() - could not load language file '" + configFile+"'"); - Logger.error(e); - return new Hashtable(); - } - - } - - /************************************************************************** - * Load the contents of the configuration file - **************************************************************************/ - static public void appendConfigFile(java.util.Properties props, String configFile) - { - java.io.BufferedInputStream bin = null; - java.io.InputStream in = openTextStream(configFile); - - if (in != null) - { - try - { - bin = new java.io.BufferedInputStream(in); - props.load(bin); - in.close(); - } - catch (java.io.IOException ex) - { - Logger.error("FileStringUtility.appendConfigFile() - could not append configuration file '" + configFile+"'"); - } - } - } - public static String convert(String init) - { - if (init==null) return null; - return init - .replace('\'', '_') - .replace('\\', '_') - .replace('/', '_') - .replace('\"', '_') - .replace(':', '_') - .replace('*', '_') - .replace('?', '_') - .replace('<', '_') - .replace('>', '_') - .replace('|', '_') - .replace('(', '[') - .replace(')', ']') - .replace(',','_'); } - public static String replaceall(String src,String from,String to) - { - StringBuffer tmp=new StringBuffer(src); - int length = from.length(); - int index = tmp.toString().indexOf(from); - while (index>0) - { - tmp.replace(index,index+length,to); - index = tmp.toString().indexOf(from); - } - return tmp.toString(); - } - public static String toAlphaNum(String source) - { - byte[] sourceb = source.getBytes(); - for (int i=0;i'9'&&sourceb[i]<'A')||(sourceb[i]>'Z'&&sourceb[i]<'_')||sourceb[i]>'z') - sourceb[i]='_'; - } - return new String(sourceb); - - } - -} diff --git a/src/main/java/com/c2kernel/utils/GTimeStampComparator.java b/src/main/java/com/c2kernel/utils/GTimeStampComparator.java deleted file mode 100644 index 641f6fa..0000000 --- a/src/main/java/com/c2kernel/utils/GTimeStampComparator.java +++ /dev/null @@ -1,45 +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.utils; - -import java.util.Comparator; - -import com.c2kernel.common.GTimeStamp; - -public class GTimeStampComparator implements Comparator { - - @Override - public int compare(GTimeStamp t0, GTimeStamp t1) { - - int retVal = compareInt(t0.mYear, t1.mYear); - if (retVal == 0) retVal = compareInt(t0.mMonth, t1.mMonth); - if (retVal == 0) retVal = compareInt(t0.mDay, t1.mDay); - if (retVal == 0) retVal = compareInt(t0.mHour-(t0.mTimeOffset/3600), t1.mHour-(t1.mTimeOffset/3600)); - if (retVal == 0) retVal = compareInt(t0.mMinute, t1.mMinute); - if (retVal == 0) retVal = compareInt(t0.mSecond, t1.mSecond); - - return retVal; - } - - private static int compareInt(int i, int j) { - return i-j; - } -} diff --git a/src/main/java/com/c2kernel/utils/KeyValuePair.java b/src/main/java/com/c2kernel/utils/KeyValuePair.java deleted file mode 100644 index 0a6278b..0000000 --- a/src/main/java/com/c2kernel/utils/KeyValuePair.java +++ /dev/null @@ -1,107 +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.utils; - - -public class KeyValuePair -{ - private String mKey = null; - private Object mValue = null; - private boolean mAbstract = false; - - public KeyValuePair() {} - - public KeyValuePair(String key, Object value, boolean isAbstract) - { - mKey = key; - mValue = value; - mAbstract = isAbstract; - } - - public String getKey() { - return mKey; - } - - public void setKey(String key) { - mKey = key; - } - - public Object getValue() { - return mValue; - } - - public void setValue(Object value) { - mValue = value; - } - - public void setAbstract(boolean isAbstract) { - mAbstract = isAbstract; - } - - public boolean isAbstract() { - return mAbstract; - } - - public String getStringValue() { - if (mValue instanceof String) - return (String)mValue; - else - return null; - } - - public void setStringValue(String value) { - mValue = value; - } - - public Integer getIntegerValue() { - if (mValue instanceof Integer) - return (Integer)mValue; - else - return null; - } - - public void setIntegerValue(Integer value) { - mValue = value; - } - - public Boolean getBooleanValue() { - if (mValue instanceof Boolean) - return (Boolean)mValue; - else - return null; - } - - public void setBooleanValue(Boolean value) { - mValue = value; - } - - public Double getFloatValue() { - if (mValue instanceof Double) - return (Double)mValue; - else - return null; - } - - public void setFloatValue(Double value) { - mValue = value; - } - -} diff --git a/src/main/java/com/c2kernel/utils/Language.java b/src/main/java/com/c2kernel/utils/Language.java deleted file mode 100644 index 540cf54..0000000 --- a/src/main/java/com/c2kernel/utils/Language.java +++ /dev/null @@ -1,86 +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.utils; - -import java.util.Enumeration; -import java.util.Hashtable; - -/************************************************************************** - * - * @author $Author: sgaspard $ $Date: 2004/09/21 13:17:40 $ - * @version $Revision: 1.9 $ - **************************************************************************/ - -public class Language -{ - public static Hashtable mTableOfTranslation = new Hashtable(); - public static Hashtable mTableOfUntranslated = new Hashtable(); - public static boolean isTranlated=false; - private Hashtable tableOfTranslation = new Hashtable(); - - public static String translate(String english) - { - if (!isTranlated) return english; - String rep = english; - if (rep != null && !rep.equals("")) { - String translated = (String) mTableOfTranslation.get(english); - if (translated != null) return translated; - else - { - mTableOfUntranslated.put(english,""); - try - { - String s = ""; - Enumeration e = mTableOfUntranslated.keys(); - while (e.hasMoreElements()) s =s+"\n"+e.nextElement(); - FileStringUtility.string2File("untranslated.txt",s); - } - catch (Exception ex) - { - Logger.warning("Could not write to preferences file. Preferences have not been updated."); - } - } - - } - return rep; - } - - public Language(String filePath) - { - String languageFile = filePath; - if (languageFile == null || languageFile.length() == 0) - // no language file defined for this process - return; - tableOfTranslation = FileStringUtility.loadLanguageFile(languageFile); - } - public String insTranslate(String english) - { - String rep = english; - if (rep != null && !rep.equals("")) { - String translated = (String) tableOfTranslation.get(english); - if (translated != null) - rep = translated; - } - return rep; - } - - -} diff --git a/src/main/java/com/c2kernel/utils/LocalObjectLoader.java b/src/main/java/com/c2kernel/utils/LocalObjectLoader.java deleted file mode 100644 index 186b599..0000000 --- a/src/main/java/com/c2kernel/utils/LocalObjectLoader.java +++ /dev/null @@ -1,110 +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.utils; - -import java.util.Iterator; - -import com.c2kernel.common.InvalidDataException; -import com.c2kernel.common.ObjectNotFoundException; -import com.c2kernel.common.PersistencyException; -import com.c2kernel.entity.proxy.ItemProxy; -import com.c2kernel.lifecycle.ActivityDef; -import com.c2kernel.lifecycle.instance.stateMachine.StateMachine; -import com.c2kernel.lookup.DomainPath; -import com.c2kernel.lookup.Path; -import com.c2kernel.persistency.ClusterStorage; -import com.c2kernel.persistency.outcome.Schema; -import com.c2kernel.persistency.outcome.Viewpoint; -import com.c2kernel.process.Gateway; - -public class LocalObjectLoader { - private static ActDefCache actCache = new ActDefCache(); - private static StateMachineCache smCache = new StateMachineCache(); - - static public ItemProxy loadLocalObjectDef(String root, String name) - throws ObjectNotFoundException - { - DomainPath defRoot = new DomainPath(root); - Iterator e = Gateway.getLookup().search(defRoot, name); - if (e.hasNext()) { - DomainPath defPath = (DomainPath)e.next(); - if (e.hasNext()) throw new ObjectNotFoundException("Too many matches for "+name+" in "+root); - return Gateway.getProxyManager().getProxy(defPath); - } - else { - throw new ObjectNotFoundException("No match for "+name+" in "+root); - } - - } - - static public String getScript(String scriptName, int scriptVersion) throws ObjectNotFoundException { - Logger.msg(5, "Loading script "+scriptName+" v"+scriptVersion); - try { - ItemProxy script = loadLocalObjectDef("/desc/Script/", scriptName); - Viewpoint scriptView = (Viewpoint)script.getObject(ClusterStorage.VIEWPOINT + "/Script/" + scriptVersion); - return scriptView.getOutcome().getData(); - } catch (PersistencyException ex) { - Logger.error(ex); - throw new ObjectNotFoundException("Error loading script " + scriptName + " version " + scriptVersion); - } - - } - - static public Schema getSchema(String schemaName, int schemaVersion) throws ObjectNotFoundException { - Logger.msg(5, "Loading schema "+schemaName+" v"+schemaVersion); - - String docType = schemaName; - int docVersion = schemaVersion; - String schemaData; - - // don't bother if this is the Schema schema - for bootstrap esp. - if (schemaName.equals("Schema") && schemaVersion == 0) - return new Schema(docType, docVersion, ""); - - ItemProxy schema = loadLocalObjectDef("/desc/OutcomeDesc/", schemaName); - Viewpoint schemaView = (Viewpoint)schema.getObject(ClusterStorage.VIEWPOINT + "/Schema/" + schemaVersion); - try { - schemaData = schemaView.getOutcome().getData(); - } catch (PersistencyException ex) { - Logger.error(ex); - throw new ObjectNotFoundException("Problem loading schema "+schemaName+" v"+schemaVersion+": "+ex.getMessage()); - } - return new Schema(docType, docVersion, schemaData); - } - - /** - * Retrieves a named version of activity def from the database - * - * @param actName - activity name - * @param version - named version (String) - * @return ActivityDef - * @throws ObjectNotFoundException - When activity or version does not exist - */ - static public ActivityDef getActDef(String actName, int actVersion) throws ObjectNotFoundException, InvalidDataException { - Logger.msg(5, "Loading activity def "+actName+" v"+actVersion); - return actCache.get(actName, actVersion); - } - - static public StateMachine getStateMachine(String smName, int smVersion) throws ObjectNotFoundException, InvalidDataException { - Logger.msg(5, "Loading activity def "+smName+" v"+smVersion); - return smCache.get(smName, smVersion); - } -} diff --git a/src/main/java/com/c2kernel/utils/Logger.java b/src/main/java/com/c2kernel/utils/Logger.java deleted file mode 100644 index e3adcc8..0000000 --- a/src/main/java/com/c2kernel/utils/Logger.java +++ /dev/null @@ -1,206 +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.utils; -import java.io.PrintStream; -import java.io.PrintWriter; -import java.io.StringWriter; -import java.sql.Timestamp; -import java.util.HashMap; -import java.util.Iterator; - -import com.c2kernel.process.AbstractMain; -import com.c2kernel.process.Gateway; -import com.c2kernel.scripting.ScriptConsole; -import com.c2kernel.utils.server.SimpleTCPIPServer; -/** - * 
- message string should always contain the class name and the method name: Logger.msg(1,"ItemFact::createDir() - LifeCycle DB created"); - use meaningfull abbreviation and also use the dash to separate the 'header' from the message! - each method should start with this 'method signature' debug: Logger.msg(1,"ItemFact::createDir() - path:" + path);
-*
- */ -public class Logger -{ - /** - * logging level 0 (only error & warning) => no logging ; 9 => maximum logging - * add ten to output time before each message - */ - private static int mHighestLogLevel = 0; - private static long startTime = System.currentTimeMillis(); - private static HashMap logStreams = new HashMap(); - static protected SimpleTCPIPServer mConsole = null; - - static private void printMessage(String message, int msgLogLevel) - { - synchronized(logStreams) { - for (Iterator iter = logStreams.keySet().iterator(); iter.hasNext();) { - PrintStream element = iter.next(); - int logLevel = logStreams.get(element); - - if ( (logLevel > 9 && logLevel - 10 < msgLogLevel) || - (msgLogLevel > 9 && logLevel < msgLogLevel - 10) || - (logLevel < 10 && msgLogLevel < 10 && logLevel < msgLogLevel) ) - continue; - - if (logLevel > 9 || msgLogLevel > 9) { - message = reportTime() + " - " + message; - } - - try { - element.println(message); - } catch (Exception ex) { - iter.remove(); - } - } - } - } - - static private String reportTime() { - long now = System.currentTimeMillis(); - Timestamp ts = new Timestamp(now); - double since = (now - startTime) / 1000.0; - return ts.toString() + " ("+since+"s)"; - } - - static private void printMessage(Throwable ex) { - StringWriter msgString = new StringWriter(); - PrintWriter msg = new PrintWriter(msgString); - msg.print(ex instanceof Exception ? "EXCEPTION:" : "JVM ERROR:"); - ex.printStackTrace(msg); - printMessage(msgString.toString(), 0); - } - - static public boolean doLog(int logLevel) - { - if (logLevel > 9) logLevel -= 10; - return mHighestLogLevel >= logLevel; - } - /** - * Use this only for temporary messages while developing/debugging. When the code is stable, change calls to debug to - * message/warning/error with an appropriate log level. Is is marked deprecated to highlight stray calls. This makes - * it easier to manage debug calls in the source. - * - * @param msg - - * the string to write to the console, or log file if specified in cmd line - * @deprecated - */ - @Deprecated - static public void debug(String msg) - { - msg("DEBUG : " + msg); - } - static public void debug(int logLevel, String msg) - { - msg(logLevel, "DEBUG : " + msg); - } - /** - * Use Logger.message to report information that will be useful for debugging a release - * - * @param level - - * log level of this message. If the current log level has been on the cmd line to be less that this number, the log message - * will not be displayed - * @param msg - - * the string to write to the console, or log file if specified in cmd line - */ - static public void msg(int level, String msg) - { - printMessage(msg, level); - } - static public void msg(String msg) - { - printMessage(msg, 0); - } - static public void error(String msg) - { - printMessage("ERROR : " + msg, 0); - } - static public void error(Throwable ex) - { - printMessage(ex); - } - static public void warning(String msg) - { - printMessage("WARNING: " + msg, 0); - } - static public void die(String msg) - { - printMessage("FATAL : " + msg, 0); - AbstractMain.shutdown(1); - } - /** - * @param console - */ - public static void addLogStream(PrintStream console, int logLevel) { - try { - console.println("***********************************************************"); - console.println(" CRISTAL log started at level "+logLevel+" @"+new Timestamp(System.currentTimeMillis()).toString()); - console.println("***********************************************************"); - } catch (Exception ex) { - System.out.println("Exception accessing log stream"); - ex.printStackTrace(); - } - - synchronized(logStreams) { - logStreams.put(console, logLevel); - if ((logLevel>10?logLevel-10:logLevel) > mHighestLogLevel) mHighestLogLevel = logLevel; - } - - } - /** - * @param console - */ - public static void removeLogStream(PrintStream console) { - synchronized(logStreams) { - Integer logIntObj = logStreams.get(console); - if (logIntObj == null) return; // not registered - int logLevel = (logIntObj).intValue(); - logStreams.remove(console); - - // recalculate lowest log level - if (logLevel == mHighestLogLevel || (logLevel > 9 && logLevel-10 == mHighestLogLevel)) { - mHighestLogLevel = 0; - for (Integer element : logStreams.values()) { - int thisLogLevel = element>9?element-10:element; - if (thisLogLevel > mHighestLogLevel) - mHighestLogLevel = thisLogLevel; - } - } - } - } - - static public void initConsole(String id) - { - int port = Gateway.getProperties().getInt(id+".Console.port", 0); - if (port == 0) - Logger.msg("No port defined for "+id+" console. Using any port."); - - mConsole = new SimpleTCPIPServer(port, ScriptConsole.class, 5); - mConsole.startListening(); - Gateway.getProperties().setProperty(id+".Console.port", String.valueOf(mConsole.getPort())); - } - - static public int getConsolePort() { - return mConsole.getPort(); - } - - static public void closeConsole() - { - if (mConsole != null) - mConsole.stopListening(); - } -} diff --git a/src/main/java/com/c2kernel/utils/ObjectProperties.java b/src/main/java/com/c2kernel/utils/ObjectProperties.java deleted file mode 100644 index 4087fa3..0000000 --- a/src/main/java/com/c2kernel/utils/ObjectProperties.java +++ /dev/null @@ -1,215 +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.utils; - -import java.util.ArrayList; -import java.util.Enumeration; -import java.util.Properties; -import java.util.StringTokenizer; - -public class ObjectProperties extends Properties { - - public ObjectProperties() { - } - - public ObjectProperties(Properties defaults) { - super(defaults); - } - - public String getString(String propName) { - return getString(propName, null); - } - - public String getString(String propName, String defaultValue) { - String value = super.getProperty(propName, defaultValue); - if (value!=null) value = value.trim(); - return value; - } - - /** - * ogattaz proposal - * - * @param propName - * the name of the property - * @return the object value of the property. Returns null if the property - * doesn't exist or if the properties of the gateway is null - */ - public Object getObject(String propName) { - return getObject(propName, null); - } - - /** - * ogattaz proposal - * - * @param aPropertyName - * the name of the property - * @param defaultValue - * the default value. - * @return the object value of the property. Returns the default value if the property - * doesn't exist or if the properties of the gateway is null. - * @return - */ - public Object getObject(String propName, - Object defaultValue) { - - Object wValue = get(propName); - if (wValue == null) { - return defaultValue; - } - return wValue; - } - - /** - * ogattaz proposal - * - * @param propName - * the name of the paroperty - * @return the boolean value of the property. Returns false if the property - * doesn't exist or if the value is not a String or a Boolean - * instance - */ - public boolean getBoolean(String aPropertyName) { - return getBoolean(aPropertyName, Boolean.FALSE); - } - - /** - * ogattaz proposal - * - * @param propName - * the name of the parameter stored in the clc file - * @param defaultValue - * the default value - * @return the boolean value of the property. Returns the default value if - * the property doesn't exist or if the value is not a String or a - * Boolean instance - */ - public boolean getBoolean(String aPropertyName, - boolean defaultValue) { - - Object wValue = getObject(aPropertyName, Boolean.valueOf(defaultValue)); - if (wValue instanceof Boolean) { - return ((Boolean) wValue).booleanValue(); - } - if (wValue instanceof String) { - return Boolean.parseBoolean((String) wValue); - } - Logger.error("getBoolean(): unable to retrieve a int value for ["+aPropertyName+"]. Returning default value ["+defaultValue+"]. object found="+wValue); - - return defaultValue; - } - - /** - * ogattaz proposal - * - * @param propName - * the name of the property - * @return the int value of the property. Returns -1 if the property doesn't - * exist or if the value is not a String or an Integer instance - */ - public int getInt(String aPropertyName) { - return getInt(aPropertyName, -1); - } - - /** - * ogattaz proposal - * - * @param propName - * the name of the property - * @param defaultValue - * the default value - * @return the int value of the property. Returns the default vakue if the - * property doesn't exist or if the value is not a String or an - * Integer instance - */ - public int getInt(String aPropertyName, int defaultValue) { - - Object wValue = getObject(aPropertyName, Integer.valueOf(defaultValue)); - if (wValue instanceof Integer) { - return ((Integer) wValue).intValue(); - } - if (wValue instanceof String) { - try { - return Integer.parseInt((String) wValue); - } catch (NumberFormatException ex) { } - } - Logger.error("getInt(): unable to retrieve a int value for ["+aPropertyName+"]. Returning default value ["+defaultValue+"]. object found="+wValue); - return defaultValue; - } - - /** - * Allow setting of properties as Objects - * - * @param aPropertyName - * the name of the property - * @param aPropertyValue - */ - public void setProperty(String aPropertyName, Object aPropertyValue) { - put(aPropertyName, aPropertyValue); - } - - public void dumpProps(int logLevel) { - Logger.msg(logLevel, "Properties:"); - for (Enumeration e = propertyNames(); e.hasMoreElements();) { - String name = (String) e.nextElement(); - Object value = getObject(name); - if (value == null) - Logger.msg(" "+name+": null"); - else - Logger.msg(" "+name+" ("+getObject(name).getClass().getSimpleName()+"): '"+getObject(name).toString()+"'"); - } - } - - public Object getInstance(String propName, Object defaultVal) throws InstantiationException, IllegalAccessException, ClassNotFoundException { - Object prop = getObject(propName, defaultVal); - if (prop == null || prop.equals("")) - throw new InstantiationException("Property '"+propName+"' was not defined. Cannot instantiate."); - if (prop instanceof String) - return Class.forName(((String)prop).trim()).newInstance(); - return prop; - } - - public Object getInstance(String propName) throws InstantiationException, IllegalAccessException, ClassNotFoundException { - return getInstance(propName, null); - } - - public ArrayList getInstances(String propName, Object defaultVal) throws InstantiationException, IllegalAccessException, ClassNotFoundException { - Object val = getObject(propName, defaultVal); - if (val == null) return null; - if (val instanceof ArrayList) - return (ArrayList)val; - else if (val instanceof String) { - ArrayList retArr = new ArrayList(); - StringTokenizer tok = new StringTokenizer((String)val, ","); - while (tok.hasMoreTokens()) - retArr.add(getInstance(tok.nextToken())); - return retArr; - } - else { - ArrayList retArr = new ArrayList(); - retArr.add(val); - return retArr; - } - } - - public ArrayList getInstances(String propName) throws InstantiationException, IllegalAccessException, ClassNotFoundException { - return getInstances(propName, null); - } -} diff --git a/src/main/java/com/c2kernel/utils/SoftCache.java b/src/main/java/com/c2kernel/utils/SoftCache.java deleted file mode 100644 index 68428e2..0000000 --- a/src/main/java/com/c2kernel/utils/SoftCache.java +++ /dev/null @@ -1,139 +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.utils; - -import java.lang.ref.ReferenceQueue; -import java.lang.ref.SoftReference; -import java.util.AbstractMap; -import java.util.HashMap; -import java.util.LinkedList; -import java.util.Map; -import java.util.Set; - -/******************************************************************************* - * SoftReferences are reaped if no strong references are left and the vm is - * running out of memory. Most caches in the kernel use this. - * - * $Revision: 1.5 $ $Date: 2004/10/29 13:29:09 $ - ******************************************************************************/ -public class SoftCache extends AbstractMap { - - private final Map> hash = new HashMap>(); - private final int minSize; - private final LinkedList hardCache = new LinkedList(); - private final ReferenceQueue queue = new ReferenceQueue(); - - public SoftCache() { - this(0); - } - - public SoftCache(int minSize) { - this.minSize = minSize; - } - - @Override - public V get(Object key) { - V result = null; - SoftValue soft_ref = hash.get(key); - if (soft_ref != null) { - result = soft_ref.get(); - if (result == null) - hash.remove(key); - else - if (minSize > 0) { // add to hard cache so it's not reaped for a while - synchronized(hardCache) { - hardCache.addFirst(result); - if (hardCache.size() > minSize) // trim last one off - hardCache.removeLast(); - } - } - } - return result; - } - - @Override - public V put(K key, V value) { - processQueue(); - if (minSize > 0) { - synchronized(hardCache) { - hardCache.addFirst(value); - if (hardCache.size() > minSize) - hardCache.removeLast(); - } - } - hash.put(key, new SoftValue(key, value, queue)); - return value; - } - - @Override - public V remove(Object key) { - processQueue(); - if (hash.containsKey(key)) return hash.remove(key).get(); - return null; - } - - @Override - public void clear() { - synchronized(hardCache) { - hardCache.clear(); - } - while(queue.poll()!=null); - hash.clear(); - } - - @Override - public int size() { - processQueue(); - return hash.size(); - } - - @Override - public Set keySet() { - processQueue(); - return hash.keySet(); - } - - @Override - public Set> entrySet() { - // Would have to create another Map to do this - too expensive - // Throwing runtime expensive is dangerous, but better than nulls - throw new UnsupportedOperationException(); - } - - private static class SoftValue extends SoftReference { - private final Object key; - private SoftValue(Object key, V value, ReferenceQueue q) { - super(value, q); - this.key = key; - } - } - - /** - * Look for values that have been reaped, and remove their keys from the cache - */ - private void processQueue() { - SoftValue sv; - while ((sv = (SoftValue) queue.poll()) != null) { - hash.remove(sv.key); - } - } - -} diff --git a/src/main/java/com/c2kernel/utils/StateMachineCache.java b/src/main/java/com/c2kernel/utils/StateMachineCache.java deleted file mode 100644 index 02eb881..0000000 --- a/src/main/java/com/c2kernel/utils/StateMachineCache.java +++ /dev/null @@ -1,66 +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.utils; - -import com.c2kernel.common.InvalidDataException; -import com.c2kernel.common.ObjectNotFoundException; -import com.c2kernel.common.PersistencyException; -import com.c2kernel.entity.proxy.ItemProxy; -import com.c2kernel.lifecycle.instance.stateMachine.StateMachine; -import com.c2kernel.persistency.ClusterStorage; -import com.c2kernel.persistency.outcome.Viewpoint; -import com.c2kernel.process.Gateway; - -public class StateMachineCache extends DescriptionObjectCache { - - - @Override - public String getDefRoot() { - return "/desc/StateMachine"; - } - - @Override - public StateMachine loadObject(String name, int version, ItemProxy proxy) throws ObjectNotFoundException, InvalidDataException { - StateMachine thisStateMachine; - Viewpoint smView = (Viewpoint)proxy.getObject(ClusterStorage.VIEWPOINT + "/StateMachine/" + version); - String marshalledSM; - try { - marshalledSM = smView.getOutcome().getData(); - } catch (PersistencyException ex) { - Logger.error(ex); - throw new ObjectNotFoundException("Problem loading State Machine "+name+" v"+version+": "+ex.getMessage()); - } - try { - thisStateMachine = (StateMachine)Gateway.getMarshaller().unmarshall(marshalledSM); - thisStateMachine.validate(); - } catch (Exception ex) { - Logger.error(ex); - throw new InvalidDataException("Could not unmarshall State Machine '"+name+"' v"+version+": "+ex.getMessage()); - } - thisStateMachine.setName(name); - thisStateMachine.setVersion(version); - return thisStateMachine; - } - -} \ No newline at end of file diff --git a/src/main/java/com/c2kernel/utils/TransientCache.java b/src/main/java/com/c2kernel/utils/TransientCache.java deleted file mode 100644 index fc5f4de..0000000 --- a/src/main/java/com/c2kernel/utils/TransientCache.java +++ /dev/null @@ -1,149 +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.utils; -import java.lang.ref.Reference; -import java.util.AbstractMap; -import java.util.AbstractSet; -import java.util.Hashtable; -import java.util.Iterator; -import java.util.Map; -import java.util.Set; -/************************************************************************** - * TransientCache - Uses transient references to allow unused entries to be - * reaped by the java garbage collector. - * - * $Revision: 1.1 $ - * $Date: 2004/04/20 09:37:02 $ - * - * Copyright (C) 2003 CERN - European Organization for Nuclear Research - * All rights reserved. - **************************************************************************/ -public abstract class TransientCache extends AbstractMap { - - private Map> map = new Hashtable>(); - - @Override - public synchronized Set> entrySet() { - Map newMap = new Hashtable(); - Iterator>> iter = map.entrySet().iterator(); - while (iter.hasNext()) { - Entry> me = iter.next(); - Reference ref = me.getValue(); - V o = ref.get(); - if (o == null) { - // Delete cleared reference - iter.remove(); - } else { - // Copy out interior object - newMap.put(me.getKey(), o); - } - } - // Return set of interior objects - return newMap.entrySet(); - } - - @Override - public synchronized V put(K key, V value) { - Reference ref = makeReference(value); - ref = map.put(key, ref); - if (ref != null) - return (ref.get()); - return null; - } - - public abstract Reference makeReference(Object value); - - @Override - public V remove(Object key) { - Iterator>> i = map.entrySet().iterator(); - Entry> correctEntry = null; - if (key == null) { - while (correctEntry == null && i.hasNext()) { - Entry> e = i.next(); - if (e.getKey() == null) - correctEntry = e; - } - } else { - while (correctEntry == null && i.hasNext()) { - Entry> e = i.next(); - if (key.equals(e.getKey())) - correctEntry = e; - } - } - V oldValue = null; - if (correctEntry != null) { - Reference correctReference = correctEntry.getValue(); - oldValue = correctReference.get(); - i.remove(); - } - return oldValue; - } - /** - * - */ - @Override - public void clear() { - map.entrySet().clear(); - } - - private transient Set keySet = null; - - @Override - public Set keySet() { - if (keySet == null) { - keySet = new AbstractSet() { - @Override - public Iterator iterator() { - return new Iterator() { - private Iterator>> i = map.entrySet().iterator(); - - @Override - public boolean hasNext() { - return i.hasNext(); - } - - @Override - public K next() { - return i.next().getKey(); - } - - @Override - public void remove() { - i.remove(); - } - }; - } - - @Override - public int size() { - return TransientCache.this.size(); - } - - @Override - public boolean contains(Object k) { - return TransientCache.this.containsKey(k); - } - }; - } - return keySet; - } - -} diff --git a/src/main/java/com/c2kernel/utils/WeakCache.java b/src/main/java/com/c2kernel/utils/WeakCache.java deleted file mode 100644 index 6b61474..0000000 --- a/src/main/java/com/c2kernel/utils/WeakCache.java +++ /dev/null @@ -1,154 +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.utils; - -import java.lang.ref.ReferenceQueue; -import java.lang.ref.WeakReference; -import java.util.AbstractMap; -import java.util.HashMap; -import java.util.LinkedList; -import java.util.Map; -import java.util.Set; - -/******************************************************************************* - * WeakReferences are reaped if no strong references are left next time the gc has a chance. - * The ClusterStorageManager caches can optionally use this one, for high volume imports etc - * - * $Revision: 1.5 $ $Date: 2004/10/29 13:29:09 $ - ******************************************************************************/ -public class WeakCache extends AbstractMap { - - private final Map> hash = new HashMap>(); - private final int minSize; - private final LinkedList hardCache = new LinkedList(); - private final ReferenceQueue queue = new ReferenceQueue(); - - public WeakCache() { - this(0); - } - - public WeakCache(int minSize) { - this.minSize = minSize; - } - - /* (non-Javadoc) - * @see com.c2kernel.utils.NonStrongRefCache#get(java.lang.Object) - */ - @Override - public V get(Object key) { - V result = null; - WeakValue weak_ref = hash.get(key); - if (weak_ref != null) { - result = weak_ref.get(); - if (result == null) - hash.remove(key); - else - if (minSize > 0) { // add to hard cache so it's not reaped for a while - hardCache.addFirst(result); - if (hardCache.size() > minSize) // trim last one off - hardCache.removeLast(); - } - } - return result; - } - - /* (non-Javadoc) - * @see com.c2kernel.utils.NonStrongRefCache#put(K, V) - */ - @Override - public V put(K key, V value) { - processQueue(); - if (minSize > 0) { - hardCache.addFirst(value); - if (hardCache.size() > minSize) - hardCache.removeLast(); - } - hash.put(key, new WeakValue(key, value, queue)); - return value; - } - - /* (non-Javadoc) - * @see com.c2kernel.utils.NonStrongRefCache#remove(java.lang.Object) - */ - @Override - public V remove(Object key) { - processQueue(); - if (hash.containsKey(key)) return hash.remove(key).get(); - return null; - } - - /* (non-Javadoc) - * @see com.c2kernel.utils.NonStrongRefCache#clear() - */ - @Override - public void clear() { - hardCache.clear(); - while(queue.poll()!=null); - hash.clear(); - } - - /* (non-Javadoc) - * @see com.c2kernel.utils.NonStrongRefCache#size() - */ - @Override - public int size() { - processQueue(); - return hash.size(); - } - - /* (non-Javadoc) - * @see com.c2kernel.utils.NonStrongRefCache#keySet() - */ - @Override - public Set keySet() { - processQueue(); - return hash.keySet(); - } - - /* (non-Javadoc) - * @see com.c2kernel.utils.NonStrongRefCache#entrySet() - */ - @Override - public Set> entrySet() { - // Would have to create another Map to do this - too expensive - // Throwing runtime expensive is dangerous, but better than nulls - throw new UnsupportedOperationException(); - } - - private static class WeakValue extends WeakReference { - private final Object key; - private WeakValue(Object key, V value, ReferenceQueue q) { - super(value, q); - this.key = key; - } - } - - /** - * Look for values that have been reaped, and remove their keys from the cache - */ - private void processQueue() { - WeakValue sv; - while ((sv = (WeakValue) queue.poll()) != null) { - hash.remove(sv.key); - } - } - -} diff --git a/src/main/java/com/c2kernel/utils/XmlElementParser.java b/src/main/java/com/c2kernel/utils/XmlElementParser.java deleted file mode 100644 index 06718c1..0000000 --- a/src/main/java/com/c2kernel/utils/XmlElementParser.java +++ /dev/null @@ -1,125 +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.utils; - -import java.io.StringReader; -import java.util.StringTokenizer; -import java.util.Vector; - -import javax.xml.parsers.DocumentBuilder; -import javax.xml.parsers.DocumentBuilderFactory; -import javax.xml.parsers.ParserConfigurationException; - -import org.w3c.dom.Document; -import org.w3c.dom.Element; -import org.w3c.dom.Node; -import org.w3c.dom.NodeList; -import org.xml.sax.InputSource; - -public class XmlElementParser { - public static String[] parse(String data, String xpath) { - Vector returnData = new Vector(); - String[] returnArray; - DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance(); - DocumentBuilder builder; - try { - builder = factory.newDocumentBuilder(); - } catch (ParserConfigurationException e) { - Logger.error(e); - throw new RuntimeException("Could not create XML Document Builder"); - } - StringReader is = new StringReader(data); - Document doc; - try { - doc = builder.parse(new InputSource(is)); - } catch (Exception e) { - Logger.error(e); - throw new RuntimeException("Parser malfunction"); - } - StringTokenizer pathTokens = new StringTokenizer(xpath, "/"); - int taille = pathTokens.countTokens(); - String[] pathElements = new String[taille]; - int i = taille; - while (pathTokens.hasMoreElements()) - pathElements[--i] = pathTokens.nextToken(); - - if (Logger.doLog(6)) { - Logger.msg(6, "Path elements:"); - for (String pathElement : pathElements) - Logger.debug(6, pathElement); - } - - Logger.msg(6, "Looking for attribute " + pathElements[0] + " in " - + pathElements[1]); - NodeList nl = doc.getElementsByTagName(pathElements[1]); - for (int j = 0; j < nl.getLength(); j++) { - Logger.msg(6, "Found one"); - Element e = (Element) nl.item(j); - boolean match = true; - Node child = e; - for (int k = 2; k < taille && match; k++) { - Logger.msg(6, "Checking parent " + pathElements[k]); - child = child.getParentNode(); - if (!child.getNodeName().equals(pathElements[k])) { - Logger.msg(6, "No match for " + child.getNodeName()); - match = false; - } else - Logger.msg(6, "Match"); - } - if (match && e.hasAttribute(pathElements[0])) { - Logger.msg( - 6, - "Matching Attribute " + pathElements[0] + "=" - + e.getAttribute(pathElements[0])); - returnData.add(e.getAttribute(pathElements[0])); - } - } - - Logger.msg(6, "Looking for element " + pathElements[0]); - nl = doc.getElementsByTagName(pathElements[0]); - for (int j = 0; j < nl.getLength(); j++) { - Logger.msg(6, "Found one"); - Element e = (Element) nl.item(j); - boolean match = true; - Node child = e; - for (int k = 1; k < taille && match; k++) { - Logger.msg(6, "Checking parent " + pathElements[k]); - child = child.getParentNode(); - if (!child.getNodeName().equals(pathElements[k])) { - Logger.msg(6, "No match for " + child.getNodeName()); - match = false; - } else - Logger.msg(6, "Match"); - } - if (match) { - String s = e.getFirstChild().getNodeValue(); - Logger.msg(6, "Found Element " + pathElements[0] + "=" + s); - if (s != null) - returnData.add(s); - } - } - Logger.msg(3, returnData.size() + " values found for " + xpath); - returnArray = new String[returnData.size()]; - for (int j = 0; j < returnArray.length; j++) - returnArray[j] = returnData.get(j); - return returnArray; - } -} diff --git a/src/main/java/com/c2kernel/utils/server/SimpleTCPIPServer.java b/src/main/java/com/c2kernel/utils/server/SimpleTCPIPServer.java deleted file mode 100644 index f34f0cc..0000000 --- a/src/main/java/com/c2kernel/utils/server/SimpleTCPIPServer.java +++ /dev/null @@ -1,129 +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.utils.server; - -import java.io.InterruptedIOException; -import java.net.ServerSocket; -import java.net.Socket; -import java.util.ArrayList; -import java.util.ListIterator; -import java.util.NoSuchElementException; - -import com.c2kernel.utils.Logger; - - -public class SimpleTCPIPServer implements Runnable -{ - int port = 0; - int maxConn = 10; - Thread listener = null; - Class handlerClass = null; - ServerSocket serverSocket = null; - boolean keepListening = true; - ArrayList currentHandlers = new ArrayList(); - static short noServers = 0; - - public SimpleTCPIPServer(int port, Class handlerClass, int maxConnections) - { - this.port = port; - this.handlerClass = handlerClass; - this.maxConn = maxConnections; - noServers++; - } - - public void startListening() - { - if(listener != null) return; - keepListening = true; - - listener = new Thread(this); - listener.start(); - } - - public void stopListening() - { - Logger.msg("SimpleTCPIPServer: Closing server for " + handlerClass.getName() +" on port "+ port); - keepListening = false; - for (SocketHandler thisHandler : currentHandlers) { - thisHandler.shutdown(); - } - } - - @Override - public void run() - { - Thread.currentThread().setName("TCP/IP Server for "+handlerClass.getName()); - Socket connectionSocket = null; - - try { - serverSocket = new ServerSocket(port); - if (port == 0) - port = serverSocket.getLocalPort(); - Logger.msg("SimpleTCPIPServer: Created server for " + handlerClass.getName()+" on port "+port); - serverSocket.setSoTimeout(500); - SocketHandler freeHandler = null; - while(keepListening) { - if (freeHandler == null || freeHandler.isBusy()) { - ListIterator i = currentHandlers.listIterator(); - try { - do { - freeHandler = i.next(); - } while (freeHandler.isBusy()); - } catch (NoSuchElementException e) { - // create new one - if (currentHandlers.size() < maxConn) { - freeHandler = (SocketHandler)handlerClass.newInstance(); - currentHandlers.add(freeHandler); - } - else { // max handlers are created. wait for a while, then look again - Logger.warning("No free handlers left for "+handlerClass.getName()+" on port "+ port + "!"); - Thread.sleep(2000); - continue; - } - } - } - try { - connectionSocket = serverSocket.accept(); - if (keepListening) { - Logger.msg("SimpleTCPIPServer: Connection to "+freeHandler.getName()+" from "+ - connectionSocket.getInetAddress()); - freeHandler.setSocket(connectionSocket); - new Thread(freeHandler).start(); - } - } catch (InterruptedIOException ex1) { }// timeout just to check if we've been told to die - - } - serverSocket.close(); - Logger.msg("SimpleTCPIPServer: Server closed for " + handlerClass.getName() +" on port "+ port); - } catch(Exception ex) { - Logger.error(ex); - Logger.error("SimpleTCPIPServer.run(): Fatal Error. Listener for '"+handlerClass.getName()+"' will stop."); - listener = null; --noServers; - return; - } - listener = null; - Logger.msg("SimpleTCPIPServer - Servers still running: "+--noServers); - } - - public int getPort() { - return port; - } -} diff --git a/src/main/java/com/c2kernel/utils/server/SocketHandler.java b/src/main/java/com/c2kernel/utils/server/SocketHandler.java deleted file mode 100644 index a9aedd9..0000000 --- a/src/main/java/com/c2kernel/utils/server/SocketHandler.java +++ /dev/null @@ -1,35 +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.utils.server; - -import java.net.Socket; - -public interface SocketHandler extends Runnable { - - public String getName(); - - public boolean isBusy(); - - public void setSocket(Socket newSocket); - - public void shutdown(); -} - -- cgit v1.2.3