(f *http2.RSTStreamFrame)
| 826 | } |
| 827 | |
| 828 | func (t *http2Server) handleRSTStream(f *http2.RSTStreamFrame) { |
| 829 | // If the stream is not deleted from the transport's active streams map, then do a regular close stream. |
| 830 | if s, ok := t.getStream(f); ok { |
| 831 | t.closeStream(s, false, 0, false) |
| 832 | return |
| 833 | } |
| 834 | // If the stream is already deleted from the active streams map, then put a cleanupStream item into controlbuf to delete the stream from loopy writer's established streams map. |
| 835 | t.controlBuf.put(&cleanupStream{ |
| 836 | streamID: f.Header().StreamID, |
| 837 | rst: false, |
| 838 | rstCode: 0, |
| 839 | onWrite: func() {}, |
| 840 | }) |
| 841 | } |
| 842 | |
| 843 | func (t *http2Server) handleSettings(f *http2.SettingsFrame) { |
| 844 | if f.IsAck() { |
no test coverage detected