This is an automated email from the ASF dual-hosted git repository.
sanpwc pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 64d0780acb IGNITE-20033 Jira links update in TODO (#2387)
64d0780acb is described below
commit 64d0780acb9f13a89590c245e1232269c6711729
Author: Alexander Lapin <[email protected]>
AuthorDate: Tue Aug 1 09:04:56 2023 +0300
IGNITE-20033 Jira links update in TODO (#2387)
---
.../table/distributed/replicator/PartitionReplicaListener.java | 6 +++---
.../src/main/java/org/apache/ignite/internal/tx/TxManager.java | 4 ++--
.../apache/ignite/internal/tx/impl/ReadWriteTransactionImpl.java | 2 +-
.../main/java/org/apache/ignite/internal/tx/impl/TxManagerImpl.java | 4 ++--
4 files changed, 8 insertions(+), 8 deletions(-)
diff --git
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
index 84b23325d3..9064de3b6a 100644
---
a/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
+++
b/modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaListener.java
@@ -206,7 +206,7 @@ public class PartitionReplicaListener implements
ReplicaListener {
/**
* Map to control clock's update in the read only transactions
concurrently with a commit timestamp.
- * TODO: IGNITE-17261 review this after the commit timestamp will be
provided from a commit request (request.commitTimestamp()).
+ * TODO: IGNITE-20034 review this after the commit timestamp will be
provided from a commit request (request.commitTimestamp()).
*/
private final ConcurrentHashMap<UUID, CompletableFuture<TxMeta>>
txTimestampUpdateMap = new ConcurrentHashMap<>();
@@ -388,7 +388,7 @@ public class PartitionReplicaListener implements
ReplicaListener {
* @return Future to transaction state meta or {@code null}.
*/
private CompletableFuture<TxMeta>
getTxStateConcurrently(TxStateReplicaRequest txStateReq) {
- //TODO: IGNITE-17261 review this after the commit timestamp will be
provided from a commit request (request.commitTimestamp()).
+ //TODO: IGNITE-20034 review this after the commit timestamp will be
provided from a commit request (request.commitTimestamp()).
CompletableFuture<TxMeta> txStateFut = new CompletableFuture<>();
txTimestampUpdateMap.compute(txStateReq.txId(), (uuid, fut) -> {
@@ -1138,7 +1138,7 @@ public class PartitionReplicaListener implements
ReplicaListener {
* @return Future to wait of the finish.
*/
private CompletableFuture<Object> finishTransaction(List<TablePartitionId>
aggregatedGroupIds, UUID txId, boolean commit) {
- // TODO: IGNITE-17261 Timestamp from request is not using until the
issue has not been fixed (request.commitTimestamp())
+ // TODO: IGNITE-20034 Timestamp from request is not using until the
issue has not been fixed (request.commitTimestamp())
var fut = new CompletableFuture<TxMeta>();
txTimestampUpdateMap.put(txId, fut);
diff --git
a/modules/transactions/src/main/java/org/apache/ignite/internal/tx/TxManager.java
b/modules/transactions/src/main/java/org/apache/ignite/internal/tx/TxManager.java
index 586d96218a..58dc4f93f0 100644
---
a/modules/transactions/src/main/java/org/apache/ignite/internal/tx/TxManager.java
+++
b/modules/transactions/src/main/java/org/apache/ignite/internal/tx/TxManager.java
@@ -63,7 +63,7 @@ public interface TxManager extends IgniteComponent {
* @param txId Transaction id.
* @return The state or null if the state is unknown.
*/
- // TODO: IGNITE-17638 TestOnly code, let's consider using Txn state map
instead of states.
+ // TODO: IGNITE-20033 TestOnly code, let's consider using Txn state map
instead of states.
@Deprecated
@Nullable TxState state(UUID txId);
@@ -74,7 +74,7 @@ public interface TxManager extends IgniteComponent {
* @param before Before state.
* @param after After state.
*/
- // TODO: IGNITE-17638 TestOnly code, let's consider using Txn state map
instead of states.
+ // TODO: IGNITE-20033 TestOnly code, let's consider using Txn state map
instead of states.
@Deprecated
void changeState(UUID txId, @Nullable TxState before, TxState after);
diff --git
a/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/ReadWriteTransactionImpl.java
b/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/ReadWriteTransactionImpl.java
index 6785b0c44b..fdc4302e15 100644
---
a/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/ReadWriteTransactionImpl.java
+++
b/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/ReadWriteTransactionImpl.java
@@ -142,7 +142,7 @@ public class ReadWriteTransactionImpl extends
IgniteAbstractTransactionImpl {
id()
);
} else {
- // TODO: IGNITE-17638 TestOnly code, let's
consider using Txn state map instead of states.
+ // TODO: IGNITE-20033 TestOnly code, let's
consider using Txn state map instead of states.
txManager.changeState(id(), PENDING, commit ?
COMMITED : ABORTED);
return completedFuture(null);
diff --git
a/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TxManagerImpl.java
b/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TxManagerImpl.java
index 02831a7964..f60d5720dd 100644
---
a/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TxManagerImpl.java
+++
b/modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/TxManagerImpl.java
@@ -72,7 +72,7 @@ public class TxManagerImpl implements TxManager {
/** Generates transaction IDs. */
private final TransactionIdGenerator transactionIdGenerator;
- // TODO: IGNITE-17638 Consider using Txn state map instead of states.
+ // TODO: IGNITE-20033 Consider using Txn state map instead of states.
/** The storage for tx states. */
@TestOnly
private final ConcurrentHashMap<UUID, TxState> states = new
ConcurrentHashMap<>();
@@ -215,7 +215,7 @@ public class TxManagerImpl implements TxManager {
.build();
return replicaService.invoke(recipientNode, req)
- // TODO: IGNITE-17638 TestOnly code, let's consider using Txn
state map instead of states.
+ // TODO: IGNITE-20033 TestOnly code, let's consider using Txn
state map instead of states.
.thenRun(() -> changeState(txId, PENDING, commit ? COMMITED :
ABORTED));
}
