public class org.apache.log4j.net.SocketHubAppender extends org.apache.log4j.AppenderSkeleton
{
static final int DEFAULT_PORT;
private int port;
private java.util.Vector oosList;
private org.apache.log4j.net.SocketHubAppender$ServerMonitor serverMonitor;
private boolean locationInfo;
private org.apache.log4j.helpers.CyclicBuffer buffer;
private java.lang.String application;
private boolean advertiseViaMulticastDNS;
private org.apache.log4j.net.ZeroConfSupport zeroConf;
public static final java.lang.String ZONE;
private java.net.ServerSocket serverSocket;
public void <init>()
{
org.apache.log4j.net.SocketHubAppender v;
java.util.Vector v;
v := @this: org.apache.log4j.net.SocketHubAppender;
specialinvoke v.<org.apache.log4j.AppenderSkeleton: void <init>()>();
v.<org.apache.log4j.net.SocketHubAppender: int port> = 4560;
v = new java.util.Vector;
specialinvoke v.<java.util.Vector: void <init>()>();
v.<org.apache.log4j.net.SocketHubAppender: java.util.Vector oosList> = v;
v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.net.SocketHubAppender$ServerMonitor serverMonitor> = null;
v.<org.apache.log4j.net.SocketHubAppender: boolean locationInfo> = 0;
v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.helpers.CyclicBuffer buffer> = null;
return;
}
public void <init>(int)
{
int v;
org.apache.log4j.net.SocketHubAppender v;
java.util.Vector v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v := @parameter: int;
specialinvoke v.<org.apache.log4j.AppenderSkeleton: void <init>()>();
v.<org.apache.log4j.net.SocketHubAppender: int port> = 4560;
v = new java.util.Vector;
specialinvoke v.<java.util.Vector: void <init>()>();
v.<org.apache.log4j.net.SocketHubAppender: java.util.Vector oosList> = v;
v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.net.SocketHubAppender$ServerMonitor serverMonitor> = null;
v.<org.apache.log4j.net.SocketHubAppender: boolean locationInfo> = 0;
v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.helpers.CyclicBuffer buffer> = null;
v.<org.apache.log4j.net.SocketHubAppender: int port> = v;
specialinvoke v.<org.apache.log4j.net.SocketHubAppender: void startServer()>();
return;
}
public void activateOptions()
{
org.apache.log4j.net.SocketHubAppender v;
org.apache.log4j.net.ZeroConfSupport v, v;
int v;
java.lang.String v;
boolean v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v = v.<org.apache.log4j.net.SocketHubAppender: boolean advertiseViaMulticastDNS>;
if v == 0 goto label;
v = new org.apache.log4j.net.ZeroConfSupport;
v = v.<org.apache.log4j.net.SocketHubAppender: int port>;
v = virtualinvoke v.<org.apache.log4j.net.SocketHubAppender: java.lang.String getName()>();
specialinvoke v.<org.apache.log4j.net.ZeroConfSupport: void <init>(java.lang.String,int,java.lang.String)>("_log4j_obj_tcpaccept_appender.local.", v, v);
v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.net.ZeroConfSupport zeroConf> = v;
v = v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.net.ZeroConfSupport zeroConf>;
virtualinvoke v.<org.apache.log4j.net.ZeroConfSupport: void advertise()>();
label:
specialinvoke v.<org.apache.log4j.net.SocketHubAppender: void startServer()>();
return;
}
public synchronized void close()
{
org.apache.log4j.net.SocketHubAppender v;
org.apache.log4j.net.ZeroConfSupport v;
java.lang.String v, v, v, v;
boolean v, v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v = v.<org.apache.log4j.net.SocketHubAppender: boolean closed>;
if v == 0 goto label;
return;
label:
v = virtualinvoke v.<org.apache.log4j.net.SocketHubAppender: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("closing SocketHubAppender \u0001");
staticinvoke <org.apache.log4j.helpers.LogLog: void debug(java.lang.String)>(v);
v.<org.apache.log4j.net.SocketHubAppender: boolean closed> = 1;
v = v.<org.apache.log4j.net.SocketHubAppender: boolean advertiseViaMulticastDNS>;
if v == 0 goto label;
v = v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.net.ZeroConfSupport zeroConf>;
virtualinvoke v.<org.apache.log4j.net.ZeroConfSupport: void unadvertise()>();
label:
virtualinvoke v.<org.apache.log4j.net.SocketHubAppender: void cleanUp()>();
v = virtualinvoke v.<org.apache.log4j.net.SocketHubAppender: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("SocketHubAppender \u closed");
staticinvoke <org.apache.log4j.helpers.LogLog: void debug(java.lang.String)>(v);
return;
}
public void cleanUp()
{
org.apache.log4j.net.SocketHubAppender v;
java.util.Vector v, v, v;
int v;
java.lang.Object v;
org.apache.log4j.net.SocketHubAppender$ServerMonitor v;
v := @this: org.apache.log4j.net.SocketHubAppender;
staticinvoke <org.apache.log4j.helpers.LogLog: void debug(java.lang.String)>("stopping ServerSocket");
v = v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.net.SocketHubAppender$ServerMonitor serverMonitor>;
virtualinvoke v.<org.apache.log4j.net.SocketHubAppender$ServerMonitor: void stopMonitor()>();
v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.net.SocketHubAppender$ServerMonitor serverMonitor> = null;
staticinvoke <org.apache.log4j.helpers.LogLog: void debug(java.lang.String)>("closing client connections");
label:
v = v.<org.apache.log4j.net.SocketHubAppender: java.util.Vector oosList>;
v = virtualinvoke v.<java.util.Vector: int size()>();
if v == 0 goto label;
v = v.<org.apache.log4j.net.SocketHubAppender: java.util.Vector oosList>;
v = virtualinvoke v.<java.util.Vector: java.lang.Object elementAt(int)>(0);
if v == null goto label;
v = v.<org.apache.log4j.net.SocketHubAppender: java.util.Vector oosList>;
virtualinvoke v.<java.util.Vector: void removeElementAt(int)>(0);
goto label;
label:
return;
}
public void append(org.apache.log4j.spi.LoggingEvent)
{
java.util.Vector v, v, v, v;
java.lang.Thread v;
org.apache.log4j.helpers.CyclicBuffer v, v;
int v, v, v;
java.lang.String v, v;
boolean v, v;
org.apache.log4j.net.SocketHubAppender v;
org.apache.log4j.spi.LoggingEvent v;
java.io.IOException v;
java.lang.ArrayIndexOutOfBoundsException v;
java.lang.Object v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v := @parameter: org.apache.log4j.spi.LoggingEvent;
if v == null goto label;
v = v.<org.apache.log4j.net.SocketHubAppender: boolean locationInfo>;
if v == 0 goto label;
virtualinvoke v.<org.apache.log4j.spi.LoggingEvent: org.apache.log4j.spi.LocationInfo getLocationInformation()>();
label:
v = v.<org.apache.log4j.net.SocketHubAppender: java.lang.String application>;
if v == null goto label;
v = v.<org.apache.log4j.net.SocketHubAppender: java.lang.String application>;
virtualinvoke v.<org.apache.log4j.spi.LoggingEvent: void setProperty(java.lang.String,java.lang.String)>("application", v);
label:
virtualinvoke v.<org.apache.log4j.spi.LoggingEvent: java.lang.String getNDC()>();
virtualinvoke v.<org.apache.log4j.spi.LoggingEvent: java.lang.String getThreadName()>();
virtualinvoke v.<org.apache.log4j.spi.LoggingEvent: void getMDCCopy()>();
virtualinvoke v.<org.apache.log4j.spi.LoggingEvent: java.lang.String getRenderedMessage()>();
virtualinvoke v.<org.apache.log4j.spi.LoggingEvent: java.lang.String[] getThrowableStrRep()>();
v = v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.helpers.CyclicBuffer buffer>;
if v == null goto label;
v = v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.helpers.CyclicBuffer buffer>;
virtualinvoke v.<org.apache.log4j.helpers.CyclicBuffer: void add(org.apache.log4j.spi.LoggingEvent)>(v);
label:
if v == null goto label;
v = v.<org.apache.log4j.net.SocketHubAppender: java.util.Vector oosList>;
v = virtualinvoke v.<java.util.Vector: int size()>();
if v != 0 goto label;
label:
return;
label:
v = 0;
label:
v = v.<org.apache.log4j.net.SocketHubAppender: java.util.Vector oosList>;
v = virtualinvoke v.<java.util.Vector: int size()>();
if v >= v goto label;
label:
v = v.<org.apache.log4j.net.SocketHubAppender: java.util.Vector oosList>;
v = virtualinvoke v.<java.util.Vector: java.lang.Object elementAt(int)>(v);
label:
goto label;
label:
v := @caughtexception;
label:
if v == null goto label;
label:
virtualinvoke v.<java.io.ObjectOutputStream: void writeObject(java.lang.Object)>(v);
virtualinvoke v.<java.io.ObjectOutputStream: void flush()>();
virtualinvoke v.<java.io.ObjectOutputStream: void reset()>();
label:
goto label;
label:
v := @caughtexception;
v = v instanceof java.io.InterruptedIOException;
if v == 0 goto label;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
v = v.<org.apache.log4j.net.SocketHubAppender: java.util.Vector oosList>;
virtualinvoke v.<java.util.Vector: void removeElementAt(int)>(v);
staticinvoke <org.apache.log4j.helpers.LogLog: void debug(java.lang.String)>("dropped connection");
v = v - 1;
label:
v = v + 1;
goto label;
label:
return;
catch java.lang.ArrayIndexOutOfBoundsException from label to label with label;
catch java.io.IOException from label to label with label;
}
public boolean requiresLayout()
{
org.apache.log4j.net.SocketHubAppender v;
v := @this: org.apache.log4j.net.SocketHubAppender;
return 0;
}
public void setPort(int)
{
int v;
org.apache.log4j.net.SocketHubAppender v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v := @parameter: int;
v.<org.apache.log4j.net.SocketHubAppender: int port> = v;
return;
}
public void setApplication(java.lang.String)
{
org.apache.log4j.net.SocketHubAppender v;
java.lang.String v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v := @parameter: java.lang.String;
v.<org.apache.log4j.net.SocketHubAppender: java.lang.String application> = v;
return;
}
public java.lang.String getApplication()
{
org.apache.log4j.net.SocketHubAppender v;
java.lang.String v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v = v.<org.apache.log4j.net.SocketHubAppender: java.lang.String application>;
return v;
}
public int getPort()
{
int v;
org.apache.log4j.net.SocketHubAppender v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v = v.<org.apache.log4j.net.SocketHubAppender: int port>;
return v;
}
public void setBufferSize(int)
{
int v;
org.apache.log4j.net.SocketHubAppender v;
org.apache.log4j.helpers.CyclicBuffer v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v := @parameter: int;
v = new org.apache.log4j.helpers.CyclicBuffer;
specialinvoke v.<org.apache.log4j.helpers.CyclicBuffer: void <init>(int)>(v);
v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.helpers.CyclicBuffer buffer> = v;
return;
}
public int getBufferSize()
{
org.apache.log4j.net.SocketHubAppender v;
org.apache.log4j.helpers.CyclicBuffer v, v;
int v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v = v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.helpers.CyclicBuffer buffer>;
if v != null goto label;
return 0;
label:
v = v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.helpers.CyclicBuffer buffer>;
v = virtualinvoke v.<org.apache.log4j.helpers.CyclicBuffer: int getMaxSize()>();
return v;
}
public void setLocationInfo(boolean)
{
org.apache.log4j.net.SocketHubAppender v;
boolean v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v := @parameter: boolean;
v.<org.apache.log4j.net.SocketHubAppender: boolean locationInfo> = v;
return;
}
public boolean getLocationInfo()
{
org.apache.log4j.net.SocketHubAppender v;
boolean v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v = v.<org.apache.log4j.net.SocketHubAppender: boolean locationInfo>;
return v;
}
public void setAdvertiseViaMulticastDNS(boolean)
{
org.apache.log4j.net.SocketHubAppender v;
boolean v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v := @parameter: boolean;
v.<org.apache.log4j.net.SocketHubAppender: boolean advertiseViaMulticastDNS> = v;
return;
}
public boolean isAdvertiseViaMulticastDNS()
{
org.apache.log4j.net.SocketHubAppender v;
boolean v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v = v.<org.apache.log4j.net.SocketHubAppender: boolean advertiseViaMulticastDNS>;
return v;
}
private void startServer()
{
org.apache.log4j.net.SocketHubAppender v;
java.util.Vector v;
int v;
org.apache.log4j.net.SocketHubAppender$ServerMonitor v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v = new org.apache.log4j.net.SocketHubAppender$ServerMonitor;
v = v.<org.apache.log4j.net.SocketHubAppender: int port>;
v = v.<org.apache.log4j.net.SocketHubAppender: java.util.Vector oosList>;
specialinvoke v.<org.apache.log4j.net.SocketHubAppender$ServerMonitor: void <init>(org.apache.log4j.net.SocketHubAppender,int,java.util.Vector)>(v, v, v);
v.<org.apache.log4j.net.SocketHubAppender: org.apache.log4j.net.SocketHubAppender$ServerMonitor serverMonitor> = v;
return;
}
protected java.net.ServerSocket createServerSocket(int) throws java.io.IOException
{
int v;
java.net.ServerSocket v;
org.apache.log4j.net.SocketHubAppender v;
v := @this: org.apache.log4j.net.SocketHubAppender;
v := @parameter: int;
v = new java.net.ServerSocket;
specialinvoke v.<java.net.ServerSocket: void <init>(int)>(v);
return v;
}
}