| 985 | } |
| 986 | |
| 987 | static bool runtime_worker_send_frame(cbm_daemon_runtime_worker_t *worker, |
| 988 | cbm_daemon_frame_type_t type, |
| 989 | cbm_daemon_runtime_operation_t operation, const void *payload, |
| 990 | uint32_t length) { |
| 991 | if (!worker) { |
| 992 | return false; |
| 993 | } |
| 994 | cbm_mutex_lock(&worker->send_mutex); |
| 995 | bool sent = |
| 996 | worker->connection && |
| 997 | cbm_daemon_ipc_send_frame(worker->connection, type, (uint16_t)operation, payload, length); |
| 998 | cbm_mutex_unlock(&worker->send_mutex); |
| 999 | return sent; |
| 1000 | } |
| 1001 | |
| 1002 | static bool runtime_worker_send_status(cbm_daemon_runtime_worker_t *worker, |
| 1003 | cbm_daemon_runtime_operation_t operation, bool success) { |
no test coverage detected