* The adapter, used to call the connector.
*/
protected Adapter adapter;
+ @Override
public void setAdapter(Adapter adapter) { this.adapter = adapter; }
+ @Override
public Adapter getAdapter() { return adapter; }
/**
* Pass config info
*/
+ @Override
public void setAttribute(String name, Object value) {
if (getLog().isTraceEnabled()) {
getLog().trace(sm.getString("http11protocol.setattribute", name, value));
attributes.put(name, value);
}
+ @Override
public Object getAttribute(String key) {
return attributes.get(key);
}
+ @Override
public Iterator<String> getAttributeNames() {
return attributes.keySet().iterator();
}
}
+ @Override
public void pause() throws Exception {
try {
endpoint.pause();
getLog().info(sm.getString("http11protocol.pause", getName()));
}
+ @Override
public void resume() throws Exception {
try {
endpoint.resume();
getLog().info(sm.getString("http11protocol.resume", getName()));
}
+ @Override
public void destroy() throws Exception {
if(getLog().isInfoEnabled())
getLog().info(sm.getString("http11protocol.stop", getName()));
public void setServer( String server ) { this.server = server; }
public String getServer() { return server; }
+ @Override
public Executor getExecutor() { return endpoint.getExecutor(); }
public void setExecutor(Executor executor) { endpoint.setExecutor(executor); }
return endpoint.getAllowUnsafeLegacyRenegotiation();
}
+ @Override
public abstract void init() throws Exception;
- public abstract void start() throws Exception;
// -------------------- JMX related methods --------------------
- // *
protected String domain;
protected ObjectName oname;
protected MBeanServer mserver;
return domain;
}
+ @Override
public ObjectName preRegister(MBeanServer server,
ObjectName name) throws Exception {
oname=name;
return name;
}
+ @Override
public void postRegister(Boolean registrationDone) {
+ // NOOP
}
+ @Override
public void preDeregister() throws Exception {
+ // NOOP
}
+ @Override
public void postDeregister() {
+ // NOOP
}
/** Pass config info
*/
+ @Override
public void setAttribute( String name, Object value ) {
if( log.isTraceEnabled())
log.trace(sm.getString("http11protocol.setattribute", name, value));
attributes.put(name, value);
}
+ @Override
public Object getAttribute( String key ) {
if( log.isTraceEnabled())
log.trace(sm.getString("http11protocol.getattribute", key));
return attributes.get(key);
}
+ @Override
public Iterator<String> getAttributeNames() {
return attributes.keySet().iterator();
}
* The adapter, used to call the connector.
*/
protected Adapter adapter;
+ @Override
public void setAdapter(Adapter adapter) { this.adapter = adapter; }
+ @Override
public Adapter getAdapter() { return adapter; }
/** Start the protocol
*/
+ @Override
public void init() throws Exception {
endpoint.setName(getName());
endpoint.setHandler(cHandler);
ObjectName tpOname;
ObjectName rgOname;
+ @Override
public void start() throws Exception {
if( this.domain != null ) {
try {
log.info(sm.getString("http11protocol.start", getName()));
}
+ @Override
public void pause() throws Exception {
try {
endpoint.pause();
log.info(sm.getString("http11protocol.pause", getName()));
}
+ @Override
public void resume() throws Exception {
try {
endpoint.resume();
log.info(sm.getString("http11protocol.resume", getName()));
}
+ @Override
public void destroy() throws Exception {
if(log.isInfoEnabled())
log.info(sm.getString("http11protocol.stop", getName()));
public int getProcessorCache() { return this.processorCache; }
public void setProcessorCache(int processorCache) { this.processorCache = processorCache; }
+ @Override
public Executor getExecutor() { return endpoint.getExecutor(); }
public void setExecutor(Executor executor) { endpoint.setExecutor(executor); }
this.proto = proto;
}
+ @Override
public SocketState event(long socket, SocketStatus status) {
Http11AprProcessor result = connections.get(Long.valueOf(socket));
return state;
}
+ @Override
public SocketState process(long socket) {
Http11AprProcessor processor = recycledProcessors.poll();
try {
return SocketState.CLOSED;
}
+ @Override
public SocketState asyncDispatch(long socket, SocketStatus status) {
Http11AprProcessor result = connections.get(Long.valueOf(socket));
return domain;
}
+ @Override
public ObjectName preRegister(MBeanServer server,
ObjectName name) throws Exception {
oname=name;
return name;
}
+ @Override
public void postRegister(Boolean registrationDone) {
}
+ @Override
public void preDeregister() throws Exception {
}
+ @Override
public void postDeregister() {
}
}
this.proto = proto;
}
+ @Override
public void releaseCaches() {
recycledProcessors.clear();
}
+ @Override
public void release(SocketChannel socket) {
if (log.isDebugEnabled())
log.debug("Iterating through our connections to release a socket channel:"+socket);
log.debug("Done iterating through our connections to release a socket channel:"+socket +" released:"+released);
}
+ @Override
public void release(NioChannel socket) {
Http11NioProcessor result = connections.remove(socket);
if ( result != null ) {
}
}
+ @Override
public SocketState event(NioChannel socket, SocketStatus status) {
Http11NioProcessor result = connections.get(socket);
NioEndpoint.KeyAttachment att = (NioEndpoint.KeyAttachment)socket.getAttachment(false);
return state;
}
+ @Override
public SocketState process(NioChannel socket) {
Http11NioProcessor processor = null;
try {
this.proto = proto;
}
+ @Override
public SocketState process(SocketWrapper<Socket> socket) {
return process(socket,SocketStatus.OPEN);
}
+ @Override
public SocketState process(SocketWrapper<Socket> socket, SocketStatus status) {
Http11Processor processor = connections.remove(socket);
boolean recycle = true;