01: //========================================================================
02: // Parts Copyright 2006 Mort Bay Consulting Pty. Ltd.
03: //------------------------------------------------------------------------
04: // Licensed under the Apache License, Version 2.0 (the "License");
05: // you may not use this file except in compliance with the License.
06: // You may obtain a copy of the License at
07: // http://www.apache.org/licenses/LICENSE-2.0
08: // Unless required by applicable law or agreed to in writing, software
09: // distributed under the License is distributed on an "AS IS" BASIS,
10: // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
11: // See the License for the specific language governing permissions and
12: // limitations under the License.
13: //========================================================================
14: package org.mortbay.jetty.grizzly;
15:
16: import com.sun.enterprise.web.connector.grizzly.SelectorThreadConfig;
17: import java.io.IOException;
18: import java.nio.channels.SelectionKey;
19:
20: /**
21: * Simple connector that disable Grizzly's SelectorThread ServerSocketChannel.
22: * This class must only be used when Jetty is embedded in GlassFish.
23: *
24: * @author Jeanfrancois Arcand
25: */
26: public class GrizzlyConnectorAdapter extends GrizzlyConnector {
27:
28: public GrizzlyConnectorAdapter() {
29: _selectorThread = new JettySelectorThread() {
30: public void initEndpoint() throws IOException,
31: InstantiationException {
32: SelectorThreadConfig.configure(this );
33: initFileCacheFactory();
34: initAlgorithm();
35: initPipeline();
36: initMonitoringLevel();
37:
38: setName("SelectorThread-" + port);
39: initProcessorTask(maxProcessorWorkerThreads);
40: initReadTask(minReadQueueLength);
41: initialized = true;
42: }
43:
44: /**
45: * Don't start the selector.
46: */
47: public void startEndpoint() throws IOException,
48: InstantiationException {
49: running = true;
50: setKaTimeout(keepAliveTimeoutInSeconds * 1000);
51: rampUpProcessorTask();
52: registerComponents();
53: startPipelines();
54: }
55:
56: public void registerKey(SelectionKey key) {
57: ;
58: }
59:
60: };
61: }
62:
63: public JettySelectorThread getSelectorThread() {
64: return _selectorThread;
65: }
66: }
|