sendReadyReplies(readySet);
}
}
}
});
<BUG>} catch (Exception e) {
responseObserver.onError(RaftGrpcUtil.wrapException(e));</BUG>
}
}
private void sendReadyReplies(Collection<PendingAppend> readySet) {

sendReadyReplies(readySet);
}
}
}
});
} catch (Throwable e) {
LOG.info("{} got exception when handling client append request {}: {}",
dispatcher.getRaftServer().getId(), request.getRpcRequest(), e);
responseObserver.onError(RaftGrpcUtil.wrapException(e));
}
}
private void sendReadyReplies(Collection<PendingAppend> readySet) {
