位置stream.go

1stream结构体

type stream struct {

mutex sync.Mutex//互斥锁，mutex.Lock()表示加锁，mutex.Unlock()解锁

ctx       context.Context

ctxCancel context.CancelFunc

streamID protocol.StreamID//streamID

onData   func()

//onReset is a callback that should send a RST_STREAM

onReset func(protocol.StreamID, protocol.ByteCount)//发送RST_STREAM的回调

readPosInFrame int

writeOffset    protocol.ByteCount

readOffset     protocol.ByteCount

//Once set, the errors must not be changed!

err error

// cancelled is set when Cancel() is called

cancelled utils.AtomicBool

// finishedReading is set once we read a frame with a FinBit一旦我们用FinBit读了一帧，finishedReading就开始了

finishedReading utils.AtomicBool

// finisedWriting is set once Close() is called

finishedWriting utils.AtomicBool

// resetLocally is set if Reset() is called

resetLocally utils.AtomicBool

// resetRemotely is set if RegisterRemoteError() is called

resetRemotely utils.AtomicBool

frameQueue   *streamFrameSorter

readChan     chan struct{}

readDeadline time.Time

dataForWriting []byte//写入的数据量

finSent        utils.AtomicBool

rstSent        utils.AtomicBool

writeChan      chan struct{}

writeDeadline  time.Time

flowControlManager flowcontrol.FlowControlManager

}