type golang.org/x/net/http2.serverConn
71 uses
golang.org/x/net/http2 (current package)
server.go#L80: testHookGetServerConn func(*serverConn)
server.go#L82: testHookOnPanic func(sc *serverConn, panicVal interface{}) (rePanic bool)
server.go#L178: activeConns map[*serverConn]struct{}
server.go#L181: func (s *serverInternalState) registerConn(sc *serverConn) {
server.go#L190: func (s *serverInternalState) unregisterConn(sc *serverConn) {
server.go#L222: conf.state = &serverInternalState{activeConns: make(map[*serverConn]struct{})}
server.go#L368: sc := &serverConn{
server.go#L484: func (sc *serverConn) rejectConn(err ErrCode, debug string) {
server.go#L492: type serverConn struct {
server.go#L550: func (sc *serverConn) maxHeaderListSize() uint32 {
server.go#L562: func (sc *serverConn) curOpenStreams() uint32 {
server.go#L576: sc *serverConn
server.go#L598: func (sc *serverConn) Framer() *Framer { return sc.framer }
server.go#L599: func (sc *serverConn) CloseConn() error { return sc.conn.Close() }
server.go#L600: func (sc *serverConn) Flush() error { return sc.bw.Flush() }
server.go#L601: func (sc *serverConn) HeaderEncoder() (*hpack.Encoder, *bytes.Buffer) {
server.go#L605: func (sc *serverConn) state(streamID uint32) (streamState, *stream) {
server.go#L632: func (sc *serverConn) setConnState(state http.ConnState) {
server.go#L638: func (sc *serverConn) vlogf(format string, args ...interface{}) {
server.go#L644: func (sc *serverConn) logf(format string, args ...interface{}) {
server.go#L696: func (sc *serverConn) condlogf(err error, format string, args ...interface{}) {
server.go#L708: func (sc *serverConn) canonicalHeader(v string) string {
server.go#L741: func (sc *serverConn) readFrames() {
server.go#L773: func (sc *serverConn) writeFrameAsync(wr FrameWriteRequest) {
server.go#L778: func (sc *serverConn) closeAllStreamsOnConnClose() {
server.go#L785: func (sc *serverConn) stopShutdownTimer() {
server.go#L792: func (sc *serverConn) notePanic() {
server.go#L807: func (sc *serverConn) serve() {
server.go#L925: func (sc *serverConn) awaitGracefulShutdown(sharedCh <-chan struct{}, privateCh chan struct{}) {
server.go#L943: func (sc *serverConn) onSettingsTimer() { sc.sendServeMsg(settingsTimerMsg) }
server.go#L944: func (sc *serverConn) onIdleTimer() { sc.sendServeMsg(idleTimerMsg) }
server.go#L945: func (sc *serverConn) onShutdownTimer() { sc.sendServeMsg(shutdownTimerMsg) }
server.go#L947: func (sc *serverConn) sendServeMsg(msg interface{}) {
server.go#L960: func (sc *serverConn) readPreface() error {
server.go#L998: func (sc *serverConn) writeDataFromHandler(stream *stream, data []byte, endStream bool) error {
server.go#L1045: func (sc *serverConn) writeFrameFromHandler(wr FrameWriteRequest) error {
server.go#L1065: func (sc *serverConn) writeFrame(wr FrameWriteRequest) {
server.go#L1129: func (sc *serverConn) startFrameWrite(wr FrameWriteRequest) {
server.go#L1179: func (sc *serverConn) wroteFrame(res frameWriteResult) {
server.go#L1243: func (sc *serverConn) scheduleFrameWrite() {
server.go#L1291: func (sc *serverConn) startGracefulShutdown() {
server.go#L1314: func (sc *serverConn) startGracefulShutdownInternal() {
server.go#L1318: func (sc *serverConn) goAway(code ErrCode) {
server.go#L1329: func (sc *serverConn) shutDownIn(d time.Duration) {
server.go#L1334: func (sc *serverConn) resetStream(se StreamError) {
server.go#L1345: func (sc *serverConn) processFrameFromReader(res readFrameResult) bool {
server.go#L1397: func (sc *serverConn) processFrame(f Frame) error {
server.go#L1435: func (sc *serverConn) processPing(f *PingFrame) error {
server.go#L1457: func (sc *serverConn) processWindowUpdate(f *WindowUpdateFrame) error {
server.go#L1489: func (sc *serverConn) processResetStream(f *RSTStreamFrame) error {
server.go#L1508: func (sc *serverConn) closeStream(st *stream, err error) {
server.go#L1543: func (sc *serverConn) processSettings(f *SettingsFrame) error {
server.go#L1571: func (sc *serverConn) processSetting(s Setting) error {
server.go#L1604: func (sc *serverConn) processSettingInitialWindowSize(val uint32) error {
server.go#L1632: func (sc *serverConn) processData(f *DataFrame) error {
server.go#L1735: func (sc *serverConn) processGoAway(f *GoAwayFrame) error {
server.go#L1787: func (sc *serverConn) processHeaders(f *MetaHeadersFrame) error {
server.go#L1943: func (sc *serverConn) processPriority(f *PriorityFrame) error {
server.go#L1954: func (sc *serverConn) newStream(id, pusherID uint32, state streamState) *stream {
server.go#L1991: func (sc *serverConn) newWriterAndRequest(st *stream, f *MetaHeadersFrame) (*responseWriter, *http.Request, error) {
server.go#L2061: func (sc *serverConn) newWriterAndRequestNoBody(st *stream, rp requestParam) (*responseWriter, *http.Request, error) {
server.go#L2147: func (sc *serverConn) runHandler(rw *responseWriter, req *http.Request, handler func(http.ResponseWriter, *http.Request)) {
server.go#L2184: func (sc *serverConn) writeHeaders(st *stream, headerData *writeResHeaders) error {
server.go#L2216: func (sc *serverConn) write100ContinueHeaders(st *stream) {
server.go#L2233: func (sc *serverConn) noteBodyReadFromHandler(st *stream, n int, err error) {
server.go#L2243: func (sc *serverConn) noteBodyRead(st *stream, n int) {
server.go#L2254: func (sc *serverConn) sendWindowUpdate(st *stream, n int) {
server.go#L2270: func (sc *serverConn) sendWindowUpdate32(st *stream, n int32) {
server.go#L2302: conn *serverConn
server.go#L2358: conn *serverConn
server.go#L2843: func (sc *serverConn) startPush(msg *startPushRequest) {
 |
The pages are generated with Golds v0.3.2-preview. (GOOS=darwin GOARCH=amd64)
Golds is a Go 101 project developed by Tapir Liu.
PR and bug reports are welcome and can be submitted to the issue list.
Please follow @Go100and1 (reachable from the left QR code) to get the latest news of Golds. |