(attempt *csAttempt)
| 914 | } |
| 915 | |
| 916 | func (cs *clientStream) replayBufferLocked(attempt *csAttempt) error { |
| 917 | for _, f := range cs.replayBuffer { |
| 918 | if err := f.op(attempt); err != nil { |
| 919 | return err |
| 920 | } |
| 921 | } |
| 922 | return nil |
| 923 | } |
| 924 | |
| 925 | func (cs *clientStream) bufferForRetryLocked(sz int, op func(a *csAttempt) error, cleanup func()) { |
| 926 | // Note: we still will buffer if retry is disabled (for transparent retries). |