THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
DistributedProcess
with special message holds new ConsistentCutMarker
(goal is to notify every node in a cluster about running incremental snapshot). ConsistentCutMarker
by discovery.ConsistentCutMarker
by transaction message (Prepare, Finish)ConsistentCut
futurecommittingTx,
goal is to track COMMITTING+ transactions, that aren't part of IgniteTxManager#activeTx
ConsistentCutMarker
.ConsistentCutStartRecord
to WAL with the received ConsistentCutMarker
.IgniteTxManager#activeTx
and committingTxs
.DistributedProcess
is alive every node signs output transaction messages:ConsistentCutMarker
(to trigger ConsistentCut
on remote node, if not yet).ConsistentCutMarker
(to trigger...) and transaction ConsistentCutMarker
(to notify nodes which side of cut this transaction belongs to).ConsistentCutMarker
on node that commits first.ConsistentCutMarker
and prepares before
, after
collections:before
sideafter
sidebefore
, after
). committingTxs
.ConsistentCut
future, and notifies a node-initiator about finishing local procedure (with DistributedProcess
protocol).ConsistentCut
:ConsistentCut
future becomes null....
Code Block | ||||
---|---|---|---|---|
| ||||
class ConsistentCutMarker {
UUID id;
AffinityTopologyVersion topVer;
} |
id
is just a unique ConsistentCut
ID (is assigned on the node initiator).
...