24 references to State
Microsoft.AspNetCore.Server.Kestrel.Core (24)
Internal\Http2\Http2FrameWriter.cs (8)
223var observed = producer.UnobservedState; 224var currentState = producer.CurrentState; 227static bool HasStateFlag(Http2OutputProducer.State state, Http2OutputProducer.State flags) 231var flushHeaders = HasStateFlag(observed, Http2OutputProducer.State.FlushHeaders) && !HasStateFlag(currentState, Http2OutputProducer.State.FlushHeaders); 235var aborted = HasStateFlag(currentState, Http2OutputProducer.State.Aborted); 236var completed = HasStateFlag(currentState, Http2OutputProducer.State.Completed) && !hasMoreData;
Internal\Http2\Http2OutputProducer.cs (16)
51private State _unobservedState; 54private State _currentState; 99internal (int, long, State, State, long) SchedulingState => (Stream.StreamId, _unconsumedBytes, _unobservedState, _currentState, _streamWindow); 101public State UnobservedState 112public State CurrentState 136private void EnqueueStateUpdate(State state) 155internal (bool hasMoreData, bool reschedule, State currentState, bool waitingForWindowUpdates) ObserveDataAndState(long bytes, State state) 163return (_unconsumedBytes > 0, _unobservedState != State.None, _currentState, _waitingForWindowUpdates); 198_unobservedState = State.None; 199_currentState = State.None; 222EnqueueStateUpdate(State.Completed); 384EnqueueStateUpdate(State.FlushHeaders); 432EnqueueStateUpdate(State.Completed); 590EnqueueStateUpdate(State.Aborted);