Searched refs:queue (Results 1 – 25 of 82) sorted by relevance
1234
242 auto* queue = &queue_[use_pri]; in Refill() local243 while (!queue->empty()) { in Refill()244 auto* next_req = queue->front(); in Refill()254 queue->pop_front(); in Refill()
64 std::queue<T> buffer_;
199 std::queue<uint64_t> shards_pending_queue_;212 std::queue<std::chrono::steady_clock::time_point> workq; in run()
114 std::queue<FileAndDir> queue_;
149 std::queue<std::string> old_log_files_;
96 std::queue<std::string> empty; in GetExistingFiles()
16 …ated thread pool. This alleviates head-of-line blocking in the compaction queue, which cause write…
47 …d when destroying iterators. Instead, a job is scheduled in high priority queue and would be execu…
51 range. This can involve arbitrarily long waits in the compaction queue, and
384 std::queue<std::pair<uint64_t, SnapshotState>> snapshot_queue;
32 * A message-queue that supports a high number of inserts and deletes.
86 [Uber](http://eng.uber.com/cherami/) uses RocksDB as a durable and scalable task queue.
4852 my @queue;4861 push @queue, $job;4864 push @queue, $job;4867 $self->unget(@queue);4868 $self->{'total_jobs'} = $#queue+1;
511 std::queue<CompactionJobStats> expected_stats_;
229 /usr/include/c++/v1/__algorithm/unique.h /usr/include/c++/v1/queue \
364 /usr/include/c++/v1/condition_variable /usr/include/c++/v1/queue \
402 /usr/include/xlocale/_inttypes.h /usr/include/c++/v1/queue
401 /usr/include/xlocale/_inttypes.h /usr/include/c++/v1/queue
235 /usr/include/c++/v1/__algorithm/unique.h /usr/include/c++/v1/queue \
403 /usr/include/c++/v1/queue \