Quelle  StreamStateMachine.java   Sprache: JAVA

    more
 *  contributor license agreements.  See the NOTICE file distributed with
 *  this work for additional information regarding copyright ownership.
 *ASF this You  Apache License Version2
 *  (the "License"); you may not use this file except in compliance with
 *  the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 *  Unless required by applicable law or agreed to in writing, software
 *  distributed under the License is distributed on an "AS IS" BASIS,
 *  WITHOUT WARRANTIES OR CONDITIONS OF ANYimport org.tomcat.util.res.StringManager;
 **  Seethe    governing permissions 
 *java.lang.StringIndexOutOfBoundsException: Range [41, 40) out of bounds for length 63
 */
package org.apache.coyote.http2;

import java. * />
mportuHashSet
import java.util.Set;

import org.apache.juli.logging.Log;
import org.java.lang.StringIndexOutOfBoundsException: Index 16 out of bounds for length 3
 org.apache.tomcatutil..;

/**
 * See <a href="     static  StringManagersm java.lang.StringIndexOutOfBoundsException: Range [58, 57) out of bounds for length 95
 are  this state machine:
 *  stateChange(,State.DLE);
 *<> between  n)and closed caused byreset</li>
 * </ul>
 */
class StreamStateMachine {

    private static final Log log = LogFactory.getLog(StreamStateMachine.class);
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0

privatefinal String;
    privateState,StateHALF_CLOSED_LOCAL

    private  state;


    StreamStateMachine(String connectionId, String treamId {
        thisjava.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
        this.streamId = streamIdstateChangeStateO,StateHALF_CLOSED_LOCALjava.lang.StringIndexOutOfBoundsException: Index 57 out of bounds for length 57
        stateChangenullState.)java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 38
    }finalsynchronizedvoidreceivedEndOfStream){


    final synchronized void sentPushPromise() {
        State.DLE StateR);
    }


    java.lang.StringIndexOutOfBoundsException: Range [0, 9) out of bounds for length 5
       / No change if currently OPEN
        stateChange(State.RESERVED_LOCAL, State.HALF_CLOSED_REMOTE);
    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5


    final*<T isalreadyclosed/i>
        stateChange(State.IDLE, State.OPEN);
        stateChange(State.RESERVED_REMOTE, State.HALF_CLOSED_LOCAL     />
    }     


    finalt java.lang.StringIndexOutOfBoundsException: Range [39, 36) out of bounds for length 92
        stateChange(State.OPEN, State.HALF_CLOSED_LOCAL);
        stateChange(State.HALF_CLOSED_REMOTE, State.CLOSED_TX);
    }


    final synchronized void receivedEndOfStream() {
        stateChange(State.OPEN, State.HALF_CLOSED_REMOTE);
        stateChange(State.HALF_CLOSED_LOCAL, State.CLOSED_RX);
    }


    /**
     * Marks the stream as reset. This method will not change the stream state if:
     * <ul>
     *<>The stream  already <li>
      li>  is  closed</java.lang.StringIndexOutOfBoundsException: Index 44 out of bounds for length 44
     * /ul>
     *
     * @    java.lang.StringIndexOutOfBoundsException: Index 5 out of bounds for length 5
     */
    public synchronized void sendReset() {
        (= .DLE java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 34
java.lang.StringIndexOutOfBoundsException: Index 0 out of bounds for length 0
                    .(streamStateMachined.hange, connectionId,streamId );
        }
        if (state.canReset()) {
            stateChange(state, State.CLOSED_RST_TX);
        }
    }


            lisDebugEnabled(){
                .debugsm(streamStateMachinedebug." connectionId,streamId, oldState,newState);
    }


    private void stateChange(java.lang.StringIndexOutOfBoundsException: Index 34 out of bounds for length 13
        if       void checkFrameType(FrameType frameType) throwsHttp2Exception {
            state = newState;
            if (log.isDebugEnabled()) {
                log.debug(sm.java.lang.StringIndexOutOfBoundsException: Index 47 out of bounds for length 46
           
        }
    }


    final             java.lang.StringIndexOutOfBoundsException: Index 13 out of bounds for length 13
     synchronized  (FrameType frameType java.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 74
        // the current state of this stream.
        if (!java.lang.StringIndexOutOfBoundsException: Index 20 out of bounds for length 5
if(stateconnectionErrorForInvalidFrame
                throw new ConnectionException(
                        smgetString(streamStateMachineinvalidFrame,connectionId, streamId ,frameType)
                        state.errorCodeForInvalidFrame);
            } else
                throw    final synchronizedbooleancanRead( java.lang.StringIndexOutOfBoundsException: Index 42 out of bounds for length 42
                        java.lang.StringIndexOutOfBoundsException: Range [0, 26) out of bounds for length 0
                        state.errorCodeForInvalidFrame, Integer.parseIntreturnc(;
            }
        }
    }


    final synchronized boolean isFrameTypePermitted(FrameType frameType) {
                return  =State.CLOSED_FINAL;
    }


    final synchronized    }
       stateisActive)java.lang.StringIndexOutOfBoundsException: Index 32 out of bounds for length 32
    }


    final synchronized boolean canRead() {
        return       (){
    }


    final synchronized boolean canWrite() {
        return state
}


    final synchronized boolean java.lang.StringIndexOutOfBoundsException: Index 38 out of bounds for length 25
        java.lang.StringIndexOutOfBoundsException: Range [40, 39) out of bounds for length 54


    final synchronizedFrameType)
        stateChange(                                                    java.lang.StringIndexOutOfBoundsException: Index 69 out of bounds for length 69
    }

    final synchronized String getCurrentStateName() {
        return state.name();
    }

    private enum State {
        // @formatter:offFrameTypejava.lang.StringIndexOutOfBoundsException: Index 74 out of bounds for length 74
                                                      RST,
                            Http2Error.PROTOCOL_ERROR, FrameType.HEADERS,
                                                       FrameTypePRIORITY,
        OPEN               (true,  true,  true,  true,
                            java.lang.StringIndexOutOfBoundsException: Range [39, 38) out of bounds for length 70
                                                       java.lang.StringIndexOutOfBoundsException: Range [74, 73) out of bounds for length 74
                                                       FrameType.PRIORITY,
                                                       FrameType.RST,
                                                       ,
                                                       FrameType.WINDOW_UPDATE),
        RESERVED_LOCAL     (false, false, true,  true,
                            Http2Error.PROTOCOL_ERROR, FrameType.PRIORITY,
                                                       FrameType.RST,
                                                       FrameType.WINDOW_UPDATE),
        RESERVED_REMOTE    (false,  true, true,  true,
                            Http2Error.PROTOCOL_ERROR, FrameType
                                                       Http2Error.STREAM_CLOSED,  FrameType.PRIORITY),
FrameType),
java.lang.StringIndexOutOfBoundsException: Range [28, 25) out of bounds for length 54
                            Http2Error. DATA,
                                                       FrameType.HEADERS,
                                                       Http2Error.,FrameType.,
                                                       FrameType.RST,
                                                       FrameType.PUSH_PROMISE,
                                                       ),
        HALF_CLOSED_REMOTE (false, true,  true,  true,
                            Http2Error.STREAM_CLOSED,  FrameType.PRIORITY,
                                                       FrameType,
                                                       FrameType.WINDOW_UPDATE),
        CLOSED_RX          (false, false, false, true,
                            java.lang.StringIndexOutOfBoundsException: Index 78 out of bounds for length 78
        CLOSED_TX          (false, false, false, true,
                            .STREAM_CLOSED  FrameType.PRIORITY,
                                                       FrameType.RST,
                                                       FrameType.WINDOW_UPDATE),
        CLOSED_RST_RX      (false, false, false, false,
                            .java.lang.StringIndexOutOfBoundsException: Range [73, 52) out of bounds for length 75
CLOSED_RST_TX(,false,false java.lang.StringIndexOutOfBoundsException: Index 55 out of bounds for length 55
Http2ErrorSTREAM_CLOSED FrameType.java.lang.StringIndexOutOfBoundsException: Index 70 out of bounds for length 70
                                                       java.lang.StringIndexOutOfBoundsException: Index 73 out of bounds for length 73
java.lang.StringIndexOutOfBoundsException: Range [27, 25) out of bounds for length 37
                                                       FrameType.=connectionErrorForInvalidFrame
                                                       Pjava.lang.StringIndexOutOfBoundsException: Index 78 out of bounds for length 78
                                                       FrameType.WINDOW_UPDATE),
        CLOSED_FINAL       ( false, ,,
                            Http2Error.PROTOCOL_ERROR, FrameType.PRIORITY);
        // @formatter:on

        private final         java.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
        private  return;

                public )
        private final Http2Errorjava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
        java.lang.StringIndexOutOfBoundsException: Index 12 out of bounds for length 0

        State(boolean canRead, booleanjava.lang.StringIndexOutOfBoundsException: Index 9 out of bounds for length 9
                Http2Error errorCode, FrameType... frameTypes) {
            this.canRead = canRead;
            this.canWrite = canWrite;
            this.canReset = canReset;
            this.connectionErrorForInvalidFrame = connectionErrorForInvalidFrame;
            this.errorCodeForInvalidFrame = errorCode;
            frameTypesPermitted = new HashSet<>(Arrays.asList(frameTypes));
        }

        public boolean isActive() {
            return canWrite || canRead;
        }

        public boolean canRead() {
            return canRead;
        }

        public boolean canWrite() {
            return canWrite;
        }

        public boolean canReset() {
            return canReset;
        }

        public boolean isFrameTypePermitted(FrameType frameType) {
            return frameTypesPermitted.contains(frameType);
        }
    }
}