Class OfficeFloorSocketWrapper


  • public class OfficeFloorSocketWrapper
    extends org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
    OfficeFloor SocketWrapperBase.
    Author:
    Daniel Sagenschneider
    • Nested Class Summary

      • Nested classes/interfaces inherited from class org.apache.tomcat.util.net.SocketWrapperBase

        org.apache.tomcat.util.net.SocketWrapperBase.BlockingMode, org.apache.tomcat.util.net.SocketWrapperBase.CompletionCheck, org.apache.tomcat.util.net.SocketWrapperBase.CompletionHandlerCall, org.apache.tomcat.util.net.SocketWrapperBase.CompletionState, org.apache.tomcat.util.net.SocketWrapperBase.OperationState<A extends java.lang.Object>, org.apache.tomcat.util.net.SocketWrapperBase.VectoredIOCompletionHandler<A extends java.lang.Object>
    • Field Summary

      • Fields inherited from class org.apache.tomcat.util.net.SocketWrapperBase

        bufferedWriteSize, closed, COMPLETE_READ, COMPLETE_READ_WITH_COMPLETION, COMPLETE_WRITE, COMPLETE_WRITE_WITH_COMPLETION, currentProcessor, localAddr, localName, localPort, nonBlockingWriteBuffer, previousIOException, READ_DATA, readOperation, readPending, remoteAddr, remoteHost, remotePort, sm, socketBufferHandler, writeOperation, writePending
    • Constructor Summary

      Constructors 
      Constructor Description
      OfficeFloorSocketWrapper​(org.apache.tomcat.util.net.AbstractEndpoint<java.lang.Void,​?> endpoint)
      Instantiate.
    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      org.apache.tomcat.util.net.SendfileDataBase createSendfileData​(java.lang.String filename, long pos, long length)  
      void doClientAuth​(org.apache.tomcat.util.net.SSLSupport sslSupport)  
      protected void doClose()  
      protected void doWrite​(boolean block, java.nio.ByteBuffer from)  
      org.apache.tomcat.util.net.SSLSupport getSslSupport​(java.lang.String clientCertProvider)  
      boolean isReadyForRead()  
      protected <A> org.apache.tomcat.util.net.SocketWrapperBase.OperationState<A> newOperationState​(boolean arg0, java.nio.ByteBuffer[] arg1, int arg2, int arg3, org.apache.tomcat.util.net.SocketWrapperBase.BlockingMode arg4, long arg5, java.util.concurrent.TimeUnit arg6, A arg7, org.apache.tomcat.util.net.SocketWrapperBase.CompletionCheck arg8, java.nio.channels.CompletionHandler<java.lang.Long,​? super A> arg9, java.util.concurrent.Semaphore arg10, org.apache.tomcat.util.net.SocketWrapperBase.VectoredIOCompletionHandler<A> arg11)  
      static java.lang.UnsupportedOperationException noSocket()
      Escalates that should not require direct Socket.
      protected void populateLocalAddr()  
      protected void populateLocalName()  
      protected void populateLocalPort()  
      protected void populateRemoteAddr()  
      protected void populateRemoteHost()  
      protected void populateRemotePort()  
      org.apache.tomcat.util.net.SendfileState processSendfile​(org.apache.tomcat.util.net.SendfileDataBase sendfileData)  
      int read​(boolean block, byte[] b, int off, int len)  
      int read​(boolean block, java.nio.ByteBuffer to)  
      void registerReadInterest()  
      void registerWriteInterest()  
      void setAppReadBufHandler​(org.apache.tomcat.util.net.ApplicationBufferHandler handler)  
      • Methods inherited from class org.apache.tomcat.util.net.SocketWrapperBase

        awaitReadComplete, awaitWriteComplete, buffersArrayHasRemaining, canWrite, checkError, close, decrementKeepAlive, doWrite, execute, flush, flushBlocking, flushNonBlocking, getCurrentProcessor, getEndpoint, getError, getLocalAddr, getLocalName, getLocalPort, getNegotiatedProtocol, getReadTimeout, getRemoteAddr, getRemoteHost, getRemotePort, getSocket, getSocketBufferHandler, getWriteTimeout, hasAsyncIO, hasDataToRead, hasDataToWrite, hasPerOperationTimeout, isClosed, isReadPending, isReadyForWrite, isSecure, isUpgraded, isWritePending, needSemaphores, populateReadBuffer, populateReadBuffer, processSocket, read, read, read, reset, setCurrentProcessor, setError, setKeepAliveLeft, setNegotiatedProtocol, setReadTimeout, setSecure, setUpgraded, setWriteTimeout, toString, transfer, transfer, unRead, vectoredOperation, write, write, write, write, write, writeBlocking, writeBlocking, writeNonBlocking, writeNonBlocking, writeNonBlockingInternal
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Constructor Detail

      • OfficeFloorSocketWrapper

        public OfficeFloorSocketWrapper​(org.apache.tomcat.util.net.AbstractEndpoint<java.lang.Void,​?> endpoint)
        Instantiate.
        Parameters:
        endpoint -
    • Method Detail

      • noSocket

        public static java.lang.UnsupportedOperationException noSocket()
        Escalates that should not require direct Socket.
        Returns:
        UnsupportedOperationException for failure.
      • populateRemoteHost

        protected void populateRemoteHost()
        Specified by:
        populateRemoteHost in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
      • populateRemoteAddr

        protected void populateRemoteAddr()
        Specified by:
        populateRemoteAddr in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
      • populateRemotePort

        protected void populateRemotePort()
        Specified by:
        populateRemotePort in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
      • populateLocalName

        protected void populateLocalName()
        Specified by:
        populateLocalName in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
      • populateLocalAddr

        protected void populateLocalAddr()
        Specified by:
        populateLocalAddr in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
      • populateLocalPort

        protected void populateLocalPort()
        Specified by:
        populateLocalPort in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
      • read

        public int read​(boolean block,
                        byte[] b,
                        int off,
                        int len)
                 throws java.io.IOException
        Specified by:
        read in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
        Throws:
        java.io.IOException
      • read

        public int read​(boolean block,
                        java.nio.ByteBuffer to)
                 throws java.io.IOException
        Specified by:
        read in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
        Throws:
        java.io.IOException
      • isReadyForRead

        public boolean isReadyForRead()
                               throws java.io.IOException
        Specified by:
        isReadyForRead in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
        Throws:
        java.io.IOException
      • setAppReadBufHandler

        public void setAppReadBufHandler​(org.apache.tomcat.util.net.ApplicationBufferHandler handler)
        Specified by:
        setAppReadBufHandler in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
      • doClose

        protected void doClose()
        Specified by:
        doClose in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
      • doWrite

        protected void doWrite​(boolean block,
                               java.nio.ByteBuffer from)
                        throws java.io.IOException
        Specified by:
        doWrite in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
        Throws:
        java.io.IOException
      • registerReadInterest

        public void registerReadInterest()
        Specified by:
        registerReadInterest in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
      • registerWriteInterest

        public void registerWriteInterest()
        Specified by:
        registerWriteInterest in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
      • createSendfileData

        public org.apache.tomcat.util.net.SendfileDataBase createSendfileData​(java.lang.String filename,
                                                                              long pos,
                                                                              long length)
        Specified by:
        createSendfileData in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
      • processSendfile

        public org.apache.tomcat.util.net.SendfileState processSendfile​(org.apache.tomcat.util.net.SendfileDataBase sendfileData)
        Specified by:
        processSendfile in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
      • doClientAuth

        public void doClientAuth​(org.apache.tomcat.util.net.SSLSupport sslSupport)
                          throws java.io.IOException
        Specified by:
        doClientAuth in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
        Throws:
        java.io.IOException
      • getSslSupport

        public org.apache.tomcat.util.net.SSLSupport getSslSupport​(java.lang.String clientCertProvider)
        Specified by:
        getSslSupport in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>
      • newOperationState

        protected <A> org.apache.tomcat.util.net.SocketWrapperBase.OperationState<A> newOperationState​(boolean arg0,
                                                                                                       java.nio.ByteBuffer[] arg1,
                                                                                                       int arg2,
                                                                                                       int arg3,
                                                                                                       org.apache.tomcat.util.net.SocketWrapperBase.BlockingMode arg4,
                                                                                                       long arg5,
                                                                                                       java.util.concurrent.TimeUnit arg6,
                                                                                                       A arg7,
                                                                                                       org.apache.tomcat.util.net.SocketWrapperBase.CompletionCheck arg8,
                                                                                                       java.nio.channels.CompletionHandler<java.lang.Long,​? super A> arg9,
                                                                                                       java.util.concurrent.Semaphore arg10,
                                                                                                       org.apache.tomcat.util.net.SocketWrapperBase.VectoredIOCompletionHandler<A> arg11)
        Specified by:
        newOperationState in class org.apache.tomcat.util.net.SocketWrapperBase<java.lang.Void>