public class org.glassfish.grizzly.websockets.SimpleWebSocket extends java.lang.Object implements org.glassfish.grizzly.websockets.WebSocket
{
private static final java.util.logging.Logger LOGGER;
protected final java.util.Queue listeners;
protected final org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler;
protected org.glassfish.grizzly.websockets.Broadcaster broadcaster;
protected final java.util.EnumSet connected;
protected final java.util.concurrent.atomic.AtomicReference state;
public transient void <init>(org.glassfish.grizzly.websockets.ProtocolHandler, org.glassfish.grizzly.websockets.WebSocketListener[])
{
org.glassfish.grizzly.websockets.WebSocketListener[] v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.websockets.SimpleWebSocket$State v, v, v;
java.util.concurrent.atomic.AtomicReference v;
org.glassfish.grizzly.websockets.ProtocolHandler v;
org.glassfish.grizzly.websockets.WebSocketListener v;
int v, v;
org.glassfish.grizzly.websockets.DummyBroadcaster v;
java.util.EnumSet v;
java.util.concurrent.ConcurrentLinkedQueue v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: org.glassfish.grizzly.websockets.ProtocolHandler;
v := @parameter: org.glassfish.grizzly.websockets.WebSocketListener[];
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.concurrent.ConcurrentLinkedQueue;
specialinvoke v.<java.util.concurrent.ConcurrentLinkedQueue: void <init>()>();
v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.Queue listeners> = v;
v = new org.glassfish.grizzly.websockets.DummyBroadcaster;
specialinvoke v.<org.glassfish.grizzly.websockets.DummyBroadcaster: void <init>()>();
v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.Broadcaster broadcaster> = v;
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State CONNECTED>;
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State CLOSING>;
v = staticinvoke <java.util.EnumSet: java.util.EnumSet range(java.lang.Enum,java.lang.Enum)>(v, v);
v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.EnumSet connected> = v;
v = new java.util.concurrent.atomic.AtomicReference;
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State NEW>;
specialinvoke v.<java.util.concurrent.atomic.AtomicReference: void <init>(java.lang.Object)>(v);
v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.concurrent.atomic.AtomicReference state> = v;
v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler> = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<org.glassfish.grizzly.websockets.SimpleWebSocket: boolean add(org.glassfish.grizzly.websockets.WebSocketListener)>(v);
v = v + 1;
goto label;
label:
virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: void setWebSocket(org.glassfish.grizzly.websockets.WebSocket)>(v);
return;
}
public java.util.Collection getListeners()
{
java.util.Queue v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.Queue listeners>;
return v;
}
public final boolean add(org.glassfish.grizzly.websockets.WebSocketListener)
{
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.websockets.WebSocketListener v;
java.util.Queue v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: org.glassfish.grizzly.websockets.WebSocketListener;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.Queue listeners>;
v = interfaceinvoke v.<java.util.Queue: boolean add(java.lang.Object)>(v);
return v;
}
public final boolean remove(org.glassfish.grizzly.websockets.WebSocketListener)
{
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.websockets.WebSocketListener v;
java.util.Queue v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: org.glassfish.grizzly.websockets.WebSocketListener;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.Queue listeners>;
v = interfaceinvoke v.<java.util.Queue: boolean remove(java.lang.Object)>(v);
return v;
}
public boolean isConnected()
{
org.glassfish.grizzly.websockets.SimpleWebSocket v;
java.lang.Object v;
java.util.concurrent.atomic.AtomicReference v;
java.util.EnumSet v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.EnumSet connected>;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.concurrent.atomic.AtomicReference state>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = virtualinvoke v.<java.util.EnumSet: boolean contains(java.lang.Object)>(v);
return v;
}
public void setClosed()
{
org.glassfish.grizzly.websockets.SimpleWebSocket$State v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
java.util.concurrent.atomic.AtomicReference v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.concurrent.atomic.AtomicReference state>;
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State CLOSED>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
return;
}
public void onClose(org.glassfish.grizzly.websockets.DataFrame)
{
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.websockets.SimpleWebSocket$State v, v, v;
java.util.concurrent.atomic.AtomicReference v, v;
org.glassfish.grizzly.websockets.DataFrame v;
org.glassfish.grizzly.websockets.ProtocolHandler v, v;
int v;
java.lang.Object v;
java.lang.String v;
java.util.Queue v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: org.glassfish.grizzly.websockets.DataFrame;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.concurrent.atomic.AtomicReference state>;
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State CONNECTED>;
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State CLOSING>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: boolean compareAndSet(java.lang.Object,java.lang.Object)>(v, v);
if v == 0 goto label;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.ClosingFrame: int getCode()>();
v = virtualinvoke v.<org.glassfish.grizzly.websockets.ClosingFrame: java.lang.String getTextPayload()>();
virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: org.glassfish.grizzly.GrizzlyFuture close(int,java.lang.String)>(v, v);
goto label;
label:
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.concurrent.atomic.AtomicReference state>;
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State CLOSED>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler>;
virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: void doClose()>();
label:
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.Queue listeners>;
v = interfaceinvoke v.<java.util.Queue: java.lang.Object poll()>();
if v == null goto label;
interfaceinvoke v.<org.glassfish.grizzly.websockets.WebSocketListener: void onClose(org.glassfish.grizzly.websockets.WebSocket,org.glassfish.grizzly.websockets.DataFrame)>(v, v);
goto label;
label:
return;
}
public void onConnect()
{
java.util.Iterator v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
java.lang.Object v;
org.glassfish.grizzly.websockets.SimpleWebSocket$State v;
java.util.Queue v;
java.util.concurrent.atomic.AtomicReference v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.concurrent.atomic.AtomicReference state>;
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State CONNECTED>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: void set(java.lang.Object)>(v);
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.Queue listeners>;
v = interfaceinvoke v.<java.util.Queue: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<org.glassfish.grizzly.websockets.WebSocketListener: void onConnect(org.glassfish.grizzly.websockets.WebSocket)>(v);
goto label;
label:
return;
}
public void onFragment(boolean, byte[])
{
byte[] v;
java.util.Iterator v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
java.lang.Object v;
java.util.Queue v;
boolean v, v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: boolean;
v := @parameter: byte[];
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.Queue listeners>;
v = interfaceinvoke v.<java.util.Queue: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<org.glassfish.grizzly.websockets.WebSocketListener: void onFragment(org.glassfish.grizzly.websockets.WebSocket,byte[],boolean)>(v, v, v);
goto label;
label:
return;
}
public void onFragment(boolean, java.lang.String)
{
java.util.Iterator v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
java.lang.Object v;
java.lang.String v;
java.util.Queue v;
boolean v, v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.Queue listeners>;
v = interfaceinvoke v.<java.util.Queue: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<org.glassfish.grizzly.websockets.WebSocketListener: void onFragment(org.glassfish.grizzly.websockets.WebSocket,java.lang.String,boolean)>(v, v, v);
goto label;
label:
return;
}
public void onMessage(byte[])
{
byte[] v;
java.util.Iterator v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
java.lang.Object v;
java.util.Queue v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: byte[];
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.Queue listeners>;
v = interfaceinvoke v.<java.util.Queue: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<org.glassfish.grizzly.websockets.WebSocketListener: void onMessage(org.glassfish.grizzly.websockets.WebSocket,byte[])>(v, v);
goto label;
label:
return;
}
public void onMessage(java.lang.String)
{
java.util.Iterator v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
java.lang.Object v;
java.lang.String v;
java.util.Queue v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: java.lang.String;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.Queue listeners>;
v = interfaceinvoke v.<java.util.Queue: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<org.glassfish.grizzly.websockets.WebSocketListener: void onMessage(org.glassfish.grizzly.websockets.WebSocket,java.lang.String)>(v, v);
goto label;
label:
return;
}
public void onPing(org.glassfish.grizzly.websockets.DataFrame)
{
byte[] v, v;
java.util.Iterator v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.websockets.DataFrame v, v;
java.lang.Object v;
java.util.Queue v;
boolean v;
org.glassfish.grizzly.websockets.frametypes.PongFrameType v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: org.glassfish.grizzly.websockets.DataFrame;
v = new org.glassfish.grizzly.websockets.DataFrame;
v = new org.glassfish.grizzly.websockets.frametypes.PongFrameType;
specialinvoke v.<org.glassfish.grizzly.websockets.frametypes.PongFrameType: void <init>()>();
v = virtualinvoke v.<org.glassfish.grizzly.websockets.DataFrame: byte[] getBytes()>();
specialinvoke v.<org.glassfish.grizzly.websockets.DataFrame: void <init>(org.glassfish.grizzly.websockets.FrameType,byte[])>(v, v);
specialinvoke v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.GrizzlyFuture send(org.glassfish.grizzly.websockets.DataFrame)>(v);
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.Queue listeners>;
v = interfaceinvoke v.<java.util.Queue: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.glassfish.grizzly.websockets.DataFrame: byte[] getBytes()>();
interfaceinvoke v.<org.glassfish.grizzly.websockets.WebSocketListener: void onPing(org.glassfish.grizzly.websockets.WebSocket,byte[])>(v, v);
goto label;
label:
return;
}
public void onPong(org.glassfish.grizzly.websockets.DataFrame)
{
byte[] v;
java.util.Iterator v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
java.lang.Object v;
java.util.Queue v;
org.glassfish.grizzly.websockets.DataFrame v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: org.glassfish.grizzly.websockets.DataFrame;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.Queue listeners>;
v = interfaceinvoke v.<java.util.Queue: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<org.glassfish.grizzly.websockets.DataFrame: byte[] getBytes()>();
interfaceinvoke v.<org.glassfish.grizzly.websockets.WebSocketListener: void onPong(org.glassfish.grizzly.websockets.WebSocket,byte[])>(v, v);
goto label;
label:
return;
}
public void close()
{
org.glassfish.grizzly.websockets.SimpleWebSocket v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
virtualinvoke v.<org.glassfish.grizzly.websockets.SimpleWebSocket: void close(int,java.lang.String)>(1000, null);
return;
}
public void close(int)
{
int v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: int;
virtualinvoke v.<org.glassfish.grizzly.websockets.SimpleWebSocket: void close(int,java.lang.String)>(v, null);
return;
}
public void close(int, java.lang.String)
{
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.websockets.SimpleWebSocket$State v, v;
java.util.concurrent.atomic.AtomicReference v;
org.glassfish.grizzly.websockets.ProtocolHandler v;
int v;
java.lang.String v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: int;
v := @parameter: java.lang.String;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.concurrent.atomic.AtomicReference state>;
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State CONNECTED>;
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State CLOSING>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: boolean compareAndSet(java.lang.Object,java.lang.Object)>(v, v);
if v == 0 goto label;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler>;
virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: org.glassfish.grizzly.GrizzlyFuture close(int,java.lang.String)>(v, v);
label:
return;
}
public org.glassfish.grizzly.GrizzlyFuture send(byte[])
{
byte[] v;
org.glassfish.grizzly.websockets.ProtocolHandler v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.GrizzlyFuture v;
java.lang.RuntimeException v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: byte[];
v = virtualinvoke v.<org.glassfish.grizzly.websockets.SimpleWebSocket: boolean isConnected()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: org.glassfish.grizzly.GrizzlyFuture send(byte[])>(v);
return v;
label:
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("Socket is not connected.");
throw v;
}
public org.glassfish.grizzly.GrizzlyFuture send(java.lang.String)
{
org.glassfish.grizzly.websockets.ProtocolHandler v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.GrizzlyFuture v;
java.lang.RuntimeException v;
java.lang.String v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.SimpleWebSocket: boolean isConnected()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: org.glassfish.grizzly.GrizzlyFuture send(java.lang.String)>(v);
return v;
label:
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("Socket is not connected.");
throw v;
}
public void broadcast(java.lang.Iterable, java.lang.String)
{
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.websockets.SimpleWebSocket$State v;
java.lang.RuntimeException v;
java.util.concurrent.atomic.AtomicReference v;
java.lang.Iterable v;
org.glassfish.grizzly.websockets.Broadcaster v;
java.lang.Object v;
java.lang.String v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: java.lang.Iterable;
v := @parameter: java.lang.String;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.concurrent.atomic.AtomicReference state>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State CONNECTED>;
if v != v goto label;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.Broadcaster broadcaster>;
interfaceinvoke v.<org.glassfish.grizzly.websockets.Broadcaster: void broadcast(java.lang.Iterable,java.lang.String)>(v, v);
goto label;
label:
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("Socket is already closed.");
throw v;
label:
return;
}
public void broadcast(java.lang.Iterable, byte[])
{
byte[] v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.websockets.SimpleWebSocket$State v;
java.lang.RuntimeException v;
java.util.concurrent.atomic.AtomicReference v;
java.lang.Iterable v;
org.glassfish.grizzly.websockets.Broadcaster v;
java.lang.Object v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: java.lang.Iterable;
v := @parameter: byte[];
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.concurrent.atomic.AtomicReference state>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State CONNECTED>;
if v != v goto label;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.Broadcaster broadcaster>;
interfaceinvoke v.<org.glassfish.grizzly.websockets.Broadcaster: void broadcast(java.lang.Iterable,byte[])>(v, v);
goto label;
label:
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("Socket is already closed.");
throw v;
label:
return;
}
public void broadcastFragment(java.lang.Iterable, java.lang.String, boolean)
{
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.websockets.SimpleWebSocket$State v;
java.lang.RuntimeException v;
java.util.concurrent.atomic.AtomicReference v;
java.lang.Iterable v;
org.glassfish.grizzly.websockets.Broadcaster v;
java.lang.Object v;
java.lang.String v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: java.lang.Iterable;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.concurrent.atomic.AtomicReference state>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State CONNECTED>;
if v != v goto label;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.Broadcaster broadcaster>;
interfaceinvoke v.<org.glassfish.grizzly.websockets.Broadcaster: void broadcastFragment(java.lang.Iterable,java.lang.String,boolean)>(v, v, v);
goto label;
label:
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("Socket is already closed.");
throw v;
label:
return;
}
public void broadcastFragment(java.lang.Iterable, byte[], boolean)
{
byte[] v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.websockets.SimpleWebSocket$State v;
java.lang.RuntimeException v;
java.util.concurrent.atomic.AtomicReference v;
java.lang.Iterable v;
org.glassfish.grizzly.websockets.Broadcaster v;
java.lang.Object v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: java.lang.Iterable;
v := @parameter: byte[];
v := @parameter: boolean;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.concurrent.atomic.AtomicReference state>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicReference: java.lang.Object get()>();
v = <org.glassfish.grizzly.websockets.SimpleWebSocket$State: org.glassfish.grizzly.websockets.SimpleWebSocket$State CONNECTED>;
if v != v goto label;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.Broadcaster broadcaster>;
interfaceinvoke v.<org.glassfish.grizzly.websockets.Broadcaster: void broadcastFragment(java.lang.Iterable,byte[],boolean)>(v, v, v);
goto label;
label:
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("Socket is already closed.");
throw v;
label:
return;
}
public org.glassfish.grizzly.GrizzlyFuture sendPing(byte[])
{
byte[] v;
org.glassfish.grizzly.websockets.frametypes.PingFrameType v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.GrizzlyFuture v;
org.glassfish.grizzly.websockets.DataFrame v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: byte[];
v = new org.glassfish.grizzly.websockets.DataFrame;
v = new org.glassfish.grizzly.websockets.frametypes.PingFrameType;
specialinvoke v.<org.glassfish.grizzly.websockets.frametypes.PingFrameType: void <init>()>();
specialinvoke v.<org.glassfish.grizzly.websockets.DataFrame: void <init>(org.glassfish.grizzly.websockets.FrameType,byte[])>(v, v);
v = specialinvoke v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.GrizzlyFuture send(org.glassfish.grizzly.websockets.DataFrame)>(v);
return v;
}
public org.glassfish.grizzly.GrizzlyFuture sendPong(byte[])
{
byte[] v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.GrizzlyFuture v;
org.glassfish.grizzly.websockets.DataFrame v;
org.glassfish.grizzly.websockets.frametypes.PongFrameType v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: byte[];
v = new org.glassfish.grizzly.websockets.DataFrame;
v = new org.glassfish.grizzly.websockets.frametypes.PongFrameType;
specialinvoke v.<org.glassfish.grizzly.websockets.frametypes.PongFrameType: void <init>()>();
specialinvoke v.<org.glassfish.grizzly.websockets.DataFrame: void <init>(org.glassfish.grizzly.websockets.FrameType,byte[])>(v, v);
v = specialinvoke v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.GrizzlyFuture send(org.glassfish.grizzly.websockets.DataFrame)>(v);
return v;
}
private org.glassfish.grizzly.GrizzlyFuture send(org.glassfish.grizzly.websockets.DataFrame)
{
org.glassfish.grizzly.websockets.ProtocolHandler v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.GrizzlyFuture v;
java.lang.RuntimeException v;
org.glassfish.grizzly.websockets.DataFrame v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: org.glassfish.grizzly.websockets.DataFrame;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.SimpleWebSocket: boolean isConnected()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: org.glassfish.grizzly.GrizzlyFuture send(org.glassfish.grizzly.websockets.DataFrame)>(v);
return v;
label:
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("Socket is not connected.");
throw v;
}
public org.glassfish.grizzly.GrizzlyFuture stream(boolean, java.lang.String)
{
org.glassfish.grizzly.websockets.ProtocolHandler v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.GrizzlyFuture v;
java.lang.RuntimeException v;
java.lang.String v;
boolean v, v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: boolean;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.SimpleWebSocket: boolean isConnected()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: org.glassfish.grizzly.GrizzlyFuture stream(boolean,java.lang.String)>(v, v);
return v;
label:
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("Socket is not connected.");
throw v;
}
public org.glassfish.grizzly.GrizzlyFuture stream(boolean, byte[], int, int)
{
byte[] v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
java.lang.RuntimeException v;
org.glassfish.grizzly.websockets.ProtocolHandler v;
org.glassfish.grizzly.GrizzlyFuture v;
int v, v;
boolean v, v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: boolean;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.SimpleWebSocket: boolean isConnected()>();
if v == 0 goto label;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: org.glassfish.grizzly.GrizzlyFuture stream(boolean,byte[],int,int)>(v, v, v, v);
return v;
label:
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.String)>("Socket is not connected.");
throw v;
}
protected byte[] toRawData(java.lang.String)
{
byte[] v;
java.lang.String v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: java.lang.String;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.SimpleWebSocket: byte[] toRawData(java.lang.String,boolean)>(v, 1);
return v;
}
protected byte[] toRawData(byte[])
{
byte[] v, v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: byte[];
v = virtualinvoke v.<org.glassfish.grizzly.websockets.SimpleWebSocket: byte[] toRawData(byte[],boolean)>(v, 1);
return v;
}
protected byte[] toRawData(java.lang.String, boolean)
{
byte[] v;
org.glassfish.grizzly.websockets.ProtocolHandler v, v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
java.lang.String v;
org.glassfish.grizzly.websockets.DataFrame v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: java.lang.String;
v := @parameter: boolean;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: org.glassfish.grizzly.websockets.DataFrame toDataFrame(java.lang.String,boolean)>(v, v);
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: byte[] frame(org.glassfish.grizzly.websockets.DataFrame)>(v);
return v;
}
protected byte[] toRawData(byte[], boolean)
{
byte[] v, v;
org.glassfish.grizzly.websockets.ProtocolHandler v, v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.websockets.DataFrame v;
boolean v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: byte[];
v := @parameter: boolean;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: org.glassfish.grizzly.websockets.DataFrame toDataFrame(byte[],boolean)>(v, v);
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: byte[] frame(org.glassfish.grizzly.websockets.DataFrame)>(v);
return v;
}
protected void sendRaw(byte[])
{
byte[] v;
org.glassfish.grizzly.Transport v;
org.glassfish.grizzly.websockets.ProtocolHandler v;
org.glassfish.grizzly.memory.MemoryManager v;
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.Connection v;
org.glassfish.grizzly.Buffer v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: byte[];
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.ProtocolHandler protocolHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.websockets.ProtocolHandler: org.glassfish.grizzly.Connection getConnection()>();
v = interfaceinvoke v.<org.glassfish.grizzly.Connection: org.glassfish.grizzly.Transport getTransport()>();
v = interfaceinvoke v.<org.glassfish.grizzly.Transport: org.glassfish.grizzly.memory.MemoryManager getMemoryManager()>();
v = staticinvoke <org.glassfish.grizzly.memory.Buffers: org.glassfish.grizzly.Buffer wrap(org.glassfish.grizzly.memory.MemoryManager,byte[])>(v, v);
interfaceinvoke v.<org.glassfish.grizzly.Buffer: void allowBufferDispose(boolean)>(0);
interfaceinvoke v.<org.glassfish.grizzly.Connection: org.glassfish.grizzly.GrizzlyFuture write(java.lang.Object)>(v);
return;
}
protected org.glassfish.grizzly.websockets.Broadcaster getBroadcaster()
{
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.websockets.Broadcaster v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v = v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.Broadcaster broadcaster>;
return v;
}
protected void setBroadcaster(org.glassfish.grizzly.websockets.Broadcaster)
{
org.glassfish.grizzly.websockets.SimpleWebSocket v;
org.glassfish.grizzly.websockets.Broadcaster v;
v := @this: org.glassfish.grizzly.websockets.SimpleWebSocket;
v := @parameter: org.glassfish.grizzly.websockets.Broadcaster;
v.<org.glassfish.grizzly.websockets.SimpleWebSocket: org.glassfish.grizzly.websockets.Broadcaster broadcaster> = v;
return;
}
static void <clinit>()
{
java.util.logging.Logger v;
v = staticinvoke <org.glassfish.grizzly.Grizzly: java.util.logging.Logger logger(java.lang.Class)>(class "Lorg/glassfish/grizzly/websockets/DefaultWebSocket;");
<org.glassfish.grizzly.websockets.SimpleWebSocket: java.util.logging.Logger LOGGER> = v;
return;
}
}