forked from apache/logging-log4j2
-
Notifications
You must be signed in to change notification settings - Fork 0
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
Showing
8 changed files
with
152 additions
and
59 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
104 changes: 104 additions & 0 deletions
104
log4j-core/src/main/java/org/apache/logging/log4j/core/async/RingBufferLogEventHandler4.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,104 @@ | ||
| /* | ||
| * Licensed to the Apache Software Foundation (ASF) under one or more | ||
| * contributor license agreements. See the NOTICE file distributed with | ||
| * this work for additional information regarding copyright ownership. | ||
| * The ASF licenses this file to you under the Apache License, Version 2.0 | ||
| * (the "License"); you may not use this file except in compliance with | ||
| * the License. You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
| package org.apache.logging.log4j.core.async; | ||
|
|
||
| import com.lmax.disruptor.EventHandler; | ||
| import com.lmax.disruptor.Sequence; | ||
| import org.apache.logging.log4j.status.StatusLogger; | ||
| import org.apache.logging.log4j.util.LoaderUtil; | ||
|
|
||
| /** | ||
| * This event handler gets passed messages from the RingBuffer as they become | ||
| * available. Processing of these messages is done in a separate thread, | ||
| * controlled by the {@code Executor} passed to the {@code Disruptor} | ||
| * constructor. | ||
| */ | ||
| class RingBufferLogEventHandler4 implements EventHandler<RingBufferLogEvent> { | ||
|
|
||
| private static final int NOTIFY_PROGRESS_THRESHOLD = 50; | ||
| private Sequence sequenceCallback; | ||
| private int counter; | ||
| private long threadId = -1; | ||
|
|
||
| /** | ||
| * Returns the appropriate {@link EventHandler} for the version of LMAX Disruptor used. | ||
| */ | ||
| public static RingBufferLogEventHandler4 create() { | ||
| try { | ||
| return LoaderUtil.newInstanceOf("org.apache.logging.log4j.core.async.RingBufferLogEventHandler"); | ||
| } catch (final ReflectiveOperationException | LinkageError e) { | ||
| StatusLogger.getLogger().debug("LMAX Disruptor 3.x is missing, trying version 4.x.", e); | ||
| } | ||
| return new RingBufferLogEventHandler4(); | ||
| } | ||
|
|
||
| /* | ||
| * Overrides a method from Disruptor 4.x. Do not remove. | ||
| */ | ||
| public void setSequenceCallback(final Sequence sequenceCallback) { | ||
| this.sequenceCallback = sequenceCallback; | ||
| } | ||
|
|
||
| @Override | ||
| public void onEvent(final RingBufferLogEvent event, final long sequence, final boolean endOfBatch) | ||
| throws Exception { | ||
| try { | ||
| // RingBufferLogEvents are populated by an EventTranslator. If an exception is thrown during event | ||
| // translation, the event may not be fully populated, but Disruptor requires that the associated sequence | ||
| // still be published since a slot has already been claimed in the ring buffer. Ignore any such unpopulated | ||
| // events. The exception that occurred during translation will have already been propagated. | ||
| if (event.isPopulated()) { | ||
| event.execute(endOfBatch); | ||
| } | ||
| } finally { | ||
| event.clear(); | ||
| // notify the BatchEventProcessor that the sequence has progressed. | ||
| // Without this callback the sequence would not be progressed | ||
| // until the batch has completely finished. | ||
| notifyCallback(sequence); | ||
| } | ||
| } | ||
|
|
||
| private void notifyCallback(final long sequence) { | ||
| if (++counter > NOTIFY_PROGRESS_THRESHOLD) { | ||
| sequenceCallback.set(sequence); | ||
| counter = 0; | ||
| } | ||
| } | ||
|
|
||
| /** | ||
| * Returns the thread ID of the background consumer thread, or {@code -1} if the background thread has not started | ||
| * yet. | ||
| * | ||
| * @return the thread ID of the background consumer thread, or {@code -1} | ||
| */ | ||
| public long getThreadId() { | ||
| return threadId; | ||
| } | ||
|
|
||
| /* | ||
| * Overrides a method from Disruptor 4.x. Do not remove. | ||
| */ | ||
| public void onStart() { | ||
| threadId = Thread.currentThread().getId(); | ||
| } | ||
|
|
||
| /* | ||
| * Overrides a method from Disruptor 4.x. Do not remove. | ||
| */ | ||
| public void onShutdown() {} | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters