GGLinnk/bees
1
0
Fork 0
mirror of https://github.com/Zygo/bees.git synced 2025-05-17 21:35:45 +02:00
Code Packages

roots: clean up crawl_master

Browse Source 
Remove some broken #if 0 code, and take advantage of new Task
non-repeating execution semantics.

Signed-off-by: Zygo Blaxell <bees@furryterror.org>
This commit is contained in:
Zygo Blaxell 2021-05-30 00:59:27 -04:00
parent 4f032ab85b
commit ffac407a9b
1 changed files with 0 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/bees-roots.cc
View File

@ -375,20 +375,11 @@ BeesRoots::crawl_thread()
m_crawl_task = Task("crawl_master", [shared_this]() { m_crawl_task = Task("crawl_master", [shared_this]() {
auto tqs = TaskMaster::get_queue_count(); auto tqs = TaskMaster::get_queue_count();
BEESNOTE("queueing extents to scan, " << tqs << " of " << BEES_MAX_QUEUE_SIZE); BEESNOTE("queueing extents to scan, " << tqs << " of " << BEES_MAX_QUEUE_SIZE);
#if 0
bool run_again = true; bool run_again = true;
while (tqs < BEES_MAX_QUEUE_SIZE && run_again) { while (tqs < BEES_MAX_QUEUE_SIZE && run_again) {
run_again = shared_this->crawl_roots(); run_again = shared_this->crawl_roots();
tqs = TaskMaster::get_queue_count(); tqs = TaskMaster::get_queue_count();
} }
#else
bool run_again = false;
while (tqs < BEES_MAX_QUEUE_SIZE) {
run_again = shared_this->crawl_roots();
tqs = TaskMaster::get_queue_count();
if (!run_again) break;
}
#endif
if (run_again) { if (run_again) {
shared_this->m_crawl_task.run(); shared_this->m_crawl_task.run();
} }