From a89f7014aeb71dba5c94404dfea7eb89e7eeee74 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Wed, 08 Jul 2015 06:48:02 +0000
Subject: [PATCH] AutoRefactor'ed Use Diamond Operator

---
 opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/Log.java |   28 ++++++++++++++--------------
 1 files changed, 14 insertions(+), 14 deletions(-)

diff --git a/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/Log.java b/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/Log.java
index 90b7d8c..52e2785 100644
--- a/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/Log.java
+++ b/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/Log.java
@@ -124,7 +124,7 @@
   };
 
   /** Map that holds the unique log instance for each log path. */
-  private static final Map<File, Log<?, ?>> logsCache = new HashMap<File, Log<?, ?>>();
+  private static final Map<File, Log<?, ?>> logsCache = new HashMap<>();
 
   /**
    * The number of references on this log instance. It is incremented each time
@@ -153,7 +153,7 @@
    * <p>
    * The read-only log files are associated with the highest key they contain.
    */
-  private final TreeMap<K, LogFile<K, V>> logFiles = new TreeMap<K, LogFile<K, V>>();
+  private final TreeMap<K, LogFile<K, V>> logFiles = new TreeMap<>();
 
   /**
    * The last key appended to the log. In order to keep the ordering of the keys
@@ -166,7 +166,7 @@
    * The list of non-empty cursors opened on this log. Opened cursors may have
    * to be updated when rotating the head log file.
    */
-  private final List<AbortableLogCursor<K, V>> openCursors = new CopyOnWriteArrayList<AbortableLogCursor<K, V>>();
+  private final List<AbortableLogCursor<K, V>> openCursors = new CopyOnWriteArrayList<>();
 
   /**
    * A log file can be rotated once it has exceeded this size limit. The log file can have
@@ -234,7 +234,7 @@
     Log<K, V> log = (Log<K, V>) logsCache.get(logPath);
     if (log == null)
     {
-      log = new Log<K, V>(replicationEnv, logPath, parser, rotationParameters);
+      log = new Log<>(replicationEnv, logPath, parser, rotationParameters);
       logsCache.put(logPath, log);
     }
     else
@@ -254,7 +254,7 @@
    * @return an empty cursor
    */
   static <K extends Comparable<K>, V> RepositionableCursor<K, V> getEmptyCursor() {
-    return new Log.EmptyCursor<K, V>();
+    return new Log.EmptyCursor<>();
   }
 
   /** Holds the parameters for log files rotation. */
@@ -537,9 +537,9 @@
     {
       if (isClosed)
       {
-        return new EmptyCursor<K, V>();
+        return new EmptyCursor<>();
       }
-      cursor = new AbortableLogCursor<K, V>(this, new InternalLogCursor<K, V>(this));
+      cursor = new AbortableLogCursor<>(this, new InternalLogCursor<K, V>(this));
       cursor.positionTo(null, null, null);
       registerCursor(cursor);
       return cursor;
@@ -600,9 +600,9 @@
     {
       if (isClosed)
       {
-        return new EmptyCursor<K, V>();
+        return new EmptyCursor<>();
       }
-      cursor = new AbortableLogCursor<K, V>(this, new InternalLogCursor<K, V>(this));
+      cursor = new AbortableLogCursor<>(this, new InternalLogCursor<K, V>(this));
       final boolean isSuccessfullyPositioned = cursor.positionTo(key, matchingStrategy, positionStrategy);
       // Allow for cursor re-initialization after exhaustion in case of
       // LESS_THAN_OR_EQUAL_TO_KEY ands GREATER_THAN_OR_EQUAL_TO_KEY strategies
@@ -614,7 +614,7 @@
       else
       {
         StaticUtils.close(cursor);
-        return new EmptyCursor<K, V>();
+        return new EmptyCursor<>();
       }
     }
     catch (ChangelogException e)
@@ -719,7 +719,7 @@
       {
         return null;
       }
-      final List<String> undeletableFiles = new ArrayList<String>();
+      final List<String> undeletableFiles = new ArrayList<>();
       final Iterator<LogFile<K, V>> entriesToPurge = logFilesToPurge.values().iterator();
       while (entriesToPurge.hasNext())
       {
@@ -793,7 +793,7 @@
       }
 
       // delete all log files
-      final List<String> undeletableFiles = new ArrayList<String>();
+      final List<String> undeletableFiles = new ArrayList<>();
       for (LogFile<K, V> logFile : logFiles.values())
       {
         try
@@ -1256,7 +1256,7 @@
     @Override
     CursorState<K, V> getState() throws ChangelogException
     {
-      return new CursorState<K, V>(currentLogFile, currentCursor.getFilePosition(), currentCursor.getRecord());
+      return new CursorState<>(currentLogFile, currentCursor.getFilePosition(), currentCursor.getRecord());
     }
 
     @Override
@@ -1462,7 +1462,7 @@
         if (mustAbort)
         {
           delegate.close();
-          delegate = new AbortedLogCursor<K, V>(log.getPath());
+          delegate = new AbortedLogCursor<>(log.getPath());
           mustAbort = false;
         }
         return delegate.next();

--
Gitblit v1.10.0