Categories:
Audio (13)
Biotech (29)
Bytecode (36)
Database (77)
Framework (7)
Game (7)
General (507)
Graphics (53)
I/O (35)
IDE (2)
JAR Tools (101)
JavaBeans (21)
JDBC (121)
JDK (426)
JSP (20)
Logging (108)
Mail (58)
Messaging (8)
Network (84)
PDF (97)
Report (7)
Scripting (84)
Security (32)
Server (121)
Servlet (26)
SOAP (24)
Testing (54)
Web (15)
XML (309)
Collections:
Other Resources:
Source Code for Apache Log4j IOStreams
Apache Log4j IOStreams is a Log4j API extension that provides numerous classes from java.io that can either write to a Logger while writing to another OutputStream or Writer, or the contents read by an InputStream or Reader can be wiretapped by a Logger.
Bytecode (Java 8) for Apache Log4j IOStreams is provided in a separate JAR file like log4j-iostreams-2.14.1.jar.
Source Code files for Apache Log4j IOStreams are provided in both binary packge like apache-log4j-2.14.1-bin.zip and source package like apache-log4j-2.14.1-src.zip. You can download them at Apache Log4j Website.
You can also browse Source Code files for Apache Log4j IOStreams 2.14.1 below.
✍: Quest
⏎ org/apache/logging/log4j/io/ByteStreamLogger.java
/* * 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.io; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.nio.ByteBuffer; import java.nio.charset.Charset; import org.apache.logging.log4j.Level; import org.apache.logging.log4j.Marker; import org.apache.logging.log4j.spi.ExtendedLogger; /** * * @since 2.1 */ public class ByteStreamLogger { private class ByteBufferInputStream extends InputStream { @Override public int read() throws IOException { ByteStreamLogger.this.buf.flip(); int result = -1; if (ByteStreamLogger.this.buf.limit() > 0) { result = ByteStreamLogger.this.buf.get() & 0xFF; } ByteStreamLogger.this.buf.compact(); return result; } @Override public int read(final byte[] bytes, final int off, final int len) throws IOException { ByteStreamLogger.this.buf.flip(); int result = -1; if (ByteStreamLogger.this.buf.limit() > 0) { result = Math.min(len, ByteStreamLogger.this.buf.limit()); ByteStreamLogger.this.buf.get(bytes, off, result); } ByteStreamLogger.this.buf.compact(); return result; } } private static final int BUFFER_SIZE = 1024; private final ExtendedLogger logger; private final Level level; private final Marker marker; private final InputStreamReader reader; private final char[] msgBuf = new char[BUFFER_SIZE]; private final StringBuilder msg = new StringBuilder(); private boolean closed; private final ByteBuffer buf = ByteBuffer.allocate(BUFFER_SIZE); public ByteStreamLogger(final ExtendedLogger logger, final Level level, final Marker marker, final Charset charset) { this.logger = logger; this.level = level == null ? logger.getLevel() : level; this.marker = marker; this.reader = new InputStreamReader(new ByteBufferInputStream(), charset == null ? Charset.defaultCharset() : charset); } public void close(final String fqcn) { synchronized (this.msg) { this.closed = true; logEnd(fqcn); } } private void extractMessages(final String fqcn) throws IOException { if (this.closed) { return; } int read = this.reader.read(this.msgBuf); while (read > 0) { int off = 0; for (int pos = 0; pos < read; pos++) { switch (this.msgBuf[pos]) { case '\r': this.msg.append(this.msgBuf, off, pos - off); off = pos + 1; break; case '\n': this.msg.append(this.msgBuf, off, pos - off); off = pos + 1; log(fqcn); break; } } this.msg.append(this.msgBuf, off, read - off); read = this.reader.read(this.msgBuf); } } private void log(final String fqcn) { // convert to string now so async loggers work this.logger.logIfEnabled(fqcn, this.level, this.marker, this.msg.toString()); this.msg.setLength(0); } private void logEnd(final String fqcn) { if (this.msg.length() > 0) { log(fqcn); } } public void put(final String fqcn, final byte[] b, final int off, final int len) throws IOException { int curOff = off; int curLen = len; if (curLen >= 0) { synchronized (this.msg) { while (curLen > this.buf.remaining()) { final int remaining = this.buf.remaining(); this.buf.put(b, curOff, remaining); curLen -= remaining; curOff += remaining; extractMessages(fqcn); } this.buf.put(b, curOff, curLen); extractMessages(fqcn); } } else { logEnd(fqcn); } } public void put(final String fqcn, final int b) throws IOException { if (b >= 0) { synchronized (this.msg) { this.buf.put((byte) (b & 0xFF)); extractMessages(fqcn); } } else { logEnd(fqcn); } } }
⏎ org/apache/logging/log4j/io/ByteStreamLogger.java
Or download all of them as a single archive file:
File name: log4j-iostreams-2.14.1-sources.jar File size: 43404 bytes Release date: 2021-03-06 Download
⇒ Source Code for Apache Log4j Web Servlet Containers
⇐ Source Code for Apache Log4j to SLF4J Adapter
2015-11-22, 20918👍, 1💬
Popular Posts:
What Is ojdbc8.jar for Oracle 12c R2? ojdbc8.jar for Oracle 12c R2 is the JAR files of ojdbc.jar, JD...
ASM is an all purpose Java bytecode manipulation and analysis framework. It can be used to modify ex...
What Is junit-3.8.1.jar? junit-3.8.1.jar is the version 3.8.1 of JUnit JAR library file. JUnit is a ...
JDK 17 jdk.hotspot.agent.jmod is the JMOD file for JDK 17 Hotspot Agent module. JDK 17 Hotspot Agent...
What Is fop.jar? I got it from the fop-2.7-bin.zip. fop.jar in fop-2.7-bin.zip is the JAR file for F...