Apache
/
hadoop
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HDDS-433. ContainerStateMachine#readStateMachineData should properly build LogEntryProto. Contributed by Lokesh Jain. 

(cherry picked from commit 47299ce23f)
This commit is contained in:
Mukul Kumar Singh 2018-09-12 18:30:53 +05:30 committed by Márton Elek
parent 22c318eeee
commit 7f5382483e
1 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
hadoop-hdds/container-service/src/main/java/org/apache/hadoop/ozone/container/common/transport/server/ratis/ContainerStateMachine.java
View File

@ -268,7 +268,7 @@ public class ContainerStateMachine extends BaseStateMachine {
}
}
private LogEntryProto readStateMachineData(SMLogEntryProto smLogEntryProto,
private LogEntryProto readStateMachineData(LogEntryProto entry,
ContainerCommandRequestProto requestProto) {
WriteChunkRequestProto writeChunkRequestProto =
requestProto.getWriteChunk();
@ -307,18 +307,18 @@ public class ContainerStateMachine extends BaseStateMachine {
ContainerCommandRequestProto.newBuilder(requestProto)
.setWriteChunk(dataWriteChunkProto);
return recreateLogEntryProto(smLogEntryProto,
return recreateLogEntryProto(entry,
newStateMachineProto.build().toByteString());
}
private LogEntryProto recreateLogEntryProto(SMLogEntryProto smLogEntryProto,
private LogEntryProto recreateLogEntryProto(LogEntryProto entry,
ByteString stateMachineData) {
// recreate the log entry
final SMLogEntryProto log =
SMLogEntryProto.newBuilder(smLogEntryProto)
SMLogEntryProto.newBuilder(entry.getSmLogEntry())
.setStateMachineData(stateMachineData)
.build();
return LogEntryProto.newBuilder().setSmLogEntry(log).build();
return LogEntryProto.newBuilder(entry).setSmLogEntry(log).build();
}
/**
@ -360,11 +360,11 @@ public class ContainerStateMachine extends BaseStateMachine {
if (requestProto.getCmdType() == Type.WriteChunk) {
return CompletableFuture.supplyAsync(() ->
readStateMachineData(smLogEntryProto, requestProto),
readStateMachineData(entry, requestProto),
chunkExecutor);
} else if (requestProto.getCmdType() == Type.CreateContainer) {
LogEntryProto log =
recreateLogEntryProto(smLogEntryProto, requestProto.toByteString());
recreateLogEntryProto(entry, requestProto.toByteString());
return CompletableFuture.completedFuture(log);
} else {
throw new IllegalStateException("Cmd type:" + requestProto.getCmdType()