forked from weaselab/conflict-set
WIP
This commit is contained in:
+2
-4
@@ -3121,9 +3121,7 @@ CONTINUATION_CALLING_CONVENTION void complete(CheckAll *context,
|
|||||||
context->queries + temp, context->results + temp, context->root,
|
context->queries + temp, context->results + temp, context->root,
|
||||||
context->oldestVersionFullPrecision, context->tls);
|
context->oldestVersionFullPrecision, context->tls);
|
||||||
}
|
}
|
||||||
prevJob = job;
|
MUSTTAIL return keepGoing(context, prevJob, job, started, count);
|
||||||
job = context->nextJob[job];
|
|
||||||
MUSTTAIL return context->next[job](context, prevJob, job, started, count);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
namespace check_point_read_state_machine {
|
namespace check_point_read_state_machine {
|
||||||
@@ -3277,7 +3275,7 @@ continuation CheckJob::init(const ConflictSet::ReadRange *read,
|
|||||||
// checkPointRead(root, begin, InternalVersionT(read->readVersion), tls)
|
// checkPointRead(root, begin, InternalVersionT(read->readVersion), tls)
|
||||||
// ? ConflictSet::Commit
|
// ? ConflictSet::Commit
|
||||||
// : ConflictSet::Conflict;
|
// : ConflictSet::Conflict;
|
||||||
// next = complete;
|
// return complete;
|
||||||
} else {
|
} else {
|
||||||
*result = checkRangeRead(root, begin, end,
|
*result = checkRangeRead(root, begin, end,
|
||||||
InternalVersionT(read->readVersion), tls)
|
InternalVersionT(read->readVersion), tls)
|
||||||
|
|||||||
Reference in New Issue
Block a user