()
| 1281 | } |
| 1282 | |
| 1283 | func (n *node) drainApplyChan() { |
| 1284 | numDrained := 0 |
| 1285 | for { |
| 1286 | select { |
| 1287 | case entries := <-n.applyCh: |
| 1288 | numDrained += len(entries) |
| 1289 | for _, entry := range entries { |
| 1290 | key := binary.BigEndian.Uint64(entry.Data[:8]) |
| 1291 | n.Proposals.Done(key, nil) |
| 1292 | n.Applied.Done(entry.Index) |
| 1293 | } |
| 1294 | default: |
| 1295 | glog.Infof("Drained %d proposals\n", numDrained) |
| 1296 | return |
| 1297 | } |
| 1298 | } |
| 1299 | } |
| 1300 | |
| 1301 | const tickDur = 100 * time.Millisecond |
| 1302 |