| 2232 | } |
| 2233 | |
| 2234 | static void raw_socket_process(int rank) |
| 2235 | { |
| 2236 | if (sipcapture_db_init(&db_url) < 0 ){ |
| 2237 | LM_ERR("unable to open database connection\n"); |
| 2238 | return; |
| 2239 | } |
| 2240 | |
| 2241 | raw_capture_rcv_loop(raw_sock_desc, moni_port_start, moni_port_end, |
| 2242 | moni_capture_on ? 0 : 1); |
| 2243 | |
| 2244 | /* Destroy DB socket */ |
| 2245 | sipcapture_db_close(); |
| 2246 | } |
| 2247 | |
| 2248 | static int do_remaining_queries(str* query_str) { |
| 2249 | if (!db_con) { |
nothing calls this directly
no test coverage detected