| 551 | } |
| 552 | |
| 553 | bool event::has_subscriber(eventgroup_t _eventgroup, client_t _client) { |
| 554 | |
| 555 | std::scoped_lock its_lock(eventgroups_mutex_); |
| 556 | auto find_eventgroup = eventgroups_.find(_eventgroup); |
| 557 | if (find_eventgroup != eventgroups_.end()) { |
| 558 | if (_client == ANY_CLIENT) { |
| 559 | return (find_eventgroup->second.size() > 0); |
| 560 | } else { |
| 561 | return (find_eventgroup->second.contains(_client)); |
| 562 | } |
| 563 | } |
| 564 | return false; |
| 565 | } |
| 566 | |
| 567 | std::set<client_t> event::get_subscribers() { |
| 568 |
no test coverage detected