| 739 | } |
| 740 | |
| 741 | void ReadSequential(ThreadState* thread) { |
| 742 | Iterator* iter = db_->NewIterator(ReadOptions()); |
| 743 | int i = 0; |
| 744 | int64_t bytes = 0; |
| 745 | for (iter->SeekToFirst(); i < reads_ && iter->Valid(); iter->Next()) { |
| 746 | bytes += iter->key().size() + iter->value().size(); |
| 747 | thread->stats.FinishedSingleOp(); |
| 748 | ++i; |
| 749 | } |
| 750 | delete iter; |
| 751 | thread->stats.AddBytes(bytes); |
| 752 | } |
| 753 | |
| 754 | void ReadReverse(ThreadState* thread) { |
| 755 | Iterator* iter = db_->NewIterator(ReadOptions()); |
nothing calls this directly
no test coverage detected