Function rtpengine_io_callback

modules/rtpengine/rtpengine.c:4852–4898

#define RTPENGINE_DGRAM_BUF		35536

static int rtpengine_io_callback(int fd, void *fs, int was_timeout)
{
	int ret;
	char *p;
	char buffer[RTPENGINE_DGRAM_BUF];

	profiling_proc_start( LEVEL_EXTRAPROCS, 1);

	do
		ret = read(fd, buffer, RTPENGINE_DGRAM_BUF);
	while (ret == -1 && errno == EINTR);
	if (ret < 0) {
		LM_ERR("problem reading on socket %s:%u (%s:%d)\n",
				rtpengine_notify_sock.s, rtpengine_notify_port, strerror(errno), errno);
		goto err;
	}

	if (!evi_probe_event(rtpengine_notify_event)) {
		LM_DBG("nothing to do - nobody is listening!\n");
		goto done;
	}

	p = shm_malloc(ret + 1);
	if (!p) {
		/* coverity[string_null] - false positive CID #211356 */
		LM_ERR("could not allocate %d for buffer %.*s\n", ret, ret, buffer);
		goto err;
	}
	memcpy(p, buffer, ret);
	p[ret] = '\0';

	profiling_proc_enter( LEVEL_EXTRAPROCS, ss_merge256("RTPE_CB ",p), 0);

	LM_INFO("dispatching buffer: %s\n", p);
	if (ipc_dispatch_rpc(rtpengine_raise_event, p) < 0) {
		LM_ERR("could not dispatch notification job!\n");
		shm_free(p);
	}

	profiling_proc_exit( LEVEL_EXTRAPROCS, "RTPE_CB", 0);
	profiling_proc_end( LEVEL_EXTRAPROCS, 0 );
done:
	return 0;
err:
	profiling_proc_end( LEVEL_EXTRAPROCS, -1 );
	return -1;
}

static void rtpengine_notify_process(int rank)
{