tkalkirill commented on code in PR #1960:
URL: https://github.com/apache/ignite-3/pull/1960#discussion_r1172458453
##########
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/storage/InternalTableImpl.java:
##########
@@ -101,8 +103,8 @@ public class InternalTableImpl implements InternalTable {
/** Number of attempts. */
private static final int ATTEMPTS_TO_ENLIST_PARTITION = 5;
- /** Partition map. */
- protected volatile Int2ObjectMap<RaftGroupService> partitionMap;
+ /** Map update guard by field {@link #updatePartitionMapsMux}. */
Review Comment:
Fix it
##########
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/storage/InternalTableImpl.java:
##########
@@ -128,15 +130,21 @@ public class InternalTableImpl implements InternalTable {
/** Replica service. */
private final ReplicaService replicaSvc;
- /** Mutex for the partition map update. */
- private final Object updatePartMapMux = new Object();
+ /** Mutex for the partition maps update. */
+ private final Object updatePartitionMapsMux = new Object();
/** Table messages factory. */
private final TableMessagesFactory tableMessagesFactory;
/** A hybrid logical clock. */
private final HybridClock clock;
+ /** Map update guard by field {@link #updatePartitionMapsMux}. */
+ private volatile
Int2ObjectMap<PendingComparableValuesTracker<HybridTimestamp>>
safeTimeTrackerByPartitionId = emptyMap();
+
+ /** Map update guard by field {@link #updatePartitionMapsMux}. */
+ private volatile Int2ObjectMap<PendingComparableValuesTracker<Long>>
storageIndexTrackerByPartitionId = emptyMap();
Review Comment:
fix it
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
