Package org.apache.tomcat.util.net.AbstractEndpoint.Handler

Examples of org.apache.tomcat.util.net.AbstractEndpoint.Handler.SocketState

147
148
149
150
151
152
153
154
155
156
157
        }
    }

    @Override
    public SocketState asyncDispatch(SocketStatus status) {
        SocketState state = super.asyncDispatch(status);
        if (state == SocketState.OPEN && ((InternalNio2InputBuffer) inputBuffer).isPending()) {
            // Following async processing, a read is still pending, so
            // keep the processor associated
            return SocketState.LONG;
        } else {
View Full Code Here
1556
1557
1558
1559
1560
1561
1562
1563
1564
1565
1566
                    if (log.isDebugEnabled()) log.debug("Error during SSL handshake",x);
                } catch (CancelledKeyException ckx) {
                    handshake = -1;
                }
                if (handshake == 0) {
                    SocketState state = SocketState.OPEN;
                    // Process the request from this socket
                    if (status == null) {
                        state = handler.process(ka, SocketStatus.OPEN_READ);
                    } else {
                        state = handler.process(ka, status);
View Full Code Here
247
248
249
250
251
252
253
254
255
256
257
              if (!socket.processing.compareAndSet(false, true)) {
                  log.error("Unable to process socket. Invalid state.");
                  return;
              }
             
              SocketState state = SocketState.OPEN;
              // Process the request from this socket
              if ( (!socket.isInitialized()) && (!setSocketOptions(socket.getSocket())) ) {
                  state = SocketState.CLOSED;
              }
              socket.setInitialized(true);
View Full Code Here
1678
1679
1680
1681
1682
1683
1684
1685
1686
1687
1688
                        if ( log.isDebugEnabled() ) log.debug("Error during SSL handshake",x);
                    }catch ( CancelledKeyException ckx ) {
                        handshake = -1;
                    }
                    if ( handshake == 0 ) {
                        SocketState state = SocketState.OPEN;
                        // Process the request from this socket
                        if (status == null) {
                            state = handler.process(
                                    (KeyAttachment) key.attachment(),
                                    SocketStatus.OPEN);
View Full Code Here
1845
1846
1847
1848
1849
1850
1851
1852
1853
1854
1855
        @Override
        public void run() {
            synchronized (socket) {
                // Process the request from this socket
                SocketState state = SocketState.OPEN;
                if (status == null) {
                    state = handler.process(socket,SocketStatus.OPEN);
                } else {
                    state = handler.process(socket, status);
                }
View Full Code Here
2243
2244
2245
2246
2247
2248
2249
2250
2251
2252
2253
            // Process the request from this socket
            if (socket.getSocket() == null) {
                // Closed in another thread
                return;
            }
            SocketState state = handler.process(socket, status);
            if (state == Handler.SocketState.CLOSED) {
                // Close socket and pool
                destroySocket(socket.getSocket().longValue());
                socket.socket = null;
            } else if (state == Handler.SocketState.LONG) {
View Full Code Here
1582
1583
1584
1585
1586
1587
1588
1589
1590
1591
1592
                    if (log.isDebugEnabled()) log.debug("Error during SSL handshake",x);
                } catch (CancelledKeyException ckx) {
                    handshake = -1;
                }
                if (handshake == 0) {
                    SocketState state = SocketState.OPEN;
                    // Process the request from this socket
                    if (status == null) {
                        state = handler.process(ka, SocketStatus.OPEN_READ);
                    } else {
                        state = handler.process(ka, status);
View Full Code Here
301
302
303
304
305
306
307
308
309
310
311
        @Override
        public void run() {
            boolean launch = false;
            synchronized (socket) {
                try {
                    SocketState state = SocketState.OPEN;
                    handler.beforeHandshake(socket);
                    try {
                        // SSL handshake
                        serverSocketFactory.handshake(socket.getSocket());
                    } catch (Throwable t) {
View Full Code Here
289
290
291
292
293
294
295
296
297
298
299
        @Override
        public void run() {
            boolean launch = false;
            synchronized (socket) {
                try {
                    SocketState state = SocketState.OPEN;

                    try {
                        // SSL handshake
                        serverSocketFactory.handshake(socket.getSocket());
                    } catch (Throwable t) {
View Full Code Here
1200
1201
1202
1203
1204
1205
1206
1207
1208
1209
1210
                } catch (IOException x) {
                    handshake = -1;
                    if (log.isDebugEnabled()) log.debug("Error during SSL handshake",x);
                }
                if (handshake == 0) {
                    SocketState state = SocketState.OPEN;
                    // Process the request from this socket
                    if (status == null) {
                        state = handler.process(socket, SocketStatus.OPEN_READ);
                    } else {
                        state = handler.process(socket, status);
View Full Code Here
TOP

Related Classes of org.apache.tomcat.util.net.AbstractEndpoint.Handler.SocketState

  • org.apache.coyote.ajp.AjpProtocol$AjpConnectionHandler
  • org.apache.coyote.http11.Http11Nio2Processor
  • org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler
  • org.apache.tomcat.util.net.AprEndpoint$SocketProcessor
  • org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor
  • org.apache.tomcat.util.net.Nio2Endpoint$SocketProcessor
  • org.apache.tomcat.util.net.NioEndpoint$SocketProcessor
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.