| 493 | } |
| 494 | |
| 495 | size_t cbm_daemon_active_clients(cbm_daemon_coordinator_t *coordinator) { |
| 496 | if (!coordinator) { |
| 497 | return 0; |
| 498 | } |
| 499 | cbm_mutex_lock(&coordinator->mutex); |
| 500 | size_t count = coordinator->client_count; |
| 501 | cbm_mutex_unlock(&coordinator->mutex); |
| 502 | return count; |
| 503 | } |
| 504 | |
| 505 | cbm_daemon_subscription_result_t cbm_daemon_job_subscribe( |
| 506 | cbm_daemon_coordinator_t *coordinator, cbm_daemon_client_id_t client_id, |
no test coverage detected