Lines Matching refs:shard
64 uint64_t shard() const { return be64toh(shard_be); } in shard() function
105 uint64_t shard; in run() local
109 shard = shards_pending_queue_.front(); in run()
111 shards_pending_set_.reset(shard); in run()
113 readOnceFromShard(shard); in run()
117 void readOnceFromShard(uint64_t shard) { in readOnceFromShard()
118 ShardState& state = (*shard_states_)[shard]; in readOnceFromShard()
124 state.upper_bound = Key(shard, std::numeric_limits<uint64_t>::max()); in readOnceFromShard()
150 Key from(shard, state.last_read.load() + 1); in readOnceFromShard()
166 assert(key.shard() == shard); in readOnceFromShard()
174 void onWrite(uint64_t shard) { in onWrite()
177 if (!shards_pending_set_.test(shard)) { in onWrite()
178 shards_pending_queue_.push(shard); in onWrite()
179 shards_pending_set_.set(shard); in onWrite()
241 uint64_t shard = my_shards[shard_dist(rng)]; in run() local
242 ShardState& state = (*shard_states_)[shard]; in run()
244 Key key(shard, seqno); in run()
252 state.reader->onWrite(shard); in run()