| 580 | } |
| 581 | |
| 582 | void sugoi_storage_t::query(const sugoi_query_t* q, sugoi_view_callback_t callback, void* u) |
| 583 | { |
| 584 | bool mainThread = true; |
| 585 | if (scheduler) |
| 586 | { |
| 587 | mainThread = scheduler->is_main_thread(this); |
| 588 | } |
| 589 | if (mainThread) |
| 590 | { |
| 591 | build_queries(); |
| 592 | } |
| 593 | else |
| 594 | SKR_ASSERT(queriesBuilt); |
| 595 | |
| 596 | auto filterChunk = [&](sugoi_group_t* group) { |
| 597 | query(group, q->filter, q->meta, q->customFilter, q->customFilterUserData, callback, u); |
| 598 | }; |
| 599 | query_groups(q, SUGOI_LAMBDA(filterChunk)); |
| 600 | } |
| 601 | |
| 602 | void sugoi_storage_t::destroy(const sugoi_query_t* q) |
| 603 | { |
no test coverage detected