()
| 131 | } |
| 132 | |
| 133 | func (e *Engine) nextAttemptIDLocked() uint64 { |
| 134 | e.state.nextAttempt++ |
| 135 | if e.state.nextAttempt == 0 { |
| 136 | e.state.nextAttempt++ |
| 137 | } |
| 138 | return e.state.nextAttempt |
| 139 | } |
| 140 | |
| 141 | func (e *Engine) commitAttempt(materialized materializedState, epoch, commitSeq, attemptID uint64) error { |
| 142 | if e == nil { |