This is an automated email from the ASF dual-hosted git repository.
vpyatkov pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
The following commit(s) were added to refs/heads/main by this push:
new 5d690bd7ed IGNITE-23225 Added logging to LogManagerImpl (#4411)
5d690bd7ed is described below
commit 5d690bd7ed0ab932b3101f3103eaebf59ee32cf9
Author: Mirza Aliev <[email protected]>
AuthorDate: Thu Sep 19 12:18:53 2024 +0400
IGNITE-23225 Added logging to LogManagerImpl (#4411)
---
.../apache/ignite/raft/jraft/storage/impl/LogManagerImpl.java | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git
a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/impl/LogManagerImpl.java
b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/impl/LogManagerImpl.java
index 7952f03ff3..31228fe671 100644
---
a/modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/impl/LogManagerImpl.java
+++
b/modules/raft/src/main/java/org/apache/ignite/raft/jraft/storage/impl/LogManagerImpl.java
@@ -353,8 +353,13 @@ public class LogManagerImpl implements LogManager {
private void offerEvent(final StableClosure done, final EventType type) {
assert(done != null);
- if (this.stopped) {
- Utils.runClosureInThread(nodeOptions.getCommonExecutor(), done,
new Status(RaftError.ESTOP, "Log manager is stopped."));
+ if (this.stopped) {
+ if (type == EventType.LAST_LOG_ID) {
+ // TODO: remove after fixing the issue
https://issues.apache.org/jira/browse/IGNITE-23132
+ LOG.info("Received a last log id request, but log manager
is stopped.");
+ }
+
+ Utils.runClosureInThread(nodeOptions.getCommonExecutor(),
done, new Status(RaftError.ESTOP, "Log manager is stopped."));
return;
}
this.diskQueue.publishEvent((event, sequence) -> {
