public class org.apache.hc.core.http.impl.bootstrap.AsyncServer extends org.apache.hc.core.http.impl.bootstrap.AbstractConnectionInitiatorBase implements org.apache.hc.core.reactor.IOReactorService, org.apache.hc.core.reactor.ConnectionAcceptor
{
private final org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor;
public void <init>(org.apache.hc.core.reactor.IOEventHandlerFactory, org.apache.hc.core.reactor.IOReactorConfig, org.apache.hc.core.function.Decorator, org.apache.hc.core.function.Callback, org.apache.hc.core.reactor.IOSessionListener, org.apache.hc.core.function.Callback)
{
org.apache.hc.core.reactor.DefaultListeningIOReactor v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
org.apache.hc.core.concurrent.DefaultThreadFactory v, v;
org.apache.hc.core.reactor.IOReactorConfig v;
org.apache.hc.core.function.Decorator v;
org.apache.hc.core.function.Callback v, v;
org.apache.hc.core.reactor.IOSessionListener v;
org.apache.hc.core.reactor.IOEventHandlerFactory v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v := @parameter: org.apache.hc.core.reactor.IOEventHandlerFactory;
v := @parameter: org.apache.hc.core.reactor.IOReactorConfig;
v := @parameter: org.apache.hc.core.function.Decorator;
v := @parameter: org.apache.hc.core.function.Callback;
v := @parameter: org.apache.hc.core.reactor.IOSessionListener;
v := @parameter: org.apache.hc.core.function.Callback;
specialinvoke v.<org.apache.hc.core.http.impl.bootstrap.AbstractConnectionInitiatorBase: void <init>()>();
v = new org.apache.hc.core.reactor.DefaultListeningIOReactor;
v = new org.apache.hc.core.concurrent.DefaultThreadFactory;
specialinvoke v.<org.apache.hc.core.concurrent.DefaultThreadFactory: void <init>(java.lang.String,boolean)>("server-dispatch", 1);
v = new org.apache.hc.core.concurrent.DefaultThreadFactory;
specialinvoke v.<org.apache.hc.core.concurrent.DefaultThreadFactory: void <init>(java.lang.String,boolean)>("server-listener", 1);
specialinvoke v.<org.apache.hc.core.reactor.DefaultListeningIOReactor: void <init>(org.apache.hc.core.reactor.IOEventHandlerFactory,org.apache.hc.core.reactor.IOReactorConfig,java.util.concurrent.ThreadFactory,java.util.concurrent.ThreadFactory,org.apache.hc.core.function.Decorator,org.apache.hc.core.function.Callback,org.apache.hc.core.reactor.IOSessionListener,org.apache.hc.core.function.Callback)>(v, v, v, v, v, v, v, v);
v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor> = v;
return;
}
public void start()
{
org.apache.hc.core.reactor.DefaultListeningIOReactor v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor>;
virtualinvoke v.<org.apache.hc.core.reactor.DefaultListeningIOReactor: void start()>();
return;
}
org.apache.hc.core.reactor.ConnectionInitiator getIOReactor()
{
org.apache.hc.core.reactor.DefaultListeningIOReactor v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor>;
return v;
}
public java.util.concurrent.Future listen(java.net.SocketAddress, java.lang.Object, org.apache.hc.core.concurrent.FutureCallback)
{
org.apache.hc.core.reactor.DefaultListeningIOReactor v;
java.util.concurrent.Future v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
java.net.SocketAddress v;
org.apache.hc.core.concurrent.FutureCallback v;
java.lang.Object v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v := @parameter: java.net.SocketAddress;
v := @parameter: java.lang.Object;
v := @parameter: org.apache.hc.core.concurrent.FutureCallback;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor>;
v = virtualinvoke v.<org.apache.hc.core.reactor.DefaultListeningIOReactor: java.util.concurrent.Future listen(java.net.SocketAddress,java.lang.Object,org.apache.hc.core.concurrent.FutureCallback)>(v, v, v);
return v;
}
public java.util.concurrent.Future listen(java.net.SocketAddress, org.apache.hc.core.concurrent.FutureCallback)
{
java.util.concurrent.Future v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
java.net.SocketAddress v;
org.apache.hc.core.concurrent.FutureCallback v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v := @parameter: java.net.SocketAddress;
v := @parameter: org.apache.hc.core.concurrent.FutureCallback;
v = virtualinvoke v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: java.util.concurrent.Future listen(java.net.SocketAddress,java.lang.Object,org.apache.hc.core.concurrent.FutureCallback)>(v, null, v);
return v;
}
public java.util.concurrent.Future listen(java.net.SocketAddress)
{
org.apache.hc.core.reactor.DefaultListeningIOReactor v;
java.util.concurrent.Future v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
java.net.SocketAddress v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v := @parameter: java.net.SocketAddress;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor>;
v = virtualinvoke v.<org.apache.hc.core.reactor.DefaultListeningIOReactor: java.util.concurrent.Future listen(java.net.SocketAddress,org.apache.hc.core.concurrent.FutureCallback)>(v, null);
return v;
}
public void pause() throws java.io.IOException
{
org.apache.hc.core.reactor.DefaultListeningIOReactor v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor>;
virtualinvoke v.<org.apache.hc.core.reactor.DefaultListeningIOReactor: void pause()>();
return;
}
public void resume() throws java.io.IOException
{
org.apache.hc.core.reactor.DefaultListeningIOReactor v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor>;
virtualinvoke v.<org.apache.hc.core.reactor.DefaultListeningIOReactor: void resume()>();
return;
}
public java.util.Set getEndpoints()
{
org.apache.hc.core.reactor.DefaultListeningIOReactor v;
java.util.Set v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor>;
v = virtualinvoke v.<org.apache.hc.core.reactor.DefaultListeningIOReactor: java.util.Set getEndpoints()>();
return v;
}
public org.apache.hc.core.reactor.IOReactorStatus getStatus()
{
org.apache.hc.core.reactor.DefaultListeningIOReactor v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
org.apache.hc.core.reactor.IOReactorStatus v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor>;
v = virtualinvoke v.<org.apache.hc.core.reactor.DefaultListeningIOReactor: org.apache.hc.core.reactor.IOReactorStatus getStatus()>();
return v;
}
public void initiateShutdown()
{
org.apache.hc.core.reactor.DefaultListeningIOReactor v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor>;
virtualinvoke v.<org.apache.hc.core.reactor.DefaultListeningIOReactor: void initiateShutdown()>();
return;
}
public void awaitShutdown(org.apache.hc.core.util.TimeValue) throws java.lang.InterruptedException
{
org.apache.hc.core.reactor.DefaultListeningIOReactor v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
org.apache.hc.core.util.TimeValue v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v := @parameter: org.apache.hc.core.util.TimeValue;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor>;
virtualinvoke v.<org.apache.hc.core.reactor.DefaultListeningIOReactor: void awaitShutdown(org.apache.hc.core.util.TimeValue)>(v);
return;
}
public void close(org.apache.hc.core.io.CloseMode)
{
org.apache.hc.core.reactor.DefaultListeningIOReactor v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
org.apache.hc.core.io.CloseMode v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v := @parameter: org.apache.hc.core.io.CloseMode;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor>;
virtualinvoke v.<org.apache.hc.core.reactor.DefaultListeningIOReactor: void close(org.apache.hc.core.io.CloseMode)>(v);
return;
}
public void close() throws java.io.IOException
{
org.apache.hc.core.reactor.DefaultListeningIOReactor v;
org.apache.hc.core.http.impl.bootstrap.AsyncServer v;
v := @this: org.apache.hc.core.http.impl.bootstrap.AsyncServer;
v = v.<org.apache.hc.core.http.impl.bootstrap.AsyncServer: org.apache.hc.core.reactor.DefaultListeningIOReactor ioReactor>;
virtualinvoke v.<org.apache.hc.core.reactor.DefaultListeningIOReactor: void close()>();
return;
}
}