(data []byte)
| 306 | } |
| 307 | |
| 308 | func (sm *StreamManager) handleReadData(data []byte) { |
| 309 | offset := 0 |
| 310 | for offset < len(data) { |
| 311 | n, waitCh := sm.buf.WriteAvailable(data[offset:]) |
| 312 | offset += n |
| 313 | |
| 314 | if n > 0 { |
| 315 | sm.lock.Lock() |
| 316 | sm.drainCond.Signal() |
| 317 | sm.lock.Unlock() |
| 318 | } |
| 319 | |
| 320 | if waitCh != nil { |
| 321 | <-waitCh |
| 322 | } |
| 323 | } |
| 324 | } |
| 325 | |
| 326 | func (sm *StreamManager) handleEOF() { |
| 327 | sm.lock.Lock() |
no test coverage detected