public long sync()

in ratis-logservice/src/main/java/org/apache/ratis/logservice/impl/LogWriterImpl.java [90:107]

• 17 lines of code
• 4 McCabe index (conditional complexity)

 public long sync() throws IOException {
     try {
       RaftClientReply reply = raftClient.io().send(Message
           .valueOf(LogServiceProtoUtil.toSyncLogRequestProto(parent.getName()).toByteString()));
       if (reply.getException() != null) {
         throw new IOException(reply.getException());
       }

       SyncLogReplyProto proto = SyncLogReplyProto.parseFrom(reply.getMessage().getContent());
       if (proto.hasException()) {
         LogServiceException e = proto.getException();
         throw new IOException(e.getErrorMsg());
       }
       return proto.getLastRecordId();
     } catch (Exception e) {
       throw new IOException(e);
   }
  }