Function rtpproxy_io_callback

modules/rtpproxy/notification_process.c:233–345

}

static int rtpproxy_io_callback(int fd, void *fs, int was_timeout)
{
	struct rtpp_notify *notify = (struct rtpp_notify *)fs;
	char buffer[BUF_LEN+1];
	int len, left, offset, total, entered = 0;
	str command;
	char *p, *start, *sp, *end;

	profiling_proc_start( LEVEL_EXTRAPROCS, 1);

	if (notify && notify->remaining) {
		memcpy(buffer, notify->remaining, notify->remaining_len);
		offset = notify->remaining_len;
		pkg_free(notify->remaining);
		notify->remaining_len = 0;
		notify->remaining = NULL;
	} else {
		offset = 0;
	}

	for (;;) {
		if (offset == BUF_LEN) {
			LM_ERR("RTPProxy notification command too large [%.*s]\n",
					offset, buffer);
			free_rtpp_notify(fd, notify);
			goto err1;
		}

		do
			len = read(fd, buffer + offset, BUF_LEN - offset);
		while (len == -1 && errno == EINTR);

		if (len < 0) {
			if (errno == EAGAIN || errno == EWOULDBLOCK)
				break;

			LM_ERR("reading from socket failed: %s\n",strerror(errno));
			free_rtpp_notify(fd, notify);
			goto err1;
		}
		if (len == 0) {
			if (offset)
				LM_WARN("dropping partial RTPProxy notification [%.*s]\n",
						offset, buffer);
			LM_DBG("closing rtpproxy notify socket\n");
			free_rtpp_notify(fd, notify);
			goto done;
		}

		total = len + offset;
		buffer[total] = 0; // make it null terminated

		LM_DBG("Notification(s) received: [%.*s]\n", total, buffer);
		if (!entered) {
			profiling_proc_enter( LEVEL_EXTRAPROCS,
					ss_merge256("RTPP_CB ",buffer), 0 );
			entered = 1;
		}