Class SpdySession


  • final class SpdySession
    extends java.lang.Object
    • Field Detail

      • activeLocalStreams

        private final java.util.concurrent.atomic.AtomicInteger activeLocalStreams
      • activeRemoteStreams

        private final java.util.concurrent.atomic.AtomicInteger activeRemoteStreams
      • sendWindowSize

        private final java.util.concurrent.atomic.AtomicInteger sendWindowSize
      • receiveWindowSize

        private final java.util.concurrent.atomic.AtomicInteger receiveWindowSize
    • Constructor Detail

      • SpdySession

        public SpdySession​(int sendWindowSize,
                           int receiveWindowSize)
    • Method Detail

      • numActiveStreams

        int numActiveStreams​(boolean remote)
      • noActiveStreams

        boolean noActiveStreams()
      • isActiveStream

        boolean isActiveStream​(int streamId)
      • acceptStream

        void acceptStream​(int streamId,
                          byte priority,
                          boolean remoteSideClosed,
                          boolean localSideClosed,
                          int sendWindowSize,
                          int receiveWindowSize,
                          boolean remote)
      • removeStream

        void removeStream​(int streamId,
                          boolean remote)
      • isRemoteSideClosed

        boolean isRemoteSideClosed​(int streamId)
      • closeRemoteSide

        void closeRemoteSide​(int streamId,
                             boolean remote)
      • isLocalSideClosed

        boolean isLocalSideClosed​(int streamId)
      • closeLocalSide

        void closeLocalSide​(int streamId,
                            boolean remote)
      • hasReceivedReply

        boolean hasReceivedReply​(int streamId)
      • receivedReply

        void receivedReply​(int streamId)
      • getSendWindowSize

        int getSendWindowSize​(int streamId)
      • updateSendWindowSize

        int updateSendWindowSize​(int streamId,
                                 int deltaWindowSize)
      • updateReceiveWindowSize

        int updateReceiveWindowSize​(int streamId,
                                    int deltaWindowSize)
      • getReceiveWindowSizeLowerBound

        int getReceiveWindowSizeLowerBound​(int streamId)
      • updateAllSendWindowSizes

        void updateAllSendWindowSizes​(int deltaWindowSize)
      • updateAllReceiveWindowSizes

        void updateAllReceiveWindowSizes​(int deltaWindowSize)
      • putPendingWrite

        boolean putPendingWrite​(int streamId,
                                MessageEvent evt)
      • getPendingWrite

        MessageEvent getPendingWrite​(int streamId)
      • removePendingWrite

        MessageEvent removePendingWrite​(int streamId)