Skip to content

Commit

Permalink
declare old TxnId
Browse files Browse the repository at this point in the history
  • Loading branch information
belliottsmith committed Aug 13, 2024
1 parent 0fdc6a1 commit 00dedfd
Showing 1 changed file with 4 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,10 @@
import accord.primitives.PartialDeps;
import accord.primitives.Range;
import accord.primitives.Ranges;
import accord.primitives.Routable;
import accord.primitives.SyncPoint;
import accord.primitives.Txn;
import accord.primitives.TxnId;
import accord.topology.Topology;
import accord.topology.TopologyUtils;
import accord.utils.SortedArrays.SortedArrayList;
Expand Down Expand Up @@ -96,7 +99,7 @@ void rangeRemovedGlobally()

private static SyncPoint<Ranges> awaitApplied(Node node, Range removed)
{
var await = CoordinateSyncPoint.exclusive(node, Ranges.single(removed))
var await = CoordinateSyncPoint.exclusive(node, new TxnId(1, node.now(), Txn.Kind.ExclusiveSyncPoint, Routable.Domain.Range, node.id()), Ranges.single(removed))
.flatMap(syncPoint ->
// the test uses an executor that runs everything right away, so this gets called outside the CommandStore
node.commandStores().forId(0).submit(() -> {
Expand Down

0 comments on commit 00dedfd

Please sign in to comment.