INTERNAL: Change addOp logic in mutate api.

naver · Jul 12, 2024 · a215e4d · a215e4d
1 parent da44d36
commit a215e4d
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/src/main/java/net/spy/memcached/MemcachedClient.java b/src/main/java/net/spy/memcached/MemcachedClient.java
@@ -1788,17 +1788,17 @@ private OperationFuture<Long> asyncMutate(Mutator m, String key, int by, long de
     final CountDownLatch latch = new CountDownLatch(1);
     final OperationFuture<Long> rv = new OperationFuture<>(
             latch, operationTimeout);
-    Operation op = addOp(key, opFact.mutate(m, key, by, def, exp,
-        new OperationCallback() {
-          public void receivedStatus(OperationStatus s) {
-            rv.set(Long.parseLong(s.isSuccess() ? s.getMessage() : "-1"), s);
-          }
+    Operation op = opFact.mutate(m, key, by, def, exp, new OperationCallback() {
+      public void receivedStatus(OperationStatus s) {
+        rv.set(Long.parseLong(s.isSuccess() ? s.getMessage() : "-1"), s);
+      }
 
-          public void complete() {
-            latch.countDown();
-          }
-        }));
+      public void complete() {
+        latch.countDown();
+      }
+    });
     rv.setOperation(op);
+    addOp(key, op);
     return rv;
   }