Method evictSequences

worker/db_storage.go:157–180

()

}

func (db *Database) evictSequences() {
	m := make(map[uint64]*list.Element)
	l := list.New()

	for connSeq := range db.connSeqEvictCh {
		if e, ok := m[connSeq]; ok {
			l.MoveToFront(e)
			return
		}

		e := l.PushFront(connSeq)
		m[connSeq] = e

		if l.Len() > MaxRecordedConnectionSequences {
			e = l.Back()
			if e != nil {
				l.Remove(e)
				evictSeq := e.Value.(uint64)
				delete(m, evictSeq)
				db.connSeqs.Delete(evictSeq)
			}
		}
	}
}