fixed LSN send for the transaction first phase
@@ -145,6 +145,9 @@ public class OTransactionPhase1Task extends OAbstractReplicatedTask {
}
lastLSN = new OLogSequenceNumber(in);
+ if (lastLSN.getSegment() == -1 && lastLSN.getSegment() == -1) {
+ lastLSN = null;
+ }
}
private void convert(ODatabaseDocumentInternal database) {
@@ -185,8 +188,12 @@ public class OTransactionPhase1Task extends OAbstractReplicatedTask {
for (ORecordOperationRequest operation : operations) {
OMessageHelper.writeTransactionEntry(out, operation);
}
+ if (lastLSN == null) {
+ new OLogSequenceNumber(-1, -1).toStream(out);
+ } else {
lastLSN.toStream(out);
}
+ }
@Override
public int getFactoryId() {
