| 694 | } |
| 695 | |
| 696 | size_t cbm_daemon_job_subscribers(cbm_daemon_coordinator_t *coordinator, const char *project_key) { |
| 697 | if (!coordinator || !project_key) { |
| 698 | return 0; |
| 699 | } |
| 700 | cbm_mutex_lock(&coordinator->mutex); |
| 701 | cbm_daemon_job_t *job = find_job_locked(coordinator, project_key); |
| 702 | size_t count = job ? job->subscription_count : 0; |
| 703 | cbm_mutex_unlock(&coordinator->mutex); |
| 704 | return count; |
| 705 | } |
| 706 | |
| 707 | size_t cbm_daemon_watch_subscribers(cbm_daemon_coordinator_t *coordinator, |
| 708 | const char *project_key) { |
no test coverage detected