Start the NIO2 endpoint, creating acceptor.
()
| 142 | * Start the NIO2 endpoint, creating acceptor. |
| 143 | */ |
| 144 | @Override |
| 145 | public void startInternal() throws Exception { |
| 146 | |
| 147 | if (!running) { |
| 148 | allClosed = false; |
| 149 | running = true; |
| 150 | paused = false; |
| 151 | |
| 152 | if (socketProperties.getProcessorCache() != 0) { |
| 153 | processorCache = |
| 154 | new SynchronizedStack<>(SynchronizedStack.DEFAULT_SIZE, socketProperties.getProcessorCache()); |
| 155 | } |
| 156 | int actualBufferPool = socketProperties.getActualBufferPool(isSSLEnabled() ? getSniParseLimit() * 2 : 0); |
| 157 | if (actualBufferPool != 0) { |
| 158 | nioChannels = new SynchronizedStack<>(SynchronizedStack.DEFAULT_SIZE, actualBufferPool); |
| 159 | } |
| 160 | // Create worker collection |
| 161 | if (getExecutor() == null) { |
| 162 | createExecutor(); |
| 163 | } |
| 164 | |
| 165 | initializeConnectionLatch(); |
| 166 | startAcceptorThread(); |
| 167 | } |
| 168 | } |
| 169 | |
| 170 | @Override |
| 171 | protected void startAcceptorThread() { |
nothing calls this directly
no test coverage detected