The version of Apache log4j used by SoundHelix.
Clone
HTTPS:
git clone https://vervis.peers.community/repos/aEp6o
SSH:
git clone USERNAME@vervis.peers.community:aEp6o
Branches
Tags
- 1.3alpha-7
- CHAINSAW_2_SANDBOX_MERGE
- CORE_VERSION
- LEVEL_REPLACES_PRIORITY
- PREALPHA_1_3_AS_OF_2004_05_12
- PRE_CHAINSAW_MODEL_CONVERSION
- PRE_UGLI_MOVE
- TAG_CHAINSAW2_MOVE
- log4j-1.2.17
- log4j-1.2.17-rc1
- v1.3alpha8
- v1.3alpha8-temp
- v1_2_1
- v1_2_10-recalled
- v1_2_11
- v1_2_11_rc1
- v1_2_11rc3
- v1_2_12
- v1_2_12_rc1
- v1_2_12_rc2
- v1_2_12_rc3
- v1_2_12_rc4
- v1_2_12_rc5
- v1_2_12_rc6
- v1_2_13
- v1_2_13_rc1
- v1_2_13_rc2
- v1_2_13_site_update
- v1_2_14
- v1_2_14_maven
- v1_2_14_rc1
- v1_2_14_site_update
- v1_2_15
- v1_2_15_rc1
- v1_2_15_rc2
- v1_2_15_rc3
- v1_2_15_rc4
- v1_2_15_rc5
- v1_2_15_rc6
- v1_2_16
- v1_2_16_rc1
- v1_2_16_rc2
- v1_2_17
- v1_2_17-rc1
- v1_2_17_rc1
- v1_2_17_rc2
- v1_2_17_rc3
- v1_2_2
- v1_2_3
- v1_2_4
- v1_2_6
- v1_2_7
- v1_2_9
- v1_2_alpha0
- v1_2_alpha7
- v1_2beta1
- v1_2final
- v1_3alpha_1
- v1_3alpha_6
- v_1_0
- v_1_0_1
- v_1_0_4
- v_1_1
- v_1_1_1
- v_1_1_2
- v_1_1_3
- v_1_1_b1
- v_1_1b2
- v_1_1b3
- v_1_1b5
- v_1_1b6
- v_1_1b7
- v_1_2beta3
ExternallyRolledFileAppender.java
// Copyright 2000, Ceki Gulcu.
//
// See the LICENCE file for the terms of usage and distribution.
package org.apache.log4j.varia;
import java.io.*;
import java.net.Socket;
import java.net.ServerSocket;
import org.apache.log4j.helpers.LogLog;
import org.apache.log4j.RollingFileAppender;
import org.apache.log4j.Layout;
import org.apache.log4j.helpers.OptionConverter;
import org.apache.log4j.helpers.LogLog;
/**
This appender listen on a socket on the port specified by the
{@link #PORT_OPTION} for a "RollOver" message. If and and when such
a message is received, the underlying log file is rolled over and
an acknowledgement message is sent back to the process initiating
the roll over.
<p>Compared to the the {@link ResilientFileAppender}, this method
of triggering roll over has the advantage of being operating system
independent, fast and reliable.
<p>A simple application {@link Roller} is provided to initiate the
roll over.
<p>Note that the intiator is not authenticated. Anyone can trigger
a rollover. In production environments, it is recommended that you
add some form of protection to prevent undesired rollovers.
@author Ceki Gülcü
@since version 0.9.0 */
public class ExternallyRolledFileAppender extends RollingFileAppender {
/**
A string constant used in naming the option for setting the port
for listening to external roll over messages. Current value of
this string constant is <b>Port</b>.
<p>All option keys are case sensitive. */
static final public String PORT_OPTION = "Port";
/**
The string constant sent to initiate a roll over. Current value of
this string constant is <b>RollOver</b>.
*/
static final public String ROLL_OVER = "RollOver";
/**
The string constant sent to acknowledge a roll over. Current value of
this string constant is <b>OK</b>.
*/
static final public String OK = "OK";
int port = 0;
HUP hup;
/**
Thia default constructor does nothing but call its super-class
constructor. */
public
ExternallyRolledFileAppender() {
}
/**
Start listening on the port specified by a preceding call to
{@link #setOption}. */
public
void activateOptions() {
super.activateOptions();
if(port != 0) {
if(hup != null) {
hup.interrupt();
}
hup = new HUP(this, port);
hup.setDaemon(true);
hup.start();
}
}
/**
Retuns the option names for this component, namely {@link
#PORT_OPTION} in addition to the options of its super class {@link
RollingFileAppender#getOptionStrings FileAppender}. */
public
String[] getOptionStrings() {
return OptionConverter.concatanateArrays(super.getOptionStrings(),
new String[] {PORT_OPTION});
}
/**
The <b>Port</b> options takes a
*/
public
void setOption(String option, String value) {
super.setOption(option, value);
if(option.equalsIgnoreCase(PORT_OPTION)) {
port = OptionConverter.toInt(value, port);
LogLog.debug("Port option set to "+port);
}
}
}
class HUP extends Thread {
int port;
ExternallyRolledFileAppender er;
HUP(ExternallyRolledFileAppender er, int port) {
this.er = er;
this.port = port;
}
public
void run() {
while(!isInterrupted()) {
try {
ServerSocket serverSocket = new ServerSocket(port);
while(true) {
Socket socket = serverSocket.accept();
LogLog.debug("Connected to client at " + socket.getInetAddress());
new Thread(new HUPNode(socket, er)).start();
}
}
catch(Exception e) {
e.printStackTrace();
}
}
}
}
class HUPNode implements Runnable {
Socket socket;
DataInputStream dis;
DataOutputStream dos;
ExternallyRolledFileAppender er;
public
HUPNode(Socket socket, ExternallyRolledFileAppender er) {
this.socket = socket;
this.er = er;
try {
dis = new DataInputStream(socket.getInputStream());
dos = new DataOutputStream(socket.getOutputStream());
}
catch(Exception e) {
e.printStackTrace();
}
}
public void run() {
try {
String line = dis.readUTF();
LogLog.debug("Got external roll over signal.");
if(ExternallyRolledFileAppender.ROLL_OVER.equals(line)) {
synchronized(er) {
er.rollOver();
}
dos.writeUTF(ExternallyRolledFileAppender.OK);
}
else {
dos.writeUTF("Expecting [RollOver] string.");
}
dos.close();
}
catch(Exception e) {
LogLog.error("Unexptected exception. Exiting HUPNode.", e);
}
}
}