| 977 | } |
| 978 | |
| 979 | static bool runtime_worker_send_frame(cbm_daemon_runtime_worker_t *worker, |
| 980 | cbm_daemon_frame_type_t type, |
| 981 | cbm_daemon_runtime_operation_t operation, const void *payload, |
| 982 | uint32_t length) { |
| 983 | if (!worker) { |
| 984 | return false; |
| 985 | } |
| 986 | cbm_mutex_lock(&worker->send_mutex); |
| 987 | bool sent = |
| 988 | worker->connection && |
| 989 | cbm_daemon_ipc_send_frame(worker->connection, type, (uint16_t)operation, payload, length); |
| 990 | cbm_mutex_unlock(&worker->send_mutex); |
| 991 | return sent; |
| 992 | } |
| 993 | |
| 994 | static bool runtime_worker_send_status(cbm_daemon_runtime_worker_t *worker, |
| 995 | cbm_daemon_runtime_operation_t operation, bool success) { |
no test coverage detected