INTERNAL: Refactor pipe insert and pipe update api.

Author: brido4125

src/main/java/net/spy/memcached/ArcusClient.java

@@ -831,7 +831,7 @@ <T> CollectionFuture<Map<Integer, CollectionOperationStatus>> asyncCollectionPip
 
     final CountDownLatch latch = new CountDownLatch(updateList.size());
     final PipedCollectionFuture<Integer, CollectionOperationStatus> rv =
-            new PipedCollectionFuture<Integer, CollectionOperationStatus>(latch, operationTimeout, updateList.size());
+            new PipedCollectionFuture<Integer, CollectionOperationStatus>(latch, operationTimeout);
 
     for (int i = 0; i < updateList.size(); i++) {
       final CollectionPipedUpdate<T> update = updateList.get(i);
@@ -868,8 +868,8 @@ public void gotStatus(Integer index, OperationStatus status) {
               }
             }
           });
-      addOp(key, op);
       rv.addOperation(op);
+      addOp(key, op);
     }
     return rv;
   }
@@ -3699,7 +3699,7 @@ <T> CollectionFuture<Map<Integer, CollectionOperationStatus>> asyncCollectionPip
 
     final CountDownLatch latch = new CountDownLatch(insertList.size());
     final PipedCollectionFuture<Integer, CollectionOperationStatus> rv =
-            new PipedCollectionFuture<Integer, CollectionOperationStatus>(latch, operationTimeout, insertList.size());
+            new PipedCollectionFuture<Integer, CollectionOperationStatus>(latch, operationTimeout);
 
     for (int i = 0; i < insertList.size(); i++) {
       final CollectionPipedInsert<T> insert = insertList.get(i);
@@ -3736,8 +3736,8 @@ public void gotStatus(Integer index, OperationStatus status) {
               }
             }
           });
-      addOp(key, op);
       rv.addOperation(op);
+      addOp(key, op);
     }
     return rv;
   }

src/main/java/net/spy/memcached/internal/PipedCollectionFuture.java

@@ -21,15 +21,14 @@
 public class PipedCollectionFuture<K, V>
         extends CollectionFuture<Map<K, V>> {
   private final ConcurrentLinkedQueue<Operation> ops = new ConcurrentLinkedQueue<Operation>();
-  private final List<CollectionOperationStatus> mergedOperationStatus;
+  private final List<CollectionOperationStatus> mergedOperationStatus
+          = Collections.synchronizedList(new ArrayList<CollectionOperationStatus>());
 
   private final Map<K, V> mergedResult =
           new ConcurrentHashMap<K, V>();
 
-  public PipedCollectionFuture(CountDownLatch l, long opTimeout, int opSize) {
+  public PipedCollectionFuture(CountDownLatch l, long opTimeout) {
     super(l, opTimeout);
-    mergedOperationStatus = Collections
-            .synchronizedList(new ArrayList<CollectionOperationStatus>(opSize));
   }
 
   @Override