(tx *Tx)
| 1066 | } |
| 1067 | |
| 1068 | func (db *DB) sendToWriteCh(tx *Tx) (*request, error) { |
| 1069 | req := requestPool.Get().(*request) |
| 1070 | req.reset() |
| 1071 | req.Wg.Add(1) |
| 1072 | req.tx = tx |
| 1073 | req.IncrRef() // for db write |
| 1074 | db.writeCh <- req // Handled in doWrites. |
| 1075 | return req, nil |
| 1076 | } |
| 1077 | |
| 1078 | func (db *DB) checkListExpired() { |
| 1079 | db.Index.List.rangeIdx(func(l *data.List) { |
no test coverage detected