| 5345 | } |
| 5346 | |
| 5347 | static inline void raise_rtpengine_status_event(struct rtpe_node *node) |
| 5348 | { |
| 5349 | static str status_connected = str_init("active"); |
| 5350 | static str status_disconnected = str_init("inactive"); |
| 5351 | |
| 5352 | if (rtpengine_status_event == EVI_ERROR) { |
| 5353 | LM_ERR("event %.*s not registered (%d)\n", rtpengine_status_event_name.len, |
| 5354 | rtpengine_status_event_name.s, rtpengine_status_event); |
| 5355 | return; |
| 5356 | } |
| 5357 | if (!evi_probe_event(rtpengine_status_event)) { |
| 5358 | LM_DBG("no %.*s event subscriber!\n", rtpengine_status_event_name.len, |
| 5359 | rtpengine_status_event_name.s); |
| 5360 | return; |
| 5361 | } |
| 5362 | |
| 5363 | if (evi_param_set_str(rtpengine_status_event_socket, &node->rn_url) < 0) { |
| 5364 | LM_ERR("cannot set rtpengine status set parameter\n"); |
| 5365 | return; |
| 5366 | } |
| 5367 | if (evi_param_set_str(rtpengine_status_event_status, node->rn_disabled? |
| 5368 | &status_disconnected:&status_connected) < 0) { |
| 5369 | LM_ERR("cannot set rtpengine status parameter\n"); |
| 5370 | return; |
| 5371 | } |
| 5372 | if (evi_param_set_int(rtpengine_status_event_set, &node->set) < 0) { |
| 5373 | LM_ERR("cannot set rtpengine status parameter\n"); |
| 5374 | return; |
| 5375 | } |
| 5376 | if (evi_raise_event(rtpengine_status_event, rtpengine_status_event_params)) |
| 5377 | LM_ERR("unable to send event\n"); |
| 5378 | } |
no test coverage detected