This is an automated email from the ASF dual-hosted git repository.

av pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git


The following commit(s) were added to refs/heads/master by this push:
     new c6abcdc3474 IGNITE-19845 IgniteTxLocalAdapter.sndTransformedVals field 
removal WIP (#10805)
c6abcdc3474 is described below

commit c6abcdc34748c2dadaa5e410853b1f488243b85f
Author: Anton Vinogradov <[email protected]>
AuthorDate: Wed Jun 28 14:31:32 2023 +0300

    IGNITE-19845 IgniteTxLocalAdapter.sndTransformedVals field removal WIP 
(#10805)
---
 .../cache/transactions/IgniteTxLocalAdapter.java          | 15 ++-------------
 1 file changed, 2 insertions(+), 13 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java
 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java
index 7b67d58906d..f9598b57ffb 100644
--- 
a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java
+++ 
b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java
@@ -133,9 +133,6 @@ public abstract class IgniteTxLocalAdapter extends 
IgniteTxAdapter implements Ig
     /** Base for completed versions. */
     private GridCacheVersion completedBase;
 
-    /** Flag indicating that transformed values should be sent to remote 
nodes. */
-    private boolean sndTransformedVals;
-
     /** Commit error. */
     protected volatile Throwable commitErr;
 
@@ -362,14 +359,6 @@ public abstract class IgniteTxLocalAdapter extends 
IgniteTxAdapter implements Ig
         return txState().hasInterceptor(cctx);
     }
 
-    /**
-     * @param snd {@code True} if values in tx entries should be replaced with 
transformed values and sent
-     * to remote nodes.
-     */
-    public void sendTransformedValues(boolean snd) {
-        sndTransformedVals = snd;
-    }
-
     /**
      * @return {@code True} if should be committed after lock is acquired.
      */
@@ -717,8 +706,8 @@ public abstract class IgniteTxLocalAdapter extends 
IgniteTxAdapter implements Ig
                                     // Nullify explicit version so that 
innerSet/innerRemove will work as usual.
                                     explicitVer = null;
 
-                                if (sndTransformedVals || conflictNeedResolve) 
{
-                                    assert sndTransformedVals && 
cacheCtx.isReplicated() || conflictNeedResolve;
+                                if (conflictNeedResolve) {
+                                    assert cacheCtx.isReplicated() || 
conflictNeedResolve;
 
                                     txEntry.value(val, true, false);
                                     txEntry.op(op);

Reply via email to