SKIPPED SEQUENCE QUEUE
(x uint64)
| 1017 | // ////// SKIPPED SEQUENCE QUEUE |
| 1018 | |
| 1019 | func (c *changeCache) RemoveSkipped(x uint64) error { |
| 1020 | _, numSkipped, err := c.skippedSeqs.list.Remove(NewSingleSkippedSequenceEntryAt(x, 0)) |
| 1021 | if err != nil { |
| 1022 | return fmt.Errorf("sequence %d not found in the skipped list, err: %v", x, err) |
| 1023 | } |
| 1024 | if numSkipped == 0 { |
| 1025 | c.db.BroadcastSlowMode.CompareAndSwap(true, false) |
| 1026 | } |
| 1027 | return nil |
| 1028 | } |
| 1029 | |
| 1030 | func (c *changeCache) WasSkipped(x uint64) bool { |
| 1031 | return c.skippedSeqs.Contains(x) |
no test coverage detected