in ratis-logservice/src/main/java/org/apache/ratis/logservice/impl/LogStreamImpl.java [109:124]
public long getSize() throws IOException{
RaftClientReply reply = raftClient
.io().sendReadOnly(Message.valueOf(LogServiceProtoUtil
.toGetSizeRequestProto(name).toByteString()));
if (reply.getException() != null) {
throw new IOException(reply.getException());
}
GetLogSizeReplyProto proto =
GetLogSizeReplyProto.parseFrom(reply.getMessage().getContent());
if (proto.hasException()) {
LogServiceException e = proto.getException();
throw new IOException(e.getErrorMsg());
}
return proto.getSize();
}