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

roots: update Task print functions for new usage

Browse Source 
This restores the old "crawl" prefix in the case of Crawler log messages.

Signed-off-by: Zygo Blaxell <bees@furryterror.org>
This commit is contained in:
Zygo Blaxell 2018-01-20 00:55:40 -05:00 committed by Zygo Blaxell
parent 5063a635fc
commit 4c05c53d28
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
src/bees-roots.cc
View File

@ -250,12 +250,13 @@ BeesRoots::crawl_roots()
size_t batch_count = 0; size_t batch_count = 0;
while (first_range && batch_count < BEES_MAX_CRAWL_BATCH) { while (first_range && batch_count < BEES_MAX_CRAWL_BATCH) {
auto subvol = first_crawl->get_state().m_root;
Task([ctx_copy, first_range]() { Task([ctx_copy, first_range]() {
BEESNOTE("scan_forward " << first_range); BEESNOTE("scan_forward " << first_range);
ctx_copy->scan_forward(first_range); ctx_copy->scan_forward(first_range);
}, },
[first_range](ostream &os) -> ostream & { [first_range, subvol](ostream &os) -> ostream & {
return os << "scan_forward " << first_range; return os << "crawl_" << subvol;
}).run(); }).run();
BEESCOUNT(crawl_scan); BEESCOUNT(crawl_scan);
m_crawl_current = first_crawl->get_state(); m_crawl_current = first_crawl->get_state();
@ -279,12 +280,13 @@ BeesRoots::crawl_roots()
auto this_range = this_crawl->peek_front(); auto this_range = this_crawl->peek_front();
size_t batch_count = 0; size_t batch_count = 0;
while (this_range && batch_count < BEES_MAX_CRAWL_BATCH) { while (this_range && batch_count < BEES_MAX_CRAWL_BATCH) {
auto subvol = this_crawl->get_state().m_root;
Task([ctx_copy, this_range]() { Task([ctx_copy, this_range]() {
BEESNOTE("scan_forward " << this_range); BEESNOTE("scan_forward " << this_range);
ctx_copy->scan_forward(this_range); ctx_copy->scan_forward(this_range);
}, },
[this_range](ostream &os) -> ostream & { [this_range, subvol](ostream &os) -> ostream & {
return os << "scan_forward " << this_range; return os << "crawl_" << subvol;
}).run(); }).run();
crawled = true; crawled = true;
BEESCOUNT(crawl_scan); BEESCOUNT(crawl_scan);
@ -330,7 +332,7 @@ BeesRoots::crawl_thread()
tqs = TaskMaster::get_queue_count(); tqs = TaskMaster::get_queue_count();
} }
Task::current_task().run(); Task::current_task().run();
}, [](ostream &os) -> ostream& { return os << "crawl task"; }).run(); }, [](ostream &os) -> ostream& { return os << "crawl"; }).run();
} }
void void