()
| 111 | } |
| 112 | |
| 113 | func (r *Runtime) commitCycle() { |
| 114 | for { |
| 115 | var cReq *commitReq |
| 116 | |
| 117 | select { |
| 118 | case <-r.stopCh: |
| 119 | return |
| 120 | case cReq = <-r.commitCh: |
| 121 | } |
| 122 | |
| 123 | if cReq != nil { |
| 124 | r.doCommitCycle(cReq) |
| 125 | } |
| 126 | } |
| 127 | } |
| 128 | |
| 129 | func (r *Runtime) leaderDoCommit(req *commitReq) { |
| 130 | if req.log != nil { |
nothing calls this directly
no test coverage detected