Lines Matching defs:Reader
89 struct Reader { struct
91 explicit Reader(std::vector<ShardState>* shard_states, in Reader() function
98 void run() { in run()
117 void readOnceFromShard(uint64_t shard) { in readOnceFromShard()
185 ~Reader() { in ~Reader() argument
192 char pad1[128] __attribute__((__unused__));
193 std::vector<ShardState>* shard_states_;
194 ROCKSDB_NAMESPACE::DB* db_;
195 ROCKSDB_NAMESPACE::port::Thread thread_;
196 sem_t sem_;
197 std::mutex queue_mutex_;
198 std::bitset<MAX_SHARDS + 1> shards_pending_set_;
199 std::queue<uint64_t> shards_pending_queue_;
200 std::atomic<bool> done_{false};
201 char pad2[128] __attribute__((__unused__));