()
| 823 | } |
| 824 | |
| 825 | func (g *streamSilenceGuard) settle() bool { |
| 826 | g.mu.Lock() |
| 827 | defer g.mu.Unlock() |
| 828 | if g.settled { |
| 829 | return false |
| 830 | } |
| 831 | g.settled = true |
| 832 | return true |
| 833 | } |
| 834 | |
| 835 | func (g *streamSilenceGuard) onTimeout() { |
| 836 | if !g.settle() { |