Skip to content

Commit

Permalink
WIP
Browse files Browse the repository at this point in the history
  • Loading branch information
anton-vinogradov committed Jun 28, 2023
1 parent 5aaa711 commit eff635b
Showing 1 changed file with 5 additions and 13 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -68,13 +68,13 @@
*/
public class GridDhtTxLocal extends GridDhtTxLocalAdapter implements GridCacheMappedVersion {
/** */
private UUID nearNodeId;
private final UUID nearNodeId;

/** Near future ID. */
private IgniteUuid nearFutId;

/** Near future ID. */
private int nearMiniId;
private final int nearMiniId;

/** Near future ID. */
private IgniteUuid nearFinFutId;
Expand All @@ -83,7 +83,7 @@ public class GridDhtTxLocal extends GridDhtTxLocalAdapter implements GridCacheMa
private int nearFinMiniId;

/** Near XID. */
private GridCacheVersion nearXidVer;
private final GridCacheVersion nearXidVer;

/** Future updater. */
private static final AtomicReferenceFieldUpdater<GridDhtTxLocal, GridDhtTxPrepareFuture> PREP_FUT_UPD =
Expand All @@ -94,7 +94,7 @@ public class GridDhtTxLocal extends GridDhtTxLocalAdapter implements GridCacheMa
private volatile GridDhtTxPrepareFuture prepFut;

/** Transaction label. */
private @Nullable String lb;
private final @Nullable String lb;

/**
* @param nearNodeId Near node ID that initiated transaction.
Expand Down Expand Up @@ -244,13 +244,6 @@ public void nearFutureId(IgniteUuid nearFutId) {
return cacheCtx.isDht() && isNearEnabled(cacheCtx) && !cctx.localNodeId().equals(nearNodeId());
}

/**
* @return Near future ID.
*/
public IgniteUuid nearFinishFutureId() {
return nearFinFutId;
}

/**
* @param nearFinFutId Near future ID.
*/
Expand Down Expand Up @@ -289,8 +282,7 @@ public void nearFinishMiniId(int nearFinMiniId) {
}

/** {@inheritDoc} */
@Override protected void updateExplicitVersion(IgniteTxEntry txEntry, GridCacheEntryEx entry)
throws GridCacheEntryRemovedException {
@Override protected void updateExplicitVersion(IgniteTxEntry txEntry, GridCacheEntryEx entry) {
// DHT local transactions don't have explicit locks.
// No-op.
}
Expand Down

0 comments on commit eff635b

Please sign in to comment.