Function xmlrpc_process

modules/event_xmlrpc/xmlrpc_send.c:513–549

}

void xmlrpc_process(int rank)
{
	enum evi_status status;

	/* init blocking reader */
	xmlrpc_init_reader();
	xmlrpc_init_send_buf();
	xmlrpc_send_t * xmlrpcs;

	/* suppress the E_CORE_LOG event for new logs while handling
	 * the event itself */
	suppress_proc_log_event();

	/* waiting for commands */
	for (;;) {
		xmlrpcs = xmlrpc_receive();
		if (!xmlrpcs) {
			LM_ERR("invalid receive sock info\n");
			goto end;
		}

		/* send msg */
		if (xmlrpc_sendmsg(xmlrpcs)) {
			LM_ERR("cannot send message\n");
			status = EVI_STATUS_FAIL;
		} else
			status = EVI_STATUS_SUCCESS;

		if (xmlrpcs->async_ctx.status_cb)
			xmlrpc_dispatch_status_cb(&xmlrpcs->async_ctx, status);
end:
		if (xmlrpcs)
			shm_free(xmlrpcs);
	}

	reset_proc_log_event();
}