]>
Commit | Line | Data |
---|---|---|
bae9f6d2 JC |
1 | package yamux |
2 | ||
3 | // asyncSendErr is used to try an async send of an error | |
4 | func asyncSendErr(ch chan error, err error) { | |
5 | if ch == nil { | |
6 | return | |
7 | } | |
8 | select { | |
9 | case ch <- err: | |
10 | default: | |
11 | } | |
12 | } | |
13 | ||
14 | // asyncNotify is used to signal a waiting goroutine | |
15 | func asyncNotify(ch chan struct{}) { | |
16 | select { | |
17 | case ch <- struct{}{}: | |
18 | default: | |
19 | } | |
20 | } | |
21 | ||
22 | // min computes the minimum of two values | |
23 | func min(a, b uint32) uint32 { | |
24 | if a < b { | |
25 | return a | |
26 | } | |
27 | return b | |
28 | } |