public abstract class org.apache.zookeeper.server.ServerCnxn extends java.lang.Object implements org.apache.zookeeper.server.Stats, org.apache.zookeeper.Watcher
{
public static final java.lang.Object me;
private static final org.slf4j.Logger LOG;
public final org.apache.zookeeper.compat.ProtocolManager protocolManager;
private final java.util.Set authInfo;
private final java.util.concurrent.atomic.AtomicLong outstandingCount;
final org.apache.zookeeper.server.ZooKeeperServer zkServer;
private volatile boolean stale;
private volatile boolean invalid;
protected org.apache.zookeeper.server.ZooKeeperSaslServer zooKeeperSaslServer;
protected final java.util.Date established;
protected final java.util.concurrent.atomic.AtomicLong packetsReceived;
protected final java.util.concurrent.atomic.AtomicLong packetsSent;
protected long minLatency;
protected long maxLatency;
protected java.lang.String lastOp;
protected long lastCxid;
protected long lastZxid;
protected long lastResponseTime;
protected long lastLatency;
protected long count;
protected long totalLatency;
protected org.apache.zookeeper.server.ServerCnxn$DisconnectReason disconnectReason;
public void <init>(org.apache.zookeeper.server.ZooKeeperServer)
{
java.util.Date v;
java.util.concurrent.ConcurrentHashMap v;
java.util.Set v;
org.apache.zookeeper.server.ServerCnxn$DisconnectReason v;
org.apache.zookeeper.server.ZooKeeperServer v;
java.util.concurrent.atomic.AtomicLong v, v, v;
org.apache.zookeeper.server.ServerCnxn v;
org.apache.zookeeper.compat.ProtocolManager v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: org.apache.zookeeper.server.ZooKeeperServer;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new org.apache.zookeeper.compat.ProtocolManager;
specialinvoke v.<org.apache.zookeeper.compat.ProtocolManager: void <init>()>();
v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.compat.ProtocolManager protocolManager> = v;
v = new java.util.concurrent.ConcurrentHashMap;
specialinvoke v.<java.util.concurrent.ConcurrentHashMap: void <init>()>();
v = staticinvoke <java.util.Collections: java.util.Set newSetFromMap(java.util.Map)>(v);
v.<org.apache.zookeeper.server.ServerCnxn: java.util.Set authInfo> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>()>();
v.<org.apache.zookeeper.server.ServerCnxn: java.util.concurrent.atomic.AtomicLong outstandingCount> = v;
v.<org.apache.zookeeper.server.ServerCnxn: boolean stale> = 0;
v.<org.apache.zookeeper.server.ServerCnxn: boolean invalid> = 0;
v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ZooKeeperSaslServer zooKeeperSaslServer> = null;
v = new java.util.Date;
specialinvoke v.<java.util.Date: void <init>()>();
v.<org.apache.zookeeper.server.ServerCnxn: java.util.Date established> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>()>();
v.<org.apache.zookeeper.server.ServerCnxn: java.util.concurrent.atomic.AtomicLong packetsReceived> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>()>();
v.<org.apache.zookeeper.server.ServerCnxn: java.util.concurrent.atomic.AtomicLong packetsSent> = v;
v = <org.apache.zookeeper.server.ServerCnxn$DisconnectReason: org.apache.zookeeper.server.ServerCnxn$DisconnectReason UNKNOWN>;
v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ServerCnxn$DisconnectReason disconnectReason> = v;
v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ZooKeeperServer zkServer> = v;
return;
}
abstract int getSessionTimeout();
public void incrOutstandingAndCheckThrottle(org.apache.zookeeper.proto.RequestHeader)
{
org.apache.zookeeper.proto.RequestHeader v;
org.apache.zookeeper.server.ZooKeeperServer v;
java.util.concurrent.atomic.AtomicLong v;
int v;
long v;
org.apache.zookeeper.server.ServerCnxn v;
boolean v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: org.apache.zookeeper.proto.RequestHeader;
v = virtualinvoke v.<org.apache.zookeeper.proto.RequestHeader: int getXid()>();
if v > 0 goto label;
return;
label:
v = v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ZooKeeperServer zkServer>;
v = v.<org.apache.zookeeper.server.ServerCnxn: java.util.concurrent.atomic.AtomicLong outstandingCount>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long incrementAndGet()>();
v = virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: boolean shouldThrottle(long)>(v);
if v == 0 goto label;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: void disableRecv(boolean)>(0);
label:
return;
}
public void decrOutstandingAndCheckThrottle(org.apache.zookeeper.proto.ReplyHeader)
{
org.apache.zookeeper.server.ZooKeeperServer v;
java.util.concurrent.atomic.AtomicLong v;
int v;
long v;
org.apache.zookeeper.server.ServerCnxn v;
org.apache.zookeeper.proto.ReplyHeader v;
boolean v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: org.apache.zookeeper.proto.ReplyHeader;
v = virtualinvoke v.<org.apache.zookeeper.proto.ReplyHeader: int getXid()>();
if v > 0 goto label;
return;
label:
v = v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ZooKeeperServer zkServer>;
v = v.<org.apache.zookeeper.server.ServerCnxn: java.util.concurrent.atomic.AtomicLong outstandingCount>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long decrementAndGet()>();
v = virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: boolean shouldThrottle(long)>(v);
if v != 0 goto label;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: void enableRecv()>();
label:
return;
}
public abstract void close(org.apache.zookeeper.server.ServerCnxn$DisconnectReason);
public abstract int sendResponse(org.apache.zookeeper.proto.ReplyHeader, org.apache.jute.Record, java.lang.String, java.lang.String, org.apache.zookeeper.data.Stat, int) throws java.io.IOException;
public int sendResponse(org.apache.zookeeper.proto.ReplyHeader, org.apache.jute.Record, java.lang.String) throws java.io.IOException
{
int v, v;
org.apache.jute.Record v;
org.apache.zookeeper.server.ServerCnxn v;
java.lang.String v;
org.apache.zookeeper.proto.ReplyHeader v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: org.apache.zookeeper.proto.ReplyHeader;
v := @parameter: org.apache.jute.Record;
v := @parameter: java.lang.String;
v = (int) -1;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: int sendResponse(org.apache.zookeeper.proto.ReplyHeader,org.apache.jute.Record,java.lang.String,java.lang.String,org.apache.zookeeper.data.Stat,int)>(v, v, v, null, null, v);
return v;
}
protected byte[] serializeRecord(org.apache.jute.Record) throws java.io.IOException
{
byte[] v;
org.apache.jute.BinaryOutputArchive v;
java.io.ByteArrayOutputStream v;
int v;
org.apache.jute.Record v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: org.apache.jute.Record;
v = new java.io.ByteArrayOutputStream;
v = <org.apache.zookeeper.server.ZooKeeperServer: int intBufferStartingSizeBytes>;
specialinvoke v.<java.io.ByteArrayOutputStream: void <init>(int)>(v);
v = staticinvoke <org.apache.jute.BinaryOutputArchive: org.apache.jute.BinaryOutputArchive getArchive(java.io.OutputStream)>(v);
virtualinvoke v.<org.apache.jute.BinaryOutputArchive: void writeRecord(org.apache.jute.Record,java.lang.String)>(v, null);
v = virtualinvoke v.<java.io.ByteArrayOutputStream: byte[] toByteArray()>();
return v;
}
protected java.nio.ByteBuffer[] serialize(org.apache.zookeeper.proto.ReplyHeader, org.apache.jute.Record, java.lang.String, java.lang.String, org.apache.zookeeper.data.Stat, int) throws java.io.IOException
{
byte[] v, v;
org.apache.zookeeper.metrics.Counter v, v;
org.apache.zookeeper.data.Stat v;
java.nio.ByteBuffer v, v, v, v;
org.apache.zookeeper.server.ResponseCache v;
byte v;
org.apache.zookeeper.server.ServerMetrics v, v, v, v;
int v, v, v, v;
org.apache.zookeeper.server.ServerCnxn v;
java.lang.String v, v;
boolean v;
java.nio.ByteBuffer[] v;
org.apache.zookeeper.server.ServerStats v;
org.apache.jute.Record v;
org.apache.zookeeper.server.ZooKeeperServer v, v;
org.apache.zookeeper.proto.ReplyHeader v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: org.apache.zookeeper.proto.ReplyHeader;
v := @parameter: org.apache.jute.Record;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: org.apache.zookeeper.data.Stat;
v := @parameter: int;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: byte[] serializeRecord(org.apache.jute.Record)>(v);
v = null;
if v == null goto label;
v = null;
v = null;
v = null;
lookupswitch(v)
{
case 4: goto label;
case 12: goto label;
default: goto label;
};
label:
v = v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ZooKeeperServer zkServer>;
v = virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: org.apache.zookeeper.server.ResponseCache getReadResponseCache()>();
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
v = v.<org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.metrics.Counter RESPONSE_PACKET_CACHE_HITS>;
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
v = v.<org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.metrics.Counter RESPONSE_PACKET_CACHE_MISSING>;
goto label;
label:
v = v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ZooKeeperServer zkServer>;
v = virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: org.apache.zookeeper.server.ResponseCache getGetChildrenResponseCache()>();
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
v = v.<org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.metrics.Counter RESPONSE_PACKET_GET_CHILDREN_CACHE_HITS>;
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
v = v.<org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.metrics.Counter RESPONSE_PACKET_GET_CHILDREN_CACHE_MISSING>;
label:
if v == null goto label;
if v == null goto label;
if v == null goto label;
v = virtualinvoke v.<java.lang.String: boolean endsWith(java.lang.String)>("zookeeper_stats");
if v != 0 goto label;
v = virtualinvoke v.<org.apache.zookeeper.server.ResponseCache: byte[] get(java.lang.String,org.apache.zookeeper.data.Stat)>(v, v);
if v != null goto label;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: byte[] serializeRecord(org.apache.jute.Record)>(v);
virtualinvoke v.<org.apache.zookeeper.server.ResponseCache: void put(java.lang.String,byte[],org.apache.zookeeper.data.Stat)>(v, v, v);
interfaceinvoke v.<org.apache.zookeeper.metrics.Counter: void add(long)>(1L);
goto label;
label:
interfaceinvoke v.<org.apache.zookeeper.metrics.Counter: void add(long)>(1L);
goto label;
label:
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: byte[] serializeRecord(org.apache.jute.Record)>(v);
label:
if v != null goto label;
v = 0;
goto label;
label:
v = lengthof v;
label:
v = lengthof v;
v = v + v;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ServerStats serverStats()>();
if v == null goto label;
virtualinvoke v.<org.apache.zookeeper.server.ServerStats: void updateClientResponseSize(int)>(v);
label:
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer allocate(int)>(4);
v = virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer rewind()>();
if v == null goto label;
v = 3;
goto label;
label:
v = 2;
label:
v = newarray (java.nio.ByteBuffer)[v];
v[0] = v;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
v[1] = v;
if v == null goto label;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
v[2] = v;
label:
return v;
}
public abstract void sendCloseSession();
public abstract void process(org.apache.zookeeper.WatchedEvent);
public abstract long getSessionId();
abstract void setSessionId(long);
public java.util.List getAuthInfo()
{
java.util.List v;
java.util.Set v;
org.apache.zookeeper.server.ServerCnxn v;
java.util.ArrayList v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = new java.util.ArrayList;
v = v.<org.apache.zookeeper.server.ServerCnxn: java.util.Set authInfo>;
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
return v;
}
public void addAuthInfo(org.apache.zookeeper.data.Id)
{
java.util.Set v;
org.apache.zookeeper.server.ServerCnxn v;
org.apache.zookeeper.data.Id v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: org.apache.zookeeper.data.Id;
v = v.<org.apache.zookeeper.server.ServerCnxn: java.util.Set authInfo>;
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
return;
}
public boolean removeAuthInfo(org.apache.zookeeper.data.Id)
{
org.apache.zookeeper.data.Id v;
java.util.Set v;
org.apache.zookeeper.server.ServerCnxn v;
boolean v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: org.apache.zookeeper.data.Id;
v = v.<org.apache.zookeeper.server.ServerCnxn: java.util.Set authInfo>;
v = interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
return v;
}
abstract transient void sendBuffer(java.nio.ByteBuffer[]);
abstract void enableRecv();
void disableRecv()
{
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: void disableRecv(boolean)>(1);
return;
}
abstract void disableRecv(boolean);
abstract void setSessionTimeout(int);
public boolean isStale()
{
org.apache.zookeeper.server.ServerCnxn v;
boolean v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: boolean stale>;
return v;
}
public void setStale()
{
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v.<org.apache.zookeeper.server.ServerCnxn: boolean stale> = 1;
return;
}
public boolean isInvalid()
{
org.apache.zookeeper.server.ServerCnxn v;
boolean v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: boolean invalid>;
return v;
}
public void setInvalid()
{
org.apache.zookeeper.server.ServerCnxn v;
boolean v, v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: boolean invalid>;
if v != 0 goto label;
v = v.<org.apache.zookeeper.server.ServerCnxn: boolean stale>;
if v != 0 goto label;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: void sendCloseSession()>();
label:
v.<org.apache.zookeeper.server.ServerCnxn: boolean invalid> = 1;
label:
return;
}
protected void packetReceived(long)
{
org.apache.zookeeper.server.ServerStats v, v;
org.apache.zookeeper.metrics.Counter v;
org.apache.zookeeper.server.ServerMetrics v;
long v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: long;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long incrPacketsReceived()>();
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ServerStats serverStats()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ServerStats serverStats()>();
virtualinvoke v.<org.apache.zookeeper.server.ServerStats: void incrementPacketsReceived()>();
label:
v = staticinvoke <org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.server.ServerMetrics getMetrics()>();
v = v.<org.apache.zookeeper.server.ServerMetrics: org.apache.zookeeper.metrics.Counter BYTES_RECEIVED_COUNT>;
interfaceinvoke v.<org.apache.zookeeper.metrics.Counter: void add(long)>(v);
return;
}
protected void packetSent()
{
org.apache.zookeeper.server.ServerCnxn v;
org.apache.zookeeper.server.ServerStats v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long incrPacketsSent()>();
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ServerStats serverStats()>();
if v == null goto label;
virtualinvoke v.<org.apache.zookeeper.server.ServerStats: void incrementPacketsSent()>();
label:
return;
}
protected abstract org.apache.zookeeper.server.ServerStats serverStats();
public synchronized void resetStats()
{
org.apache.zookeeper.server.ServerCnxn$DisconnectReason v;
java.util.concurrent.atomic.AtomicLong v, v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = <org.apache.zookeeper.server.ServerCnxn$DisconnectReason: org.apache.zookeeper.server.ServerCnxn$DisconnectReason RESET_COMMAND>;
v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ServerCnxn$DisconnectReason disconnectReason> = v;
v = v.<org.apache.zookeeper.server.ServerCnxn: java.util.concurrent.atomic.AtomicLong packetsReceived>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(0L);
v = v.<org.apache.zookeeper.server.ServerCnxn: java.util.concurrent.atomic.AtomicLong packetsSent>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(0L);
v.<org.apache.zookeeper.server.ServerCnxn: long minLatency> = 9223372036854775807L;
v.<org.apache.zookeeper.server.ServerCnxn: long maxLatency> = 0L;
v.<org.apache.zookeeper.server.ServerCnxn: java.lang.String lastOp> = "NA";
v.<org.apache.zookeeper.server.ServerCnxn: long lastCxid> = -1L;
v.<org.apache.zookeeper.server.ServerCnxn: long lastZxid> = -1L;
v.<org.apache.zookeeper.server.ServerCnxn: long lastResponseTime> = 0L;
v.<org.apache.zookeeper.server.ServerCnxn: long lastLatency> = 0L;
v.<org.apache.zookeeper.server.ServerCnxn: long count> = 0L;
v.<org.apache.zookeeper.server.ServerCnxn: long totalLatency> = 0L;
return;
}
protected long incrPacketsReceived()
{
java.util.concurrent.atomic.AtomicLong v;
long v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: java.util.concurrent.atomic.AtomicLong packetsReceived>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long incrementAndGet()>();
return v;
}
protected long incrPacketsSent()
{
java.util.concurrent.atomic.AtomicLong v;
long v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: java.util.concurrent.atomic.AtomicLong packetsSent>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long incrementAndGet()>();
return v;
}
protected synchronized void updateStatsForResponse(long, long, java.lang.String, long, long)
{
long v, v, v, v, v, v, v, v, v, v, v;
byte v, v, v;
org.apache.zookeeper.server.ServerCnxn v;
java.lang.String v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: long;
v := @parameter: long;
v := @parameter: java.lang.String;
v := @parameter: long;
v := @parameter: long;
v = v cmp 0L;
if v < 0 goto label;
v.<org.apache.zookeeper.server.ServerCnxn: long lastCxid> = v;
label:
v.<org.apache.zookeeper.server.ServerCnxn: long lastZxid> = v;
v.<org.apache.zookeeper.server.ServerCnxn: java.lang.String lastOp> = v;
v.<org.apache.zookeeper.server.ServerCnxn: long lastResponseTime> = v;
v = v - v;
v.<org.apache.zookeeper.server.ServerCnxn: long lastLatency> = v;
v = v.<org.apache.zookeeper.server.ServerCnxn: long minLatency>;
v = v cmp v;
if v >= 0 goto label;
v.<org.apache.zookeeper.server.ServerCnxn: long minLatency> = v;
label:
v = v.<org.apache.zookeeper.server.ServerCnxn: long maxLatency>;
v = v cmp v;
if v <= 0 goto label;
v.<org.apache.zookeeper.server.ServerCnxn: long maxLatency> = v;
label:
v = v.<org.apache.zookeeper.server.ServerCnxn: long count>;
v = v + 1L;
v.<org.apache.zookeeper.server.ServerCnxn: long count> = v;
v = v.<org.apache.zookeeper.server.ServerCnxn: long totalLatency>;
v = v + v;
v.<org.apache.zookeeper.server.ServerCnxn: long totalLatency> = v;
return;
}
public java.util.Date getEstablished()
{
java.lang.Object v;
org.apache.zookeeper.server.ServerCnxn v;
java.util.Date v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: java.util.Date established>;
v = virtualinvoke v.<java.util.Date: java.lang.Object clone()>();
return v;
}
public long getOutstandingRequests()
{
java.util.concurrent.atomic.AtomicLong v;
long v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: java.util.concurrent.atomic.AtomicLong outstandingCount>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long longValue()>();
return v;
}
public long getPacketsReceived()
{
java.util.concurrent.atomic.AtomicLong v;
long v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: java.util.concurrent.atomic.AtomicLong packetsReceived>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long longValue()>();
return v;
}
public long getPacketsSent()
{
java.util.concurrent.atomic.AtomicLong v;
long v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: java.util.concurrent.atomic.AtomicLong packetsSent>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long longValue()>();
return v;
}
public synchronized long getMinLatency()
{
byte v;
long v, v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: long minLatency>;
v = v cmp 9223372036854775807L;
if v != 0 goto label;
v = 0L;
goto label;
label:
v = v.<org.apache.zookeeper.server.ServerCnxn: long minLatency>;
label:
return v;
}
public synchronized long getAvgLatency()
{
byte v;
long v, v, v, v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: long count>;
v = v cmp 0L;
if v != 0 goto label;
v = 0L;
goto label;
label:
v = v.<org.apache.zookeeper.server.ServerCnxn: long totalLatency>;
v = v.<org.apache.zookeeper.server.ServerCnxn: long count>;
v = v / v;
label:
return v;
}
public synchronized long getMaxLatency()
{
long v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: long maxLatency>;
return v;
}
public synchronized java.lang.String getLastOperation()
{
org.apache.zookeeper.server.ServerCnxn v;
java.lang.String v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: java.lang.String lastOp>;
return v;
}
public synchronized long getLastCxid()
{
long v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: long lastCxid>;
return v;
}
public synchronized long getLastZxid()
{
long v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: long lastZxid>;
return v;
}
public synchronized long getLastResponseTime()
{
long v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: long lastResponseTime>;
return v;
}
public synchronized long getLastLatency()
{
long v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: long lastLatency>;
return v;
}
public java.lang.String toString()
{
java.io.PrintWriter v;
java.io.StringWriter v;
org.apache.zookeeper.server.ServerCnxn v;
java.lang.String v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = new java.io.StringWriter;
specialinvoke v.<java.io.StringWriter: void <init>()>();
v = new java.io.PrintWriter;
specialinvoke v.<java.io.PrintWriter: void <init>(java.io.Writer)>(v);
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: void dumpConnectionInfo(java.io.PrintWriter,boolean)>(v, 0);
virtualinvoke v.<java.io.PrintWriter: void flush()>();
virtualinvoke v.<java.io.PrintWriter: void close()>();
v = virtualinvoke v.<java.io.StringWriter: java.lang.String toString()>();
return v;
}
public abstract java.net.InetSocketAddress getRemoteSocketAddress();
public abstract int getInterestOps();
public abstract boolean isSecure();
public abstract java.security.cert.Certificate[] getClientCertificateChain();
public abstract void setClientCertificateChain(java.security.cert.Certificate[]);
public synchronized void dumpConnectionInfo(java.io.PrintWriter, boolean)
{
java.util.Date v;
long v, v, v, v, v, v, v, v, v, v, v, v;
byte v, v;
int v, v;
org.apache.zookeeper.server.ServerCnxn v;
java.lang.String v, v, v, v, v;
boolean v;
java.io.PrintWriter v;
java.net.InetSocketAddress v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: java.io.PrintWriter;
v := @parameter: boolean;
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(" ");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: java.net.InetSocketAddress getRemoteSocketAddress()>();
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.Object)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>("[");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: int getInterestOps()>();
if v != 0 goto label;
v = "0";
goto label;
label:
v = staticinvoke <java.lang.Integer: java.lang.String toHexString(int)>(v);
label:
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>("](queued=");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getOutstandingRequests()>();
virtualinvoke v.<java.io.PrintWriter: void print(long)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(",recved=");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getPacketsReceived()>();
virtualinvoke v.<java.io.PrintWriter: void print(long)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(",sent=");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getPacketsSent()>();
virtualinvoke v.<java.io.PrintWriter: void print(long)>(v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getSessionId()>();
v = v cmp 0L;
if v == 0 goto label;
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(",sid=0x");
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(",lop=");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: java.lang.String getLastOperation()>();
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(",est=");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: java.util.Date getEstablished()>();
v = virtualinvoke v.<java.util.Date: long getTime()>();
virtualinvoke v.<java.io.PrintWriter: void print(long)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(",to=");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: int getSessionTimeout()>();
virtualinvoke v.<java.io.PrintWriter: void print(int)>(v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getLastCxid()>();
v = v cmp 0L;
if v < 0 goto label;
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(",lcxid=0x");
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(v);
label:
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(",lzxid=0x");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getLastZxid()>();
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(",lresp=");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getLastResponseTime()>();
virtualinvoke v.<java.io.PrintWriter: void print(long)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(",llat=");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getLastLatency()>();
virtualinvoke v.<java.io.PrintWriter: void print(long)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(",minlat=");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getMinLatency()>();
virtualinvoke v.<java.io.PrintWriter: void print(long)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(",avglat=");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getAvgLatency()>();
virtualinvoke v.<java.io.PrintWriter: void print(long)>(v);
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(",maxlat=");
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getMaxLatency()>();
virtualinvoke v.<java.io.PrintWriter: void print(long)>(v);
label:
virtualinvoke v.<java.io.PrintWriter: void print(java.lang.String)>(")");
return;
}
public synchronized java.util.Map getConnectionInfo(boolean)
{
java.util.Date v;
java.lang.Integer v, v;
java.lang.Long v, v, v, v, v, v, v, v, v, v, v;
org.apache.zookeeper.server.ServerCnxn v;
boolean v;
java.net.InetSocketAddress v;
long v, v, v, v, v, v, v, v, v, v, v;
java.util.LinkedHashMap v;
int v, v;
java.lang.String v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: boolean;
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: java.net.InetSocketAddress getRemoteSocketAddress()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("remote_socket_address", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: int getInterestOps()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("interest_ops", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getOutstandingRequests()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("outstanding_requests", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getPacketsReceived()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("packets_received", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getPacketsSent()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("packets_sent", v);
if v != 0 goto label;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getSessionId()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("session_id", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: java.lang.String getLastOperation()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("last_operation", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: java.util.Date getEstablished()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("established", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: int getSessionTimeout()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("session_timeout", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getLastCxid()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("last_cxid", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getLastZxid()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("last_zxid", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getLastResponseTime()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("last_response_time", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getLastLatency()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("last_latency", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getMinLatency()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("min_latency", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getAvgLatency()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("avg_latency", v);
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getMaxLatency()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>("max_latency", v);
label:
return v;
}
public void cleanupWriterSocket(java.io.PrintWriter)
{
java.io.PrintWriter v;
java.lang.Throwable v;
org.slf4j.Logger v, v, v, v;
java.lang.Exception v, v, v, v;
org.apache.zookeeper.server.ServerCnxn$DisconnectReason v, v, v;
org.apache.zookeeper.server.ServerCnxn v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v := @parameter: java.io.PrintWriter;
label:
if v == null goto label;
virtualinvoke v.<java.io.PrintWriter: void flush()>();
virtualinvoke v.<java.io.PrintWriter: void close()>();
label:
v = <org.apache.zookeeper.server.ServerCnxn$DisconnectReason: org.apache.zookeeper.server.ServerCnxn$DisconnectReason CLOSE_CONNECTION_COMMAND>;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: void close(org.apache.zookeeper.server.ServerCnxn$DisconnectReason)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.zookeeper.server.ServerCnxn: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error closing a command socket ", v);
goto label;
label:
v := @caughtexception;
v = <org.apache.zookeeper.server.ServerCnxn: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String,java.lang.Throwable)>("Error closing PrintWriter ", v);
label:
v = <org.apache.zookeeper.server.ServerCnxn$DisconnectReason: org.apache.zookeeper.server.ServerCnxn$DisconnectReason CLOSE_CONNECTION_COMMAND>;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: void close(org.apache.zookeeper.server.ServerCnxn$DisconnectReason)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.zookeeper.server.ServerCnxn: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error closing a command socket ", v);
goto label;
label:
v := @caughtexception;
label:
v = <org.apache.zookeeper.server.ServerCnxn$DisconnectReason: org.apache.zookeeper.server.ServerCnxn$DisconnectReason CLOSE_CONNECTION_COMMAND>;
virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: void close(org.apache.zookeeper.server.ServerCnxn$DisconnectReason)>(v);
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.zookeeper.server.ServerCnxn: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void error(java.lang.String,java.lang.Throwable)>("Error closing a command socket ", v);
label:
throw v;
label:
return;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Exception from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
catch java.lang.Exception from label to label with label;
}
public boolean isZKServerRunning()
{
org.apache.zookeeper.server.ZooKeeperServer v, v;
org.apache.zookeeper.server.ServerCnxn v;
boolean v, v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ZooKeeperServer zkServer>;
if v == null goto label;
v = v.<org.apache.zookeeper.server.ServerCnxn: org.apache.zookeeper.server.ZooKeeperServer zkServer>;
v = virtualinvoke v.<org.apache.zookeeper.server.ZooKeeperServer: boolean isRunning()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public java.lang.String getHostAddress()
{
java.net.InetAddress v;
org.apache.zookeeper.server.ServerCnxn v;
java.lang.String v;
java.net.InetSocketAddress v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: java.net.InetSocketAddress getRemoteSocketAddress()>();
if v != null goto label;
return "";
label:
v = virtualinvoke v.<java.net.InetSocketAddress: java.net.InetAddress getAddress()>();
if v != null goto label;
return "";
label:
v = virtualinvoke v.<java.net.InetAddress: java.lang.String getHostAddress()>();
return v;
}
public java.lang.String getSessionIdHex()
{
long v;
org.apache.zookeeper.server.ServerCnxn v;
java.lang.String v, v;
v := @this: org.apache.zookeeper.server.ServerCnxn;
v = virtualinvoke v.<org.apache.zookeeper.server.ServerCnxn: long getSessionId()>();
v = staticinvoke <java.lang.Long: java.lang.String toHexString(long)>(v);
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[])>("0x\u0001");
return v;
}
static void <clinit>()
{
java.lang.Object v;
org.slf4j.Logger v;
v = new java.lang.Object;
specialinvoke v.<java.lang.Object: void <init>()>();
<org.apache.zookeeper.server.ServerCnxn: java.lang.Object me> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/zookeeper/server/ServerCnxn;");
<org.apache.zookeeper.server.ServerCnxn: org.slf4j.Logger LOG> = v;
return;
}
}