()
| 675 | } |
| 676 | |
| 677 | func (cs *clientStream) commitAttempt() { |
| 678 | cs.mu.Lock() |
| 679 | cs.commitAttemptLocked() |
| 680 | cs.mu.Unlock() |
| 681 | } |
| 682 | |
| 683 | // shouldRetry returns nil if the RPC should be retried; otherwise it returns |
| 684 | // the error that should be returned by the operation. If the RPC should be |
no test coverage detected