entry : properties.entrySet())
+ {
+ if (entry.getKey() instanceof String)
+ {
+ String key = (String)entry.getKey();
+ if (namespace != null)
+ {
+ if (key.startsWith(namespace))
+ {
+ key = key.substring(namespace.length());
+ }
+ else
+ {
+ continue;
+ }
+ }
+
+ if (classKey.equals(key))
+ {
+ Object classValue = entry.getValue();
+ if (classValue instanceof String)
+ {
+ className = (String)classValue;
+ }
+ else
+ {
+ OM.LOG.warn("Value of classKey " + classKey + " is not a String"); //$NON-NLS-1$ //$NON-NLS-2$
+ }
+ }
+ else
+ {
+ values.put(key, entry.getValue());
+ }
+ }
+ }
+
+ if (className == null)
+ {
+ throw new IllegalArgumentException("Properties do not contain a valid class name for key " + classKey); //$NON-NLS-1$
+ }
+
+ Class c = classLoader.loadClass(className);
+ Object instance = c.newInstance();
+ Method[] methods = c.getMethods();
+ for (Method method : methods)
+ {
+ if (isSetter(method))
+ {
+ String name = StringUtil.uncap(method.getName().substring(3));
+ Object value = values.get(name);
+ if (value != null)
+ {
+ Class type = method.getParameterTypes()[0];
+ if (!type.isAssignableFrom(value.getClass()))
+ {
+ if (value instanceof String)
+ {
+ String str = (String)value;
+ value = null;
+ if (type.isAssignableFrom(Boolean.class))
+ {
+ value = Boolean.parseBoolean(str);
+ }
+ else if (type.isAssignableFrom(Byte.class))
+ {
+ value = Byte.parseByte(str);
+ }
+ else if (type.isAssignableFrom(Short.class))
+ {
+ value = Short.parseShort(str);
+ }
+ else if (type.isAssignableFrom(Integer.class))
+ {
+ value = Integer.parseInt(str);
+ }
+ else if (type.isAssignableFrom(Long.class))
+ {
+ value = Long.parseLong(str);
+ }
+ else if (type.isAssignableFrom(Float.class))
+ {
+ value = Float.parseFloat(str);
+ }
+ else if (type.isAssignableFrom(Double.class))
+ {
+ value = Double.parseDouble(str);
+ }
+ }
+ else
+ {
+ value = null;
+ }
+ }
+
+ if (value == null)
+ {
+ throw new IllegalArgumentException("Value of property " + name + " can not be assigned to type " //$NON-NLS-1$ //$NON-NLS-2$
+ + type.getName());
+ }
+
+ method.invoke(instance, value);
+ }
+ }
+ }
+
+ return instance;
+ }
+
+ public static boolean isSetter(Method method)
+ {
+ return method.getParameterTypes().length == 1 && isSetterName(method.getName());
+ }
+
+ public static boolean isSetterName(String name)
+ {
+ return name.startsWith("set") && name.length() > 3 && Character.isUpperCase(name.charAt(3)); //$NON-NLS-1$
+ }
+
+ public static String toString(Object object)
+ {
+ return toString(object, " "); //$NON-NLS-1$
+ }
+
+ public static String toString(Object object, String prefix)
+ {
+ StringBuilder builder = new StringBuilder();
+ builder.append(prefix);
+ builder.append(getLabel(object));
+ builder.append(StringUtil.NL);
+ toString(object.getClass(), object, prefix, builder);
+ return builder.toString();
+ }
+
+ private static void toString(Class segment, Object object, String prefix, StringBuilder builder)
+ {
+ if (segment == ROOT_CLASS || segment == Lifecycle.class)
+ {
+ return;
+ }
+
+ // Recurse
+ toString(segment.getSuperclass(), object, prefix, builder);
+
+ String segmentPrefix = segment == object.getClass() ? "" : getSimpleName(segment) + NAMESPACE_SEPARATOR; //$NON-NLS-1$
+ for (Field field : segment.getDeclaredFields())
+ {
+ if (field.isSynthetic())
+ {
+ continue;
+ }
+
+ if ((field.getModifiers() & Modifier.STATIC) != 0 && !DUMP_STATICS)
+ {
+ continue;
+ }
+
+ if (field.getAnnotation(ExcludeFromDump.class) != null)
+ {
+ continue;
+ }
+
+ builder.append(prefix);
+ builder.append(segmentPrefix);
+ builder.append(field.getName());
+ builder.append(" = "); //$NON-NLS-1$
+
+ Object value = getValue(field, object);
+ if (value instanceof Map)
+ {
+ value = ((Map)value).entrySet();
+ }
+
+ if (value instanceof Collection)
+ {
+ builder.append(StringUtil.NL);
+ Collection collection = (Collection)value;
+ Object[] array = collection.toArray(new Object[collection.size()]);
+ for (Object element : array)
+ {
+ builder.append(" "); //$NON-NLS-1$
+ builder.append(element);
+ builder.append(StringUtil.NL);
+ }
+ }
+ else
+ {
+ builder.append(value);
+ builder.append(StringUtil.NL);
+ }
+ }
+ }
+
+ private static Method lookupHashCodeMethod()
+ {
+ Method method;
+
+ try
+ {
+ method = ROOT_CLASS.getMethod("hashCode", NO_PARAMETERS); //$NON-NLS-1$
+ }
+ catch (Exception ex)
+ {
+ // This can really not happen
+ throw new AssertionError();
+ }
+
+ if (!method.isAccessible())
+ {
+ method.setAccessible(true);
+ }
+
+ return method;
+ }
+
+ /**
+ * Annotates fields that are to be skipped in {@link ReflectUtil#collectFields(Class, List)
+ * ReflectUtil.collectFields()} and {@link ReflectUtil#toString(Object) ReflectUtil.toString()}.
+ *
+ * @author Eike Stepper
+ * @apiviz.exclude
+ */
+ @Retention(RetentionPolicy.RUNTIME)
+ @Target(ElementType.FIELD)
+ public @interface ExcludeFromDump
+ {
+ }
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/StringUtil.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/StringUtil.java
index 30806f9e02..3fb7bdd0a1 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/StringUtil.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/StringUtil.java
@@ -1,393 +1,393 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util;
-
-import org.eclipse.net4j.util.om.OMPlatform;
-
-import java.io.ByteArrayOutputStream;
-import java.io.PrintStream;
-
-/**
- * Various static helper methods for dealing with strings.
- *
- * @author Eike Stepper
- */
-public final class StringUtil
-{
- public static final String EMPTY = ""; //$NON-NLS-1$
-
- public static final String NL = OMPlatform.INSTANCE.getProperty("line.separator"); //$NON-NLS-1$
-
- private StringUtil()
- {
- }
-
- /**
- * @since 2.0
- */
- public static String formatException(Throwable t)
- {
- ByteArrayOutputStream baos = new ByteArrayOutputStream();
- PrintStream s = new PrintStream(baos);
- t.printStackTrace(s);
- return baos.toString();
- }
-
- public static String replace(String text, String[] find, String[] replace)
- {
- for (int i = 0; i < find.length; i++)
- {
- int end = 0;
- for (;;)
- {
- int start = text.indexOf(find[i], end);
- if (start == -1)
- {
- break;
- }
-
- end = start + find[i].length();
- text = text.substring(0, start) + replace[i] + text.substring(end);
- }
- }
-
- return text;
- }
-
- public static String safe(String str)
- {
- if (str == null)
- {
- return EMPTY;
- }
-
- return str;
- }
-
- public static int compare(String s1, String s2)
- {
- if (s1 == null)
- {
- return s2 == null ? 0 : -1;
- }
-
- if (s2 == null)
- {
- return 1;
- }
-
- return s1.compareTo(s2);
- }
-
- /**
- * @since 3.1
- */
- public static boolean equalsUpperOrLowerCase(String s, String upperOrLowerCase)
- {
- if (s == null)
- {
- return upperOrLowerCase == null;
- }
-
- return s.equals(upperOrLowerCase.toLowerCase()) || s.equals(upperOrLowerCase.toUpperCase());
- }
-
- /**
- * @since 2.0
- */
- public static String capAll(String str)
- {
- if (str == null || str.length() == 0)
- {
- return str;
- }
-
- boolean inWhiteSpace = true;
- StringBuilder builder = new StringBuilder(str);
- for (int i = 0; i < builder.length(); i++)
- {
- char c = builder.charAt(i);
- boolean isWhiteSpace = Character.isWhitespace(c);
- if (!isWhiteSpace && inWhiteSpace)
- {
- builder.setCharAt(i, Character.toUpperCase(c));
- }
-
- inWhiteSpace = isWhiteSpace;
- }
-
- return builder.toString();
- }
-
- /**
- * @since 2.0
- */
- public static String uncapAll(String str)
- {
- if (str == null || str.length() == 0)
- {
- return str;
- }
-
- boolean inWhiteSpace = true;
- StringBuilder builder = new StringBuilder(str);
- for (int i = 0; i < builder.length(); i++)
- {
- char c = builder.charAt(i);
- boolean isWhiteSpace = Character.isWhitespace(c);
- if (!isWhiteSpace && inWhiteSpace)
- {
- builder.setCharAt(i, Character.toLowerCase(c));
- }
-
- inWhiteSpace = isWhiteSpace;
- }
-
- return builder.toString();
- }
-
- public static String cap(String str)
- {
- if (str == null || str.length() == 0)
- {
- return str;
- }
-
- char first = str.charAt(0);
- if (Character.isUpperCase(first))
- {
- return str;
- }
-
- if (str.length() == 1)
- {
- return str.toUpperCase();
- }
-
- StringBuilder builder = new StringBuilder(str);
- builder.setCharAt(0, Character.toUpperCase(first));
- return builder.toString();
- }
-
- public static String uncap(String str)
- {
- if (str == null || str.length() == 0)
- {
- return str;
- }
-
- char first = str.charAt(0);
- if (Character.isLowerCase(first))
- {
- return str;
- }
-
- if (str.length() == 1)
- {
- return str.toLowerCase();
- }
-
- StringBuilder builder = new StringBuilder(str);
- builder.setCharAt(0, Character.toLowerCase(first));
- return builder.toString();
- }
-
- public static int occurrences(String str, char c)
- {
- int count = 0;
- for (int i = 0; (i = str.indexOf(c, i)) != -1; ++i)
- {
- ++count;
- }
-
- return count;
- }
-
- public static int occurrences(String str, String c)
- {
- int count = 0;
- for (int i = 0; (i = str.indexOf(c, i)) != -1; i += c.length())
- {
- ++count;
- }
-
- return count;
- }
-
- public static boolean isEmpty(String str)
- {
- return ObjectUtil.isEmpty(str);
- }
-
- /**
- * Matches a string against a pattern.
- *
- * Pattern description:
- *
- * * matches 0 or more characters
- * ? matches a single character
- * [...] matches a set and/or range of characters
- * \ escapes the following character
- *
- *
- * @since 2.0
- */
- public static boolean glob(String pattern, String string)
- {
- return glob(pattern, string, null);
- }
-
- /**
- * Matches a string against a pattern and fills an array with the sub-matches.
- *
- * Pattern description:
- *
- * * matches 0 or more characters
- * ? matches a single character
- * [...] matches a set and/or range of characters
- * \ escapes the following character
- *
- *
- * @since 2.0
- */
- public static boolean glob(String pattern, String string, String[] subStrings)
- {
- return globRecurse(pattern, 0, string, 0, subStrings, 0);
- }
-
- private static boolean globRecurse(String pattern, int patternIndex, String string, int stringIndex,
- String[] subStrings, int subStringsIndex)
- {
- int patternLength = pattern.length();
- int stringLength = string.length();
-
- for (;;)
- {
- char patternChar = pattern.charAt(patternIndex);
- boolean endReached = stringIndex == stringLength;
- if (patternIndex == patternLength)
- {
- return endReached;
- }
- else if (endReached && patternChar != '*')
- {
- return false;
- }
-
- switch (patternChar)
- {
- case '*':
- {
- int startIndex = stringIndex;
- if (++patternIndex >= patternLength)
- {
- globRemember(string, startIndex, stringLength, subStrings, subStringsIndex);
- return true;
- }
-
- for (;;)
- {
- if (globRecurse(pattern, patternIndex, string, stringIndex, subStrings, subStringsIndex + 1))
- {
- globRemember(string, startIndex, stringIndex, subStrings, subStringsIndex);
- return true;
- }
-
- if (endReached)
- {
- return false;
- }
-
- ++stringIndex;
- }
- }
-
- case '?':
- ++patternIndex;
- globRemember(string, stringIndex, ++stringIndex, subStrings, subStringsIndex++);
- break;
-
- case '[':
- try
- {
- ++patternIndex;
- char stringChar = string.charAt(stringIndex);
- char rangeStartChar = patternChar;
-
- while (true)
- {
- if (rangeStartChar == ']')
- {
- return false;
- }
-
- if (rangeStartChar == stringChar)
- {
- break;
- }
-
- ++patternIndex;
- char nextPatternChar = patternChar;
- if (nextPatternChar == '-')
- {
- ++patternIndex;
- char rangeEndChar = patternChar;
- if (rangeStartChar <= stringChar && stringChar <= rangeEndChar)
- {
- break;
- }
-
- ++patternIndex;
- nextPatternChar = patternChar;
- }
-
- rangeStartChar = nextPatternChar;
- }
-
- patternIndex = pattern.indexOf(']', patternIndex) + 1;
- if (patternIndex <= 0)
- {
- return false;
- }
-
- globRemember(string, stringIndex, ++stringIndex, subStrings, subStringsIndex++);
- }
- catch (StringIndexOutOfBoundsException ex)
- {
- return false;
- }
-
- break;
-
- case '\\':
- if (++patternIndex >= patternLength)
- {
- return false;
- }
-
- //$FALL-THROUGH$
- default:
- if (patternChar++ != string.charAt(stringIndex++))
- {
- return false;
- }
- }
- }
- }
-
- private static void globRemember(String string, int start, int end, String[] subStrings, int subStringsIndex)
- {
- if (subStrings != null && subStringsIndex < subStrings.length)
- {
- subStrings[subStringsIndex] = string.substring(start, end);
- }
- }
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util;
+
+import org.eclipse.net4j.util.om.OMPlatform;
+
+import java.io.ByteArrayOutputStream;
+import java.io.PrintStream;
+
+/**
+ * Various static helper methods for dealing with strings.
+ *
+ * @author Eike Stepper
+ */
+public final class StringUtil
+{
+ public static final String EMPTY = ""; //$NON-NLS-1$
+
+ public static final String NL = OMPlatform.INSTANCE.getProperty("line.separator"); //$NON-NLS-1$
+
+ private StringUtil()
+ {
+ }
+
+ /**
+ * @since 2.0
+ */
+ public static String formatException(Throwable t)
+ {
+ ByteArrayOutputStream baos = new ByteArrayOutputStream();
+ PrintStream s = new PrintStream(baos);
+ t.printStackTrace(s);
+ return baos.toString();
+ }
+
+ public static String replace(String text, String[] find, String[] replace)
+ {
+ for (int i = 0; i < find.length; i++)
+ {
+ int end = 0;
+ for (;;)
+ {
+ int start = text.indexOf(find[i], end);
+ if (start == -1)
+ {
+ break;
+ }
+
+ end = start + find[i].length();
+ text = text.substring(0, start) + replace[i] + text.substring(end);
+ }
+ }
+
+ return text;
+ }
+
+ public static String safe(String str)
+ {
+ if (str == null)
+ {
+ return EMPTY;
+ }
+
+ return str;
+ }
+
+ public static int compare(String s1, String s2)
+ {
+ if (s1 == null)
+ {
+ return s2 == null ? 0 : -1;
+ }
+
+ if (s2 == null)
+ {
+ return 1;
+ }
+
+ return s1.compareTo(s2);
+ }
+
+ /**
+ * @since 3.1
+ */
+ public static boolean equalsUpperOrLowerCase(String s, String upperOrLowerCase)
+ {
+ if (s == null)
+ {
+ return upperOrLowerCase == null;
+ }
+
+ return s.equals(upperOrLowerCase.toLowerCase()) || s.equals(upperOrLowerCase.toUpperCase());
+ }
+
+ /**
+ * @since 2.0
+ */
+ public static String capAll(String str)
+ {
+ if (str == null || str.length() == 0)
+ {
+ return str;
+ }
+
+ boolean inWhiteSpace = true;
+ StringBuilder builder = new StringBuilder(str);
+ for (int i = 0; i < builder.length(); i++)
+ {
+ char c = builder.charAt(i);
+ boolean isWhiteSpace = Character.isWhitespace(c);
+ if (!isWhiteSpace && inWhiteSpace)
+ {
+ builder.setCharAt(i, Character.toUpperCase(c));
+ }
+
+ inWhiteSpace = isWhiteSpace;
+ }
+
+ return builder.toString();
+ }
+
+ /**
+ * @since 2.0
+ */
+ public static String uncapAll(String str)
+ {
+ if (str == null || str.length() == 0)
+ {
+ return str;
+ }
+
+ boolean inWhiteSpace = true;
+ StringBuilder builder = new StringBuilder(str);
+ for (int i = 0; i < builder.length(); i++)
+ {
+ char c = builder.charAt(i);
+ boolean isWhiteSpace = Character.isWhitespace(c);
+ if (!isWhiteSpace && inWhiteSpace)
+ {
+ builder.setCharAt(i, Character.toLowerCase(c));
+ }
+
+ inWhiteSpace = isWhiteSpace;
+ }
+
+ return builder.toString();
+ }
+
+ public static String cap(String str)
+ {
+ if (str == null || str.length() == 0)
+ {
+ return str;
+ }
+
+ char first = str.charAt(0);
+ if (Character.isUpperCase(first))
+ {
+ return str;
+ }
+
+ if (str.length() == 1)
+ {
+ return str.toUpperCase();
+ }
+
+ StringBuilder builder = new StringBuilder(str);
+ builder.setCharAt(0, Character.toUpperCase(first));
+ return builder.toString();
+ }
+
+ public static String uncap(String str)
+ {
+ if (str == null || str.length() == 0)
+ {
+ return str;
+ }
+
+ char first = str.charAt(0);
+ if (Character.isLowerCase(first))
+ {
+ return str;
+ }
+
+ if (str.length() == 1)
+ {
+ return str.toLowerCase();
+ }
+
+ StringBuilder builder = new StringBuilder(str);
+ builder.setCharAt(0, Character.toLowerCase(first));
+ return builder.toString();
+ }
+
+ public static int occurrences(String str, char c)
+ {
+ int count = 0;
+ for (int i = 0; (i = str.indexOf(c, i)) != -1; ++i)
+ {
+ ++count;
+ }
+
+ return count;
+ }
+
+ public static int occurrences(String str, String c)
+ {
+ int count = 0;
+ for (int i = 0; (i = str.indexOf(c, i)) != -1; i += c.length())
+ {
+ ++count;
+ }
+
+ return count;
+ }
+
+ public static boolean isEmpty(String str)
+ {
+ return ObjectUtil.isEmpty(str);
+ }
+
+ /**
+ * Matches a string against a pattern.
+ *
+ * Pattern description:
+ *
+ * * matches 0 or more characters
+ * ? matches a single character
+ * [...] matches a set and/or range of characters
+ * \ escapes the following character
+ *
+ *
+ * @since 2.0
+ */
+ public static boolean glob(String pattern, String string)
+ {
+ return glob(pattern, string, null);
+ }
+
+ /**
+ * Matches a string against a pattern and fills an array with the sub-matches.
+ *
+ * Pattern description:
+ *
+ * * matches 0 or more characters
+ * ? matches a single character
+ * [...] matches a set and/or range of characters
+ * \ escapes the following character
+ *
+ *
+ * @since 2.0
+ */
+ public static boolean glob(String pattern, String string, String[] subStrings)
+ {
+ return globRecurse(pattern, 0, string, 0, subStrings, 0);
+ }
+
+ private static boolean globRecurse(String pattern, int patternIndex, String string, int stringIndex,
+ String[] subStrings, int subStringsIndex)
+ {
+ int patternLength = pattern.length();
+ int stringLength = string.length();
+
+ for (;;)
+ {
+ char patternChar = pattern.charAt(patternIndex);
+ boolean endReached = stringIndex == stringLength;
+ if (patternIndex == patternLength)
+ {
+ return endReached;
+ }
+ else if (endReached && patternChar != '*')
+ {
+ return false;
+ }
+
+ switch (patternChar)
+ {
+ case '*':
+ {
+ int startIndex = stringIndex;
+ if (++patternIndex >= patternLength)
+ {
+ globRemember(string, startIndex, stringLength, subStrings, subStringsIndex);
+ return true;
+ }
+
+ for (;;)
+ {
+ if (globRecurse(pattern, patternIndex, string, stringIndex, subStrings, subStringsIndex + 1))
+ {
+ globRemember(string, startIndex, stringIndex, subStrings, subStringsIndex);
+ return true;
+ }
+
+ if (endReached)
+ {
+ return false;
+ }
+
+ ++stringIndex;
+ }
+ }
+
+ case '?':
+ ++patternIndex;
+ globRemember(string, stringIndex, ++stringIndex, subStrings, subStringsIndex++);
+ break;
+
+ case '[':
+ try
+ {
+ ++patternIndex;
+ char stringChar = string.charAt(stringIndex);
+ char rangeStartChar = patternChar;
+
+ while (true)
+ {
+ if (rangeStartChar == ']')
+ {
+ return false;
+ }
+
+ if (rangeStartChar == stringChar)
+ {
+ break;
+ }
+
+ ++patternIndex;
+ char nextPatternChar = patternChar;
+ if (nextPatternChar == '-')
+ {
+ ++patternIndex;
+ char rangeEndChar = patternChar;
+ if (rangeStartChar <= stringChar && stringChar <= rangeEndChar)
+ {
+ break;
+ }
+
+ ++patternIndex;
+ nextPatternChar = patternChar;
+ }
+
+ rangeStartChar = nextPatternChar;
+ }
+
+ patternIndex = pattern.indexOf(']', patternIndex) + 1;
+ if (patternIndex <= 0)
+ {
+ return false;
+ }
+
+ globRemember(string, stringIndex, ++stringIndex, subStrings, subStringsIndex++);
+ }
+ catch (StringIndexOutOfBoundsException ex)
+ {
+ return false;
+ }
+
+ break;
+
+ case '\\':
+ if (++patternIndex >= patternLength)
+ {
+ return false;
+ }
+
+ //$FALL-THROUGH$
+ default:
+ if (patternChar++ != string.charAt(stringIndex++))
+ {
+ return false;
+ }
+ }
+ }
+ }
+
+ private static void globRemember(String string, int start, int end, String[] subStrings, int subStringsIndex)
+ {
+ if (subStrings != null && subStringsIndex < subStrings.length)
+ {
+ subStrings[subStringsIndex] = string.substring(start, end);
+ }
+ }
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/UUIDGenerator.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/UUIDGenerator.java
index 1ac1fa0167..82a1f8e45a 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/UUIDGenerator.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/UUIDGenerator.java
@@ -1,5 +1,5 @@
/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/WrappedException.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/WrappedException.java
index 64f09560bf..7ee8967faf 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/WrappedException.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/WrappedException.java
@@ -1,66 +1,66 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util;
-
-/**
- * An unchecked exception that wraps a checked exception. Wrapping occurs conditionally in the static
- * {@link #wrap(Exception, String) wrap()} methods.
- *
- * @author Eike Stepper
- * @noextend This class is not intended to be subclassed by clients.
- */
-public class WrappedException extends RuntimeException
-{
- private static final long serialVersionUID = 1L;
-
- private WrappedException(Exception exception)
- {
- super(exception);
- }
-
- private WrappedException(String message, Exception exception)
- {
- super(message, exception);
- }
-
- public Exception exception()
- {
- return (Exception)getCause();
- }
-
- /**
- * @since 3.1
- */
- public static RuntimeException wrap(Exception exception, String message)
- {
- return new WrappedException(message, exception);
- }
-
- public static RuntimeException wrap(Exception exception)
- {
- if (exception instanceof RuntimeException)
- {
- return (RuntimeException)exception;
- }
-
- return new WrappedException(exception);
- }
-
- public static Exception unwrap(Exception exception)
- {
- if (exception instanceof WrappedException)
- {
- return ((WrappedException)exception).exception();
- }
-
- return exception;
- }
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util;
+
+/**
+ * An unchecked exception that wraps a checked exception. Wrapping occurs conditionally in the static
+ * {@link #wrap(Exception, String) wrap()} methods.
+ *
+ * @author Eike Stepper
+ * @noextend This class is not intended to be subclassed by clients.
+ */
+public class WrappedException extends RuntimeException
+{
+ private static final long serialVersionUID = 1L;
+
+ private WrappedException(Exception exception)
+ {
+ super(exception);
+ }
+
+ private WrappedException(String message, Exception exception)
+ {
+ super(message, exception);
+ }
+
+ public Exception exception()
+ {
+ return (Exception)getCause();
+ }
+
+ /**
+ * @since 3.1
+ */
+ public static RuntimeException wrap(Exception exception, String message)
+ {
+ return new WrappedException(message, exception);
+ }
+
+ public static RuntimeException wrap(Exception exception)
+ {
+ if (exception instanceof RuntimeException)
+ {
+ return (RuntimeException)exception;
+ }
+
+ return new WrappedException(exception);
+ }
+
+ public static Exception unwrap(Exception exception)
+ {
+ if (exception instanceof WrappedException)
+ {
+ return ((WrappedException)exception).exception();
+ }
+
+ return exception;
+ }
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/Cache.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/Cache.java
index 00b6908a0a..c4de6167a0 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/Cache.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/Cache.java
@@ -1,108 +1,108 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util.cache;
-
-import org.eclipse.net4j.internal.util.bundle.OM;
-import org.eclipse.net4j.util.concurrent.Worker;
-import org.eclipse.net4j.util.om.trace.ContextTracer;
-
-import java.lang.ref.Reference;
-import java.lang.ref.ReferenceQueue;
-
-/**
- * @author Eike Stepper
- */
-public abstract class Cache extends Worker implements ICache
-{
- private static final ContextTracer TRACER = new ContextTracer(OM.DEBUG, Cache.class);
-
- private ICacheMonitor cacheMonitor;
-
- private ICacheProbe cacheProbe;
-
- private ReferenceQueue referenceQueue = new ReferenceQueue();
-
- public Cache()
- {
- }
-
- public ICacheMonitor getCacheMonitor()
- {
- return cacheMonitor;
- }
-
- public void setCacheMonitor(ICacheMonitor cacheMonitor)
- {
- this.cacheMonitor = cacheMonitor;
- }
-
- protected ICacheProbe getCacheProbe()
- {
- return cacheProbe;
- }
-
- protected ReferenceQueue getReferenceQueue()
- {
- return referenceQueue;
- }
-
- @Override
- protected void doBeforeActivate() throws Exception
- {
- super.doBeforeActivate();
- if (cacheMonitor == null)
- {
- throw new IllegalStateException("cacheMonitor == null"); //$NON-NLS-1$
- }
- }
-
- @Override
- protected void doActivate() throws Exception
- {
- super.doActivate();
- cacheProbe = cacheMonitor.registerCache(this);
- }
-
- @Override
- protected void doDeactivate() throws Exception
- {
- cacheMonitor.deregisterCache(this);
- cacheProbe = null;
- super.doDeactivate();
- }
-
- @Override
- protected void work(WorkContext context) throws Exception
- {
- Reference reference = referenceQueue.remove(200);
- if (reference != null)
- {
- unreachableElement(reference);
- }
- }
-
- protected void unreachableElement(Reference reference)
- {
- E element = reference.get();
- if (element != null)
- {
- unreachableElement(element);
- }
- }
-
- protected void unreachableElement(E element)
- {
- if (TRACER.isEnabled())
- {
- TRACER.trace("Unreachable: " + element); //$NON-NLS-1$
- }
- }
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util.cache;
+
+import org.eclipse.net4j.internal.util.bundle.OM;
+import org.eclipse.net4j.util.concurrent.Worker;
+import org.eclipse.net4j.util.om.trace.ContextTracer;
+
+import java.lang.ref.Reference;
+import java.lang.ref.ReferenceQueue;
+
+/**
+ * @author Eike Stepper
+ */
+public abstract class Cache extends Worker implements ICache
+{
+ private static final ContextTracer TRACER = new ContextTracer(OM.DEBUG, Cache.class);
+
+ private ICacheMonitor cacheMonitor;
+
+ private ICacheProbe cacheProbe;
+
+ private ReferenceQueue referenceQueue = new ReferenceQueue();
+
+ public Cache()
+ {
+ }
+
+ public ICacheMonitor getCacheMonitor()
+ {
+ return cacheMonitor;
+ }
+
+ public void setCacheMonitor(ICacheMonitor cacheMonitor)
+ {
+ this.cacheMonitor = cacheMonitor;
+ }
+
+ protected ICacheProbe getCacheProbe()
+ {
+ return cacheProbe;
+ }
+
+ protected ReferenceQueue getReferenceQueue()
+ {
+ return referenceQueue;
+ }
+
+ @Override
+ protected void doBeforeActivate() throws Exception
+ {
+ super.doBeforeActivate();
+ if (cacheMonitor == null)
+ {
+ throw new IllegalStateException("cacheMonitor == null"); //$NON-NLS-1$
+ }
+ }
+
+ @Override
+ protected void doActivate() throws Exception
+ {
+ super.doActivate();
+ cacheProbe = cacheMonitor.registerCache(this);
+ }
+
+ @Override
+ protected void doDeactivate() throws Exception
+ {
+ cacheMonitor.deregisterCache(this);
+ cacheProbe = null;
+ super.doDeactivate();
+ }
+
+ @Override
+ protected void work(WorkContext context) throws Exception
+ {
+ Reference reference = referenceQueue.remove(200);
+ if (reference != null)
+ {
+ unreachableElement(reference);
+ }
+ }
+
+ protected void unreachableElement(Reference reference)
+ {
+ E element = reference.get();
+ if (element != null)
+ {
+ unreachableElement(element);
+ }
+ }
+
+ protected void unreachableElement(E element)
+ {
+ if (TRACER.isEnabled())
+ {
+ TRACER.trace("Unreachable: " + element); //$NON-NLS-1$
+ }
+ }
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/CacheMonitor.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/CacheMonitor.java
index 9ad020d686..f4dc24ce36 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/CacheMonitor.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/CacheMonitor.java
@@ -1,251 +1,251 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util.cache;
-
-import org.eclipse.net4j.internal.util.bundle.OM;
-import org.eclipse.net4j.util.ImplementationError;
-import org.eclipse.net4j.util.concurrent.Worker;
-import org.eclipse.net4j.util.event.Event;
-import org.eclipse.net4j.util.event.IListener;
-import org.eclipse.net4j.util.om.trace.ContextTracer;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * @author Eike Stepper
- */
-public class CacheMonitor extends Worker implements ICacheMonitor
-{
- // percentFreeAllocated = Round((freeMemory / totalMemory) * 100);
- // percentAllocated = Round((totalMemory / maxMemory ) * 100);
-
- private static final ContextTracer TRACER = new ContextTracer(OM.DEBUG, CacheMonitor.class);
-
- private static final long DEFAULT_PAUSE_GREEN = 60L * 1000L; // 1 minute
-
- private static final long DEFAULT_PAUSE_YELLOW = 5L * 1000L; // 5 seconds
-
- private static final long DEFAULT_PAUSE_RED = 100L; // 100 milliseconds
-
- private long pauseGREEN = DEFAULT_PAUSE_GREEN;
-
- private long pauseYELLOW = DEFAULT_PAUSE_YELLOW;
-
- private long pauseRED = DEFAULT_PAUSE_RED;
-
- private ConditionPolicy conditionPolicy;
-
- private Condition condition;
-
- private Map registrations = new HashMap();
-
- public CacheMonitor()
- {
- }
-
- public long getPauseGREEN()
- {
- return pauseGREEN;
- }
-
- public void setPauseGREEN(long pauseGREEN)
- {
- this.pauseGREEN = pauseGREEN;
- }
-
- public long getPauseYELLOW()
- {
- return pauseYELLOW;
- }
-
- public void setPauseYELLOW(long pauseYELLOW)
- {
- this.pauseYELLOW = pauseYELLOW;
- }
-
- public long getPauseRED()
- {
- return pauseRED;
- }
-
- public void setPauseRED(long pauseRED)
- {
- this.pauseRED = pauseRED;
- }
-
- public ConditionPolicy getConditionPolicy()
- {
- return conditionPolicy;
- }
-
- public void setConditionPolicy(ConditionPolicy conditionPolicy)
- {
- this.conditionPolicy = conditionPolicy;
- }
-
- public Condition getCondition()
- {
- return condition;
- }
-
- public ICacheRegistration[] getRegistrations()
- {
- synchronized (registrations)
- {
- return registrations.values().toArray(new ICacheRegistration[registrations.size()]);
- }
- }
-
- public ICacheRegistration registerCache(ICache cache)
- {
- if (TRACER.isEnabled())
- {
- TRACER.trace("Registering cache " + cache); //$NON-NLS-1$
- }
-
- ICacheRegistration registration = new CacheRegistration(this, cache);
- ICacheRegistration oldRegistration;
- synchronized (registrations)
- {
- oldRegistration = registrations.put(cache, registration);
- }
-
- if (oldRegistration != null)
- {
- oldRegistration.dispose();
- }
-
- return registration;
- }
-
- public void deregisterCache(ICache cache)
- {
- ICacheRegistration registration;
- synchronized (registrations)
- {
- registration = registrations.remove(cache);
- }
-
- if (registration != null)
- {
- registration.dispose();
- if (TRACER.isEnabled())
- {
- TRACER.trace("Deregistered cache " + cache); //$NON-NLS-1$
- }
- }
- }
-
- @Override
- protected void doBeforeActivate() throws Exception
- {
- super.doBeforeActivate();
- if (conditionPolicy == null)
- {
- throw new IllegalStateException("conditionPolicy == null"); //$NON-NLS-1$
- }
- }
-
- @Override
- protected void doDeactivate() throws Exception
- {
- for (ICacheRegistration registration : getRegistrations())
- {
- registration.dispose();
- }
-
- registrations.clear();
- super.doDeactivate();
- }
-
- @Override
- protected void work(WorkContext context) throws Exception
- {
- Condition newCondition = conditionPolicy.getNewCondition(condition);
- setCondition(newCondition);
-
- switch (newCondition)
- {
- case GREEN:
- context.nextWork(pauseGREEN);
- break;
-
- case YELLOW:
- context.nextWork(pauseYELLOW);
- break;
-
- case RED:
- handleConditionRED();
- context.nextWork(pauseRED);
- break;
- }
- }
-
- protected void setCondition(Condition newCondition)
- {
- if (newCondition == null)
- {
- throw new ImplementationError("newCondition == null"); //$NON-NLS-1$
- }
-
- Condition oldCondition = condition;
- if (newCondition != oldCondition)
- {
- condition = newCondition;
- IListener[] listeners = getListeners();
- if (listeners != null)
- {
- fireEvent(new CacheMonitorEvent(oldCondition, newCondition), listeners);
- }
- }
- }
-
- protected void handleConditionRED()
- {
- OM.LOG.warn("CONDITION RED"); //$NON-NLS-1$
- }
-
- /**
- * @author Eike Stepper
- */
- private final class CacheMonitorEvent extends Event implements ICacheMonitorEvent
- {
- private static final long serialVersionUID = 1L;
-
- private Condition oldCondition;
-
- private Condition newCondition;
-
- public CacheMonitorEvent(Condition oldCondition, Condition newCondition)
- {
- super(CacheMonitor.this);
- this.oldCondition = oldCondition;
- this.newCondition = newCondition;
- }
-
- @Override
- public ICacheMonitor getSource()
- {
- return (ICacheMonitor)super.getSource();
- }
-
- public Condition getOldCondition()
- {
- return oldCondition;
- }
-
- public Condition getNewCondition()
- {
- return newCondition;
- }
- }
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util.cache;
+
+import org.eclipse.net4j.internal.util.bundle.OM;
+import org.eclipse.net4j.util.ImplementationError;
+import org.eclipse.net4j.util.concurrent.Worker;
+import org.eclipse.net4j.util.event.Event;
+import org.eclipse.net4j.util.event.IListener;
+import org.eclipse.net4j.util.om.trace.ContextTracer;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author Eike Stepper
+ */
+public class CacheMonitor extends Worker implements ICacheMonitor
+{
+ // percentFreeAllocated = Round((freeMemory / totalMemory) * 100);
+ // percentAllocated = Round((totalMemory / maxMemory ) * 100);
+
+ private static final ContextTracer TRACER = new ContextTracer(OM.DEBUG, CacheMonitor.class);
+
+ private static final long DEFAULT_PAUSE_GREEN = 60L * 1000L; // 1 minute
+
+ private static final long DEFAULT_PAUSE_YELLOW = 5L * 1000L; // 5 seconds
+
+ private static final long DEFAULT_PAUSE_RED = 100L; // 100 milliseconds
+
+ private long pauseGREEN = DEFAULT_PAUSE_GREEN;
+
+ private long pauseYELLOW = DEFAULT_PAUSE_YELLOW;
+
+ private long pauseRED = DEFAULT_PAUSE_RED;
+
+ private ConditionPolicy conditionPolicy;
+
+ private Condition condition;
+
+ private Map registrations = new HashMap();
+
+ public CacheMonitor()
+ {
+ }
+
+ public long getPauseGREEN()
+ {
+ return pauseGREEN;
+ }
+
+ public void setPauseGREEN(long pauseGREEN)
+ {
+ this.pauseGREEN = pauseGREEN;
+ }
+
+ public long getPauseYELLOW()
+ {
+ return pauseYELLOW;
+ }
+
+ public void setPauseYELLOW(long pauseYELLOW)
+ {
+ this.pauseYELLOW = pauseYELLOW;
+ }
+
+ public long getPauseRED()
+ {
+ return pauseRED;
+ }
+
+ public void setPauseRED(long pauseRED)
+ {
+ this.pauseRED = pauseRED;
+ }
+
+ public ConditionPolicy getConditionPolicy()
+ {
+ return conditionPolicy;
+ }
+
+ public void setConditionPolicy(ConditionPolicy conditionPolicy)
+ {
+ this.conditionPolicy = conditionPolicy;
+ }
+
+ public Condition getCondition()
+ {
+ return condition;
+ }
+
+ public ICacheRegistration[] getRegistrations()
+ {
+ synchronized (registrations)
+ {
+ return registrations.values().toArray(new ICacheRegistration[registrations.size()]);
+ }
+ }
+
+ public ICacheRegistration registerCache(ICache cache)
+ {
+ if (TRACER.isEnabled())
+ {
+ TRACER.trace("Registering cache " + cache); //$NON-NLS-1$
+ }
+
+ ICacheRegistration registration = new CacheRegistration(this, cache);
+ ICacheRegistration oldRegistration;
+ synchronized (registrations)
+ {
+ oldRegistration = registrations.put(cache, registration);
+ }
+
+ if (oldRegistration != null)
+ {
+ oldRegistration.dispose();
+ }
+
+ return registration;
+ }
+
+ public void deregisterCache(ICache cache)
+ {
+ ICacheRegistration registration;
+ synchronized (registrations)
+ {
+ registration = registrations.remove(cache);
+ }
+
+ if (registration != null)
+ {
+ registration.dispose();
+ if (TRACER.isEnabled())
+ {
+ TRACER.trace("Deregistered cache " + cache); //$NON-NLS-1$
+ }
+ }
+ }
+
+ @Override
+ protected void doBeforeActivate() throws Exception
+ {
+ super.doBeforeActivate();
+ if (conditionPolicy == null)
+ {
+ throw new IllegalStateException("conditionPolicy == null"); //$NON-NLS-1$
+ }
+ }
+
+ @Override
+ protected void doDeactivate() throws Exception
+ {
+ for (ICacheRegistration registration : getRegistrations())
+ {
+ registration.dispose();
+ }
+
+ registrations.clear();
+ super.doDeactivate();
+ }
+
+ @Override
+ protected void work(WorkContext context) throws Exception
+ {
+ Condition newCondition = conditionPolicy.getNewCondition(condition);
+ setCondition(newCondition);
+
+ switch (newCondition)
+ {
+ case GREEN:
+ context.nextWork(pauseGREEN);
+ break;
+
+ case YELLOW:
+ context.nextWork(pauseYELLOW);
+ break;
+
+ case RED:
+ handleConditionRED();
+ context.nextWork(pauseRED);
+ break;
+ }
+ }
+
+ protected void setCondition(Condition newCondition)
+ {
+ if (newCondition == null)
+ {
+ throw new ImplementationError("newCondition == null"); //$NON-NLS-1$
+ }
+
+ Condition oldCondition = condition;
+ if (newCondition != oldCondition)
+ {
+ condition = newCondition;
+ IListener[] listeners = getListeners();
+ if (listeners != null)
+ {
+ fireEvent(new CacheMonitorEvent(oldCondition, newCondition), listeners);
+ }
+ }
+ }
+
+ protected void handleConditionRED()
+ {
+ OM.LOG.warn("CONDITION RED"); //$NON-NLS-1$
+ }
+
+ /**
+ * @author Eike Stepper
+ */
+ private final class CacheMonitorEvent extends Event implements ICacheMonitorEvent
+ {
+ private static final long serialVersionUID = 1L;
+
+ private Condition oldCondition;
+
+ private Condition newCondition;
+
+ public CacheMonitorEvent(Condition oldCondition, Condition newCondition)
+ {
+ super(CacheMonitor.this);
+ this.oldCondition = oldCondition;
+ this.newCondition = newCondition;
+ }
+
+ @Override
+ public ICacheMonitor getSource()
+ {
+ return (ICacheMonitor)super.getSource();
+ }
+
+ public Condition getOldCondition()
+ {
+ return oldCondition;
+ }
+
+ public Condition getNewCondition()
+ {
+ return newCondition;
+ }
+ }
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/CacheRegistration.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/CacheRegistration.java
index a6b8fe976f..43e5f0edf2 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/CacheRegistration.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/CacheRegistration.java
@@ -1,110 +1,110 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util.cache;
-
-/**
- * @author Eike Stepper
- */
-public class CacheRegistration implements ICacheRegistration
-{
- public static final float DEFAULT_RECONSTRUCTION_COST_DECAY_FACTOR = 0.1f;
-
- private ICacheMonitor cacheMonitor;
-
- private ICache cache;
-
- private int elementCount;
-
- private long cacheSize;
-
- private long reconstructionCost;
-
- public CacheRegistration(ICacheMonitor cacheMonitor, ICache cache)
- {
- this.cacheMonitor = cacheMonitor;
- this.cache = cache;
- }
-
- public void dispose()
- {
- cacheMonitor = null;
- cache = null;
- }
-
- public boolean isDisposed()
- {
- return cacheMonitor == null || cache == null;
- }
-
- public ICacheMonitor getCacheMonitor()
- {
- return cacheMonitor;
- }
-
- public ICache getCache()
- {
- return cache;
- }
-
- public int getElementCount()
- {
- return elementCount;
- }
-
- public long getCacheSize()
- {
- return cacheSize;
- }
-
- public long getAverageElementSize()
- {
- return cacheSize / elementCount;
- }
-
- public long getReconstructionCost()
- {
- return reconstructionCost;
- }
-
- public void elementCached(int elementSize)
- {
- checkDisposal();
- ++elementCount;
- cacheSize += elementSize;
- }
-
- public void elementEvicted(int elementSize)
- {
- checkDisposal();
- --elementCount;
- cacheSize -= elementSize;
- }
-
- public void elementReconstructed(long reconstructionTime)
- {
- checkDisposal();
- float decayFactor = getReconstructionCostDecayFactor();
- reconstructionCost = (long)(decayFactor * reconstructionCost + (1 - decayFactor) * reconstructionTime);
- }
-
- protected float getReconstructionCostDecayFactor()
- {
- return DEFAULT_RECONSTRUCTION_COST_DECAY_FACTOR;
- }
-
- private void checkDisposal()
- {
- if (isDisposed())
- {
- throw new IllegalStateException("disposed"); //$NON-NLS-1$
- }
- }
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util.cache;
+
+/**
+ * @author Eike Stepper
+ */
+public class CacheRegistration implements ICacheRegistration
+{
+ public static final float DEFAULT_RECONSTRUCTION_COST_DECAY_FACTOR = 0.1f;
+
+ private ICacheMonitor cacheMonitor;
+
+ private ICache cache;
+
+ private int elementCount;
+
+ private long cacheSize;
+
+ private long reconstructionCost;
+
+ public CacheRegistration(ICacheMonitor cacheMonitor, ICache cache)
+ {
+ this.cacheMonitor = cacheMonitor;
+ this.cache = cache;
+ }
+
+ public void dispose()
+ {
+ cacheMonitor = null;
+ cache = null;
+ }
+
+ public boolean isDisposed()
+ {
+ return cacheMonitor == null || cache == null;
+ }
+
+ public ICacheMonitor getCacheMonitor()
+ {
+ return cacheMonitor;
+ }
+
+ public ICache getCache()
+ {
+ return cache;
+ }
+
+ public int getElementCount()
+ {
+ return elementCount;
+ }
+
+ public long getCacheSize()
+ {
+ return cacheSize;
+ }
+
+ public long getAverageElementSize()
+ {
+ return cacheSize / elementCount;
+ }
+
+ public long getReconstructionCost()
+ {
+ return reconstructionCost;
+ }
+
+ public void elementCached(int elementSize)
+ {
+ checkDisposal();
+ ++elementCount;
+ cacheSize += elementSize;
+ }
+
+ public void elementEvicted(int elementSize)
+ {
+ checkDisposal();
+ --elementCount;
+ cacheSize -= elementSize;
+ }
+
+ public void elementReconstructed(long reconstructionTime)
+ {
+ checkDisposal();
+ float decayFactor = getReconstructionCostDecayFactor();
+ reconstructionCost = (long)(decayFactor * reconstructionCost + (1 - decayFactor) * reconstructionTime);
+ }
+
+ protected float getReconstructionCostDecayFactor()
+ {
+ return DEFAULT_RECONSTRUCTION_COST_DECAY_FACTOR;
+ }
+
+ private void checkDisposal()
+ {
+ if (isDisposed())
+ {
+ throw new IllegalStateException("disposed"); //$NON-NLS-1$
+ }
+ }
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/HysteresisConditionPolicy.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/HysteresisConditionPolicy.java
index d6a6c08c1b..a341c9fe97 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/HysteresisConditionPolicy.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/HysteresisConditionPolicy.java
@@ -1,105 +1,105 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util.cache;
-
-import org.eclipse.net4j.util.cache.ICacheMonitor.Condition;
-
-/**
- * @author Eike Stepper
- */
-public class HysteresisConditionPolicy extends ThresholdConditionPolicy
-{
- private long thresholdYellowRed;
-
- private long thresholdGreenYellow;
-
- public HysteresisConditionPolicy(long thresholdYellowRed, long thresholdRedYellow, long thresholdGreenYellow,
- long thresholdYellowGreen)
- {
- super(thresholdRedYellow, thresholdYellowGreen);
- if (thresholdYellowRed > thresholdRedYellow)
- {
- throw new IllegalArgumentException("thresholdYellowRed > thresholdRedYellow"); //$NON-NLS-1$
- }
-
- if (thresholdRedYellow > thresholdGreenYellow)
- {
- throw new IllegalArgumentException("thresholdRedYellow > thresholdGreenYellow"); //$NON-NLS-1$
- }
-
- if (thresholdGreenYellow > thresholdYellowGreen)
- {
- throw new IllegalArgumentException("thresholdGreenYellow > thresholdYellowGreen"); //$NON-NLS-1$
- }
-
- this.thresholdGreenYellow = thresholdGreenYellow;
- this.thresholdYellowRed = thresholdYellowRed;
- }
-
- public long getThresholdYellowRed()
- {
- return thresholdYellowRed;
- }
-
- public long getThresholdGreenYellow()
- {
- return thresholdGreenYellow;
- }
-
- @Override
- protected Condition getNewCondition(Condition oldCondition, long freeMemory)
- {
- switch (oldCondition)
- {
- case GREEN:
- if (freeMemory < thresholdYellowRed)
- {
- return Condition.RED;
- }
-
- if (freeMemory < thresholdGreenYellow)
- {
- return Condition.YELLOW;
- }
-
- return Condition.GREEN;
-
- case YELLOW:
- if (freeMemory < thresholdYellowRed)
- {
- return Condition.RED;
- }
-
- if (freeMemory > getThresholdYellowGreen())
- {
- return Condition.GREEN;
- }
-
- return Condition.YELLOW;
-
- case RED:
- if (freeMemory > getThresholdYellowGreen())
- {
- return Condition.GREEN;
- }
-
- if (freeMemory > getThresholdRedYellow())
- {
- return Condition.YELLOW;
- }
-
- return Condition.RED;
-
- default:
- throw new IllegalArgumentException("oldCondition == " + oldCondition); //$NON-NLS-1$
- }
- }
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util.cache;
+
+import org.eclipse.net4j.util.cache.ICacheMonitor.Condition;
+
+/**
+ * @author Eike Stepper
+ */
+public class HysteresisConditionPolicy extends ThresholdConditionPolicy
+{
+ private long thresholdYellowRed;
+
+ private long thresholdGreenYellow;
+
+ public HysteresisConditionPolicy(long thresholdYellowRed, long thresholdRedYellow, long thresholdGreenYellow,
+ long thresholdYellowGreen)
+ {
+ super(thresholdRedYellow, thresholdYellowGreen);
+ if (thresholdYellowRed > thresholdRedYellow)
+ {
+ throw new IllegalArgumentException("thresholdYellowRed > thresholdRedYellow"); //$NON-NLS-1$
+ }
+
+ if (thresholdRedYellow > thresholdGreenYellow)
+ {
+ throw new IllegalArgumentException("thresholdRedYellow > thresholdGreenYellow"); //$NON-NLS-1$
+ }
+
+ if (thresholdGreenYellow > thresholdYellowGreen)
+ {
+ throw new IllegalArgumentException("thresholdGreenYellow > thresholdYellowGreen"); //$NON-NLS-1$
+ }
+
+ this.thresholdGreenYellow = thresholdGreenYellow;
+ this.thresholdYellowRed = thresholdYellowRed;
+ }
+
+ public long getThresholdYellowRed()
+ {
+ return thresholdYellowRed;
+ }
+
+ public long getThresholdGreenYellow()
+ {
+ return thresholdGreenYellow;
+ }
+
+ @Override
+ protected Condition getNewCondition(Condition oldCondition, long freeMemory)
+ {
+ switch (oldCondition)
+ {
+ case GREEN:
+ if (freeMemory < thresholdYellowRed)
+ {
+ return Condition.RED;
+ }
+
+ if (freeMemory < thresholdGreenYellow)
+ {
+ return Condition.YELLOW;
+ }
+
+ return Condition.GREEN;
+
+ case YELLOW:
+ if (freeMemory < thresholdYellowRed)
+ {
+ return Condition.RED;
+ }
+
+ if (freeMemory > getThresholdYellowGreen())
+ {
+ return Condition.GREEN;
+ }
+
+ return Condition.YELLOW;
+
+ case RED:
+ if (freeMemory > getThresholdYellowGreen())
+ {
+ return Condition.GREEN;
+ }
+
+ if (freeMemory > getThresholdRedYellow())
+ {
+ return Condition.YELLOW;
+ }
+
+ return Condition.RED;
+
+ default:
+ throw new IllegalArgumentException("oldCondition == " + oldCondition); //$NON-NLS-1$
+ }
+ }
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICache.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICache.java
index 8fd6c44e8d..43c55009fa 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICache.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICache.java
@@ -1,24 +1,24 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util.cache;
-
-/**
- * @author Eike Stepper
- */
-public interface ICache
-{
- public ICacheMonitor getCacheMonitor();
-
- /**
- * Instructs this cache to evict elementCount elements.
- */
- public void evictElements(int elementCount);
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util.cache;
+
+/**
+ * @author Eike Stepper
+ */
+public interface ICache
+{
+ public ICacheMonitor getCacheMonitor();
+
+ /**
+ * Instructs this cache to evict elementCount elements.
+ */
+ public void evictElements(int elementCount);
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheMonitor.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheMonitor.java
index d795c7bc3a..f8c9aefb6d 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheMonitor.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheMonitor.java
@@ -1,60 +1,60 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util.cache;
-
-import org.eclipse.net4j.util.event.INotifier;
-
-/**
- * @author Eike Stepper
- */
-public interface ICacheMonitor extends INotifier
-{
- public ConditionPolicy getConditionPolicy();
-
- public Condition getCondition();
-
- public ICacheProbe registerCache(ICache cache);
-
- public void deregisterCache(ICache cache);
-
- /**
- * @author Eike Stepper
- */
- public enum Condition
- {
- /**
- * Condition GREEN indicates that the system is operating normally and enough free memory is available so
- * that caches are free to cache additional elements.
- */
- GREEN,
-
- /**
- * Condition YELLOW indicates that the system is operating normally but free memory is about to go low so
- * that caches should stop to cache additional elements.
- */
- YELLOW,
-
- /**
- * Condition RED indicates that the system state is critical and free memory is almost exhausted so that
- * caches must immediately stop to cache additional elements. Depending of the eviction strategy element eviction is
- * ordered.
- */
- RED;
- }
-
- /**
- * @author Eike Stepper
- */
- public interface ConditionPolicy
- {
- public Condition getNewCondition(Condition oldCondition);
- }
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util.cache;
+
+import org.eclipse.net4j.util.event.INotifier;
+
+/**
+ * @author Eike Stepper
+ */
+public interface ICacheMonitor extends INotifier
+{
+ public ConditionPolicy getConditionPolicy();
+
+ public Condition getCondition();
+
+ public ICacheProbe registerCache(ICache cache);
+
+ public void deregisterCache(ICache cache);
+
+ /**
+ * @author Eike Stepper
+ */
+ public enum Condition
+ {
+ /**
+ * Condition GREEN indicates that the system is operating normally and enough free memory is available so
+ * that caches are free to cache additional elements.
+ */
+ GREEN,
+
+ /**
+ * Condition YELLOW indicates that the system is operating normally but free memory is about to go low so
+ * that caches should stop to cache additional elements.
+ */
+ YELLOW,
+
+ /**
+ * Condition RED indicates that the system state is critical and free memory is almost exhausted so that
+ * caches must immediately stop to cache additional elements. Depending of the eviction strategy element eviction is
+ * ordered.
+ */
+ RED;
+ }
+
+ /**
+ * @author Eike Stepper
+ */
+ public interface ConditionPolicy
+ {
+ public Condition getNewCondition(Condition oldCondition);
+ }
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheMonitorEvent.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheMonitorEvent.java
index 5f82e55068..9ebebc683e 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheMonitorEvent.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheMonitorEvent.java
@@ -1,30 +1,30 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util.cache;
-
-import org.eclipse.net4j.util.event.IEvent;
-
-/**
- * @author Eike Stepper
- * @noextend This interface is not intended to be extended by clients.
- * @noimplement This interface is not intended to be implemented by clients.
- */
-public interface ICacheMonitorEvent extends IEvent
-{
- /**
- * @since 3.0
- */
- public ICacheMonitor getSource();
-
- public ICacheMonitor.Condition getOldCondition();
-
- public ICacheMonitor.Condition getNewCondition();
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util.cache;
+
+import org.eclipse.net4j.util.event.IEvent;
+
+/**
+ * @author Eike Stepper
+ * @noextend This interface is not intended to be extended by clients.
+ * @noimplement This interface is not intended to be implemented by clients.
+ */
+public interface ICacheMonitorEvent extends IEvent
+{
+ /**
+ * @since 3.0
+ */
+ public ICacheMonitor getSource();
+
+ public ICacheMonitor.Condition getOldCondition();
+
+ public ICacheMonitor.Condition getNewCondition();
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheProbe.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheProbe.java
index b2919ed265..e4c9c93074 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheProbe.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheProbe.java
@@ -1,33 +1,33 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util.cache;
-
-/**
- * @author Eike Stepper
- */
-public interface ICacheProbe
-{
- public boolean isDisposed();
-
- public void elementCached(int elementSize);
-
- public void elementEvicted(int elementSize);
-
- public void elementReconstructed(long reconstructionTime);
-
- public int getElementCount();
-
- public long getCacheSize();
-
- public long getAverageElementSize();
-
- public long getReconstructionCost();
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util.cache;
+
+/**
+ * @author Eike Stepper
+ */
+public interface ICacheProbe
+{
+ public boolean isDisposed();
+
+ public void elementCached(int elementSize);
+
+ public void elementEvicted(int elementSize);
+
+ public void elementReconstructed(long reconstructionTime);
+
+ public int getElementCount();
+
+ public long getCacheSize();
+
+ public long getAverageElementSize();
+
+ public long getReconstructionCost();
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheRegistration.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheRegistration.java
index 3a95717d77..7cc730a3f2 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheRegistration.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ICacheRegistration.java
@@ -1,23 +1,23 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util.cache;
-
-/**
- * @author Eike Stepper
- */
-public interface ICacheRegistration extends ICacheProbe
-{
- public ICacheMonitor getCacheMonitor();
-
- public ICache getCache();
-
- public void dispose();
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util.cache;
+
+/**
+ * @author Eike Stepper
+ */
+public interface ICacheRegistration extends ICacheProbe
+{
+ public ICacheMonitor getCacheMonitor();
+
+ public ICache getCache();
+
+ public void dispose();
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ThresholdConditionPolicy.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ThresholdConditionPolicy.java
index 2883bb64d8..01a228948d 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ThresholdConditionPolicy.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/ThresholdConditionPolicy.java
@@ -1,64 +1,64 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util.cache;
-
-import org.eclipse.net4j.util.cache.ICacheMonitor.Condition;
-
-/**
- * @author Eike Stepper
- */
-public class ThresholdConditionPolicy implements ICacheMonitor.ConditionPolicy
-{
- private long thresholdRedYellow;
-
- private long thresholdYellowGreen;
-
- public ThresholdConditionPolicy(long thresholdRedYellow, long thresholdYellowGreen)
- {
- if (thresholdRedYellow > thresholdYellowGreen)
- {
- throw new IllegalArgumentException("thresholdRedYellow > thresholdYellowGreen"); //$NON-NLS-1$
- }
-
- this.thresholdRedYellow = thresholdRedYellow;
- this.thresholdYellowGreen = thresholdYellowGreen;
- }
-
- public long getThresholdRedYellow()
- {
- return thresholdRedYellow;
- }
-
- public long getThresholdYellowGreen()
- {
- return thresholdYellowGreen;
- }
-
- public Condition getNewCondition(Condition oldCondition)
- {
- return getNewCondition(oldCondition, Runtime.getRuntime().freeMemory());
- }
-
- protected Condition getNewCondition(Condition oldCondition, long freeMemory)
- {
- if (freeMemory > thresholdYellowGreen)
- {
- return Condition.GREEN;
- }
-
- if (freeMemory > thresholdRedYellow)
- {
- return Condition.YELLOW;
- }
-
- return Condition.RED;
- }
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util.cache;
+
+import org.eclipse.net4j.util.cache.ICacheMonitor.Condition;
+
+/**
+ * @author Eike Stepper
+ */
+public class ThresholdConditionPolicy implements ICacheMonitor.ConditionPolicy
+{
+ private long thresholdRedYellow;
+
+ private long thresholdYellowGreen;
+
+ public ThresholdConditionPolicy(long thresholdRedYellow, long thresholdYellowGreen)
+ {
+ if (thresholdRedYellow > thresholdYellowGreen)
+ {
+ throw new IllegalArgumentException("thresholdRedYellow > thresholdYellowGreen"); //$NON-NLS-1$
+ }
+
+ this.thresholdRedYellow = thresholdRedYellow;
+ this.thresholdYellowGreen = thresholdYellowGreen;
+ }
+
+ public long getThresholdRedYellow()
+ {
+ return thresholdRedYellow;
+ }
+
+ public long getThresholdYellowGreen()
+ {
+ return thresholdYellowGreen;
+ }
+
+ public Condition getNewCondition(Condition oldCondition)
+ {
+ return getNewCondition(oldCondition, Runtime.getRuntime().freeMemory());
+ }
+
+ protected Condition getNewCondition(Condition oldCondition, long freeMemory)
+ {
+ if (freeMemory > thresholdYellowGreen)
+ {
+ return Condition.GREEN;
+ }
+
+ if (freeMemory > thresholdRedYellow)
+ {
+ return Condition.YELLOW;
+ }
+
+ return Condition.RED;
+ }
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/package-info.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/package-info.java
index 1049573dce..dc74f11f66 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/package-info.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/cache/package-info.java
@@ -1,5 +1,5 @@
/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/collection/AbstractIterator.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/collection/AbstractIterator.java
index 897a487bb0..37a4ffd0ed 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/collection/AbstractIterator.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/collection/AbstractIterator.java
@@ -1,5 +1,5 @@
/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
* All rights reserved. This program and the accompanying materials
* are made available under the terms of the Eclipse Public License v1.0
* which accompanies this distribution, and is available at
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/collection/ArrayIterator.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/collection/ArrayIterator.java
index 9f8b282702..c7ecb0b8b9 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/collection/ArrayIterator.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/collection/ArrayIterator.java
@@ -1,72 +1,72 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util.collection;
-
-import java.util.Iterator;
-import java.util.NoSuchElementException;
-
-/**
- * An object that iterates over the elements of an array
- *
- * @author Eike Stepper
- * @since 3.0
- */
-public class ArrayIterator implements Iterator
-{
- private T[] elements;
-
- private int index;
-
- private int lastElement;
-
- public ArrayIterator(T[] elements)
- {
- this(elements, 0, elements.length - 1);
- }
-
- public ArrayIterator(T[] elements, int firstElement)
- {
- this(elements, firstElement, elements.length - 1);
- }
-
- public ArrayIterator(T[] elements, int firstElement, int lastElement)
- {
- this.elements = elements;
- index = firstElement;
- this.lastElement = lastElement;
- }
-
- public boolean hasNext()
- {
- return elements != null && index <= lastElement;
- }
-
- public T next() throws NoSuchElementException
- {
- if (!hasNext())
- {
- throw new NoSuchElementException();
- }
-
- return elements[index++];
- }
-
- /**
- * Unsupported.
- *
- * @throws UnsupportedOperationException
- * always
- */
- public void remove()
- {
- throw new UnsupportedOperationException();
- }
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util.collection;
+
+import java.util.Iterator;
+import java.util.NoSuchElementException;
+
+/**
+ * An object that iterates over the elements of an array
+ *
+ * @author Eike Stepper
+ * @since 3.0
+ */
+public class ArrayIterator implements Iterator
+{
+ private T[] elements;
+
+ private int index;
+
+ private int lastElement;
+
+ public ArrayIterator(T[] elements)
+ {
+ this(elements, 0, elements.length - 1);
+ }
+
+ public ArrayIterator(T[] elements, int firstElement)
+ {
+ this(elements, firstElement, elements.length - 1);
+ }
+
+ public ArrayIterator(T[] elements, int firstElement, int lastElement)
+ {
+ this.elements = elements;
+ index = firstElement;
+ this.lastElement = lastElement;
+ }
+
+ public boolean hasNext()
+ {
+ return elements != null && index <= lastElement;
+ }
+
+ public T next() throws NoSuchElementException
+ {
+ if (!hasNext())
+ {
+ throw new NoSuchElementException();
+ }
+
+ return elements[index++];
+ }
+
+ /**
+ * Unsupported.
+ *
+ * @throws UnsupportedOperationException
+ * always
+ */
+ public void remove()
+ {
+ throw new UnsupportedOperationException();
+ }
+}
diff --git a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/collection/BidiMapper.java b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/collection/BidiMapper.java
index 6c5867de5c..8d04d15bff 100644
--- a/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/collection/BidiMapper.java
+++ b/plugins/org.eclipse.net4j.util/src/org/eclipse/net4j/util/collection/BidiMapper.java
@@ -1,80 +1,80 @@
-/*
- * Copyright (c) 2004 - 2011 Eike Stepper (Berlin, Germany) and others.
- * All rights reserved. This program and the accompanying materials
- * are made available under the terms of the Eclipse Public License v1.0
- * which accompanies this distribution, and is available at
- * http://www.eclipse.org/legal/epl-v10.html
- *
- * Contributors:
- * Eike Stepper - initial API and implementation
- */
-package org.eclipse.net4j.util.collection;
-
-import java.util.HashMap;
-import java.util.Map;
-
-/**
- * @since 2.0
- * @author Eike Stepper
- */
-public class BidiMapper
-{
- private Map map1 = new HashMap();
-
- private Map map2 = new HashMap();
-
- public BidiMapper()
- {
- }
-
- public synchronized void map(T1 v1, T2 v2)
- {
- map1.put(v1, v2);
- map2.put(v2, v1);
- }
-
- public synchronized int size()
- {
- return map1.size();
- }
-
- public synchronized void clear()
- {
- map1.clear();
- map2.clear();
- }
-
- public synchronized T2 lookup1(T1 v1)
- {
- return map1.get(v1);
- }
-
- public synchronized T1 lookup2(T2 v2)
- {
- return map2.get(v2);
- }
-
- public synchronized boolean remove1(T1 v1)
- {
- T2 v2 = map1.remove(v1);
- if (v2 != null)
- {
- map2.remove(v2);
- return true;
- }
-
- return false;
- }
-
- public synchronized boolean remove2(T2 v2)
- {
- T1 v1 = map2.remove(v2);
- if (v1 != null)
- {
- map1.remove(v1);
- return true;
- }
-
- return false;
- }
-}
+/*
+ * Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.
+ * All rights reserved. This program and the accompanying materials
+ * are made available under the terms of the Eclipse Public License v1.0
+ * which accompanies this distribution, and is available at
+ * http://www.eclipse.org/legal/epl-v10.html
+ *
+ * Contributors:
+ * Eike Stepper - initial API and implementation
+ */
+package org.eclipse.net4j.util.collection;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @since 2.0
+ * @author Eike Stepper
+ */
+public class BidiMapper
+{
+ private Map