Lines Matching refs:state
118 ShardState& state = (*shard_states_)[shard]; in readOnceFromShard() local
119 if (!state.it) { in readOnceFromShard()
124 state.upper_bound = Key(shard, std::numeric_limits<uint64_t>::max()); in readOnceFromShard()
125 state.upper_bound_slice = ROCKSDB_NAMESPACE::Slice( in readOnceFromShard()
126 (const char*)&state.upper_bound, sizeof(state.upper_bound)); in readOnceFromShard()
127 options.iterate_upper_bound = &state.upper_bound_slice; in readOnceFromShard()
130 state.it.reset(db_->NewIterator(options)); in readOnceFromShard()
134 state.it_cacheonly.reset(db_->NewIterator(options)); in readOnceFromShard()
138 const uint64_t upto = state.last_written.load(); in readOnceFromShard()
140 {state.it_cacheonly.get(), state.it.get()}) { in readOnceFromShard()
144 if (state.last_read.load() >= upto) { in readOnceFromShard()
148 for (uint64_t seq = state.last_read.load() + 1; seq <= upto; ++seq) { in readOnceFromShard()
150 Key from(shard, state.last_read.load() + 1); in readOnceFromShard()
168 state.last_read.store(seq); in readOnceFromShard()
242 ShardState& state = (*shard_states_)[shard]; in run() local
243 uint64_t seqno = state.last_written.load() + 1; in run()
251 state.last_written.store(seqno); in run()
252 state.reader->onWrite(shard); in run()