12345678910111213141516171819202122232425262728 |
- package yamux
- // asyncSendErr is used to try an async send of an error
- func asyncSendErr(ch chan error, err error) {
- if ch == nil {
- return
- }
- select {
- case ch <- err:
- default:
- }
- }
- // asyncNotify is used to signal a waiting goroutine
- func asyncNotify(ch chan struct{}) {
- select {
- case ch <- struct{}{}:
- default:
- }
- }
- // min computes the minimum of two values
- func min(a, b uint32) uint32 {
- if a < b {
- return a
- }
- return b
- }
|