Added field hasContent also in the OBeginTransactionRequest message
@@ -69,6 +69,7 @@ public class OBeginTransactionRequest implements OBinaryRequest<OBinaryResponse>
ORecordSerializerNetworkV37 serializer = ORecordSerializerNetworkV37.INSTANCE;
network.writeInt(txId);
+ network.writeBoolean(true);
network.writeBoolean(usingLog);
for (ORecordOperationRequest txEntry : operations) {
@@ -85,7 +86,9 @@ public class OBeginTransactionRequest implements OBinaryRequest<OBinaryResponse>
@Override
public void read(OChannelDataInput channel, int protocolVersion, ORecordSerializer serializer) throws IOException {
txId = channel.readInt();
+ boolean hasContent = channel.readBoolean();
usingLog = channel.readBoolean();
+ if(hasContent) {
operations = new ArrayList<>();
byte hasEntry;
do {
@@ -99,6 +102,7 @@ public class OBeginTransactionRequest implements OBinaryRequest<OBinaryResponse>
// RECEIVE MANUAL INDEX CHANGES
this.indexChanges = OMessageHelper.readTransactionIndexChanges(channel, (ORecordSerializerNetworkV37) serializer);
}
+ }
@Override
public byte getCommand() {
