parent
8c20124612
commit
97165dd278
|
@ -369,7 +369,6 @@ struct RocksDBKeyValueStore : IKeyValueStore {
|
|||
a->batchToCommit = std::move(writeBatch);
|
||||
auto res = a->done.getFuture();
|
||||
writeThread->post(a);
|
||||
threadYield();
|
||||
return res;
|
||||
}
|
||||
|
||||
|
@ -377,7 +376,6 @@ struct RocksDBKeyValueStore : IKeyValueStore {
|
|||
auto a = new Reader::ReadValueAction(key, debugID);
|
||||
auto res = a->result.getFuture();
|
||||
readThreads->post(a);
|
||||
threadYield();
|
||||
return res;
|
||||
}
|
||||
|
||||
|
@ -385,7 +383,6 @@ struct RocksDBKeyValueStore : IKeyValueStore {
|
|||
auto a = new Reader::ReadValuePrefixAction(key, maxLength, debugID);
|
||||
auto res = a->result.getFuture();
|
||||
readThreads->post(a);
|
||||
threadYield();
|
||||
return res;
|
||||
}
|
||||
|
||||
|
@ -393,7 +390,6 @@ struct RocksDBKeyValueStore : IKeyValueStore {
|
|||
auto a = new Reader::ReadRangeAction(keys, rowLimit, byteLimit);
|
||||
auto res = a->result.getFuture();
|
||||
readThreads->post(a);
|
||||
threadYield();
|
||||
return res;
|
||||
}
|
||||
|
||||
|
|
Loading…
Reference in New Issue