| 153 | } |
| 154 | |
| 155 | static void stream_dispatch_status_cb(evi_async_ctx_t *async_ctx, |
| 156 | enum evi_status status) |
| 157 | { |
| 158 | struct stream_cb_ipc_param *cb_ipc_param; |
| 159 | |
| 160 | cb_ipc_param = shm_malloc(sizeof *cb_ipc_param); |
| 161 | if (!cb_ipc_param) { |
| 162 | LM_ERR("oom!\n"); |
| 163 | return; |
| 164 | } |
| 165 | |
| 166 | cb_ipc_param->async_ctx = *async_ctx; |
| 167 | cb_ipc_param->status = status; |
| 168 | |
| 169 | ipc_dispatch_rpc(stream_run_status_cb, cb_ipc_param); |
| 170 | } |
| 171 | |
| 172 | int stream_init_writer(void) |
| 173 | { |
no test coverage detected