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);